Google Git
Sign in
apache / streampipes-website / bf42af0a2bd043307b827093b2417851ef5586c5 / . / website_old / website / img / pipeline-elements
tree: d9f6b429b3c007f8569983aa9053e397d7af76ce [path history] [tgz]
  1. org.apache.streampipes.connect.adapters.coindesk/
  2. org.apache.streampipes.connect.adapters.flic.mqtt/
  3. org.apache.streampipes.connect.adapters.gdelt/
  4. org.apache.streampipes.connect.adapters.iex.news/
  5. org.apache.streampipes.connect.adapters.iex.stocks/
  6. org.apache.streampipes.connect.adapters.image.set/
  7. org.apache.streampipes.connect.adapters.image.stream/
  8. org.apache.streampipes.connect.adapters.influxdb.set/
  9. org.apache.streampipes.connect.adapters.influxdb.stream/
  10. org.apache.streampipes.connect.adapters.iss/
  11. org.apache.streampipes.connect.adapters.mysql.set/
  12. org.apache.streampipes.connect.adapters.mysql.stream/
  13. org.apache.streampipes.connect.adapters.netio.mqtt/
  14. org.apache.streampipes.connect.adapters.netio.rest/
  15. org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/
  16. org.apache.streampipes.connect.adapters.opcua/
  17. org.apache.streampipes.connect.adapters.plc4x.modbus/
  18. org.apache.streampipes.connect.adapters.plc4x.s7/
  19. org.apache.streampipes.connect.adapters.ros/
  20. org.apache.streampipes.connect.adapters.simulator.machine/
  21. org.apache.streampipes.connect.adapters.simulator.randomdataset/
  22. org.apache.streampipes.connect.adapters.simulator.randomdatastream/
  23. org.apache.streampipes.connect.adapters.slack/
  24. org.apache.streampipes.connect.adapters.ti/
  25. org.apache.streampipes.connect.adapters.wikipedia.edit/
  26. org.apache.streampipes.connect.adapters.wikipedia.new/
  27. org.apache.streampipes.connect.protocol.stream.file/
  28. org.apache.streampipes.connect.protocol.stream.http/
  29. org.apache.streampipes.connect.protocol.stream.httpserver/
  30. org.apache.streampipes.connect.protocol.stream.kafka/
  31. org.apache.streampipes.connect.protocol.stream.mqtt/
  32. org.apache.streampipes.connect.protocol.stream.pulsar/
  33. org.apache.streampipes.processor.geo.flink/
  34. org.apache.streampipes.processor.geo.jvm.geocoding/
  35. org.apache.streampipes.processor.geo.jvm.reversegeocoding/
  36. org.apache.streampipes.processor.geo.jvm.staticgeocoding/
  37. org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/
  38. org.apache.streampipes.processor.imageclassification.jvm.image-cropper/
  39. org.apache.streampipes.processor.imageclassification.jvm.image-enricher/
  40. org.apache.streampipes.processor.imageclassification.qrcode/
  41. org.apache.streampipes.processors.aggregation.flink.aggregation/
  42. org.apache.streampipes.processors.aggregation.flink.count/
  43. org.apache.streampipes.processors.aggregation.flink.eventcount/
  44. org.apache.streampipes.processors.aggregation.flink.rate/
  45. org.apache.streampipes.processors.changedetection.jvm.cusum/
  46. org.apache.streampipes.processors.enricher.flink.processor.math.mathop/
  47. org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/
  48. org.apache.streampipes.processors.enricher.flink.processor.trigonometry/
  49. org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/
  50. org.apache.streampipes.processors.enricher.flink.timestamp/
  51. org.apache.streampipes.processors.enricher.jvm.jseval/
  52. org.apache.streampipes.processors.enricher.jvm.sizemeasure/
  53. org.apache.streampipes.processors.filters.jvm.compose/
  54. org.apache.streampipes.processors.filters.jvm.enrich/
  55. org.apache.streampipes.processors.filters.jvm.limit/
  56. org.apache.streampipes.processors.filters.jvm.merge/
  57. org.apache.streampipes.processors.filters.jvm.numericalfilter/
  58. org.apache.streampipes.processors.filters.jvm.numericaltextfilter/
  59. org.apache.streampipes.processors.filters.jvm.project/
  60. org.apache.streampipes.processors.filters.jvm.textfilter/
  61. org.apache.streampipes.processors.filters.jvm.threshold/
  62. org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/
  63. org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/
  64. org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/
  65. org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/
  66. org.apache.streampipes.processors.geo.jvm.processor.speed/
  67. org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator/
  68. org.apache.streampipes.processors.pattern-detection.flink.absence/
  69. org.apache.streampipes.processors.pattern-detection.flink.and/
  70. org.apache.streampipes.processors.pattern-detection.flink.peak-detection/
  71. org.apache.streampipes.processors.pattern-detection.flink.sequence/
  72. org.apache.streampipes.processors.siddhi.frequency/
  73. org.apache.streampipes.processors.siddhi.frequencychange/
  74. org.apache.streampipes.processors.siddhi.increase/
  75. org.apache.streampipes.processors.siddhi.numericalfilter/
  76. org.apache.streampipes.processors.siddhi.sequence/
  77. org.apache.streampipes.processors.siddhi.stop/
  78. org.apache.streampipes.processors.statistics.flink.statistics-summary/
  79. org.apache.streampipes.processors.textmining.flink.languagedetection/
  80. org.apache.streampipes.processors.textmining.flink.wordcount/
  81. org.apache.streampipes.processors.textmining.jvm.chunker/
  82. org.apache.streampipes.processors.textmining.jvm.languagedetection/
  83. org.apache.streampipes.processors.textmining.jvm.namefinder/
  84. org.apache.streampipes.processors.textmining.jvm.partofspeech/
  85. org.apache.streampipes.processors.textmining.jvm.sentencedetection/
  86. org.apache.streampipes.processors.textmining.jvm.tokenizer/
  87. org.apache.streampipes.processors.transformation.flink.field-converter/
  88. org.apache.streampipes.processors.transformation.flink.field-mapper/
  89. org.apache.streampipes.processors.transformation.flink.field-renamer/
  90. org.apache.streampipes.processors.transformation.flink.fieldhasher/
  91. org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/
  92. org.apache.streampipes.processors.transformation.flink.processor.boilerplate/
  93. org.apache.streampipes.processors.transformation.jvm.booloperator.counter/
  94. org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/
  95. org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/
  96. org.apache.streampipes.processors.transformation.jvm.booloperator.timer/
  97. org.apache.streampipes.processors.transformation.jvm.changed-value/
  98. org.apache.streampipes.processors.transformation.jvm.count-array/
  99. org.apache.streampipes.processors.transformation.jvm.csvmetadata/
  100. org.apache.streampipes.processors.transformation.jvm.duration-value/
  101. org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge/
  102. org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state/
  103. org.apache.streampipes.processors.transformation.jvm.processor.state.buffer/
  104. org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/
  105. org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number/
  106. org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state/
  107. org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/
  108. org.apache.streampipes.processors.transformation.jvm.split-array/
  109. org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/
  110. org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/
  111. org.apache.streampipes.processors.transformation.jvm.taskduration/
  112. org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/
  113. org.apache.streampipes.protocol.set.file/
  114. org.apache.streampipes.protocol.set.http/
  115. org.apache.streampipes.sinks.brokers.jvm.bufferrest/
  116. org.apache.streampipes.sinks.brokers.jvm.jms/
  117. org.apache.streampipes.sinks.brokers.jvm.kafka/
  118. org.apache.streampipes.sinks.brokers.jvm.mqtt/
  119. org.apache.streampipes.sinks.brokers.jvm.nats/
  120. org.apache.streampipes.sinks.brokers.jvm.pulsar/
  121. org.apache.streampipes.sinks.brokers.jvm.rabbitmq/
  122. org.apache.streampipes.sinks.brokers.jvm.rest/
  123. org.apache.streampipes.sinks.databases.ditto/
  124. org.apache.streampipes.sinks.databases.flink.elasticsearch/
  125. org.apache.streampipes.sinks.databases.jvm.couchdb/
  126. org.apache.streampipes.sinks.databases.jvm.influxdb/
  127. org.apache.streampipes.sinks.databases.jvm.iotdb/
  128. org.apache.streampipes.sinks.databases.jvm.mysql/
  129. org.apache.streampipes.sinks.databases.jvm.opcua/
  130. org.apache.streampipes.sinks.databases.jvm.postgresql/
  131. org.apache.streampipes.sinks.databases.jvm.redis/
  132. org.apache.streampipes.sinks.internal.jvm.dashboard/
  133. org.apache.streampipes.sinks.internal.jvm.datalake/
  134. org.apache.streampipes.sinks.internal.jvm.notification/
  135. org.apache.streampipes.sinks.notifications.jvm.email/
  136. org.apache.streampipes.sinks.notifications.jvm.onesignal/
  137. org.apache.streampipes.sinks.notifications.jvm.slack/
  138. org.apache.streampipes.sinks.notifications.jvm.telegram/
  139. org.streampipes.processor.geo.flink/
  140. org.streampipes.processor.imageclassification.image-rectifier/
  141. org.streampipes.processor.imageclassification.jvm.generic-image-classification/
  142. org.streampipes.processor.imageclassification.jvm.image-cropper/
  143. org.streampipes.processor.imageclassification.jvm.image-enricher/
  144. org.streampipes.processor.imageclassification.qrcode/
  145. org.streampipes.processors.aggregation.flink.aggregation/
  146. org.streampipes.processors.aggregation.flink.count/
  147. org.streampipes.processors.aggregation.flink.rate/
  148. org.streampipes.processors.enricher.flink.processor.math.mathop/
  149. org.streampipes.processors.enricher.flink.processor.math.staticmathop/
  150. org.streampipes.processors.enricher.flink.processor.trigonometry/
  151. org.streampipes.processors.enricher.flink.processor.urldereferencing/
  152. org.streampipes.processors.enricher.flink.timestamp/
  153. org.streampipes.processors.filters.jvm.compose/
  154. org.streampipes.processors.filters.jvm.numericalfilter/
  155. org.streampipes.processors.filters.jvm.processor.mergestartandend/
  156. org.streampipes.processors.filters.jvm.processor.pallettransportdetection/
  157. org.streampipes.processors.filters.jvm.project/
  158. org.streampipes.processors.filters.jvm.textfilter/
  159. org.streampipes.processors.geo.jvm.geocoder/
  160. org.streampipes.processors.geo.jvm.google-routing/
  161. org.streampipes.processors.pattern-detection.flink.absence/
  162. org.streampipes.processors.pattern-detection.flink.and/
  163. org.streampipes.processors.pattern-detection.flink.increase/
  164. org.streampipes.processors.pattern-detection.flink.peak-detection/
  165. org.streampipes.processors.pattern-detection.flink.sequence/
  166. org.streampipes.processors.siddhi.frequency/
  167. org.streampipes.processors.siddhi.frequencychange/
  168. org.streampipes.processors.siddhi.increase/
  169. org.streampipes.processors.siddhi.numericalfilter/
  170. org.streampipes.processors.siddhi.sequence/
  171. org.streampipes.processors.siddhi.stop/
  172. org.streampipes.processors.statistics.flink.statistics-summary/
  173. org.streampipes.processors.textmining.flink.languagedetection/
  174. org.streampipes.processors.textmining.flink.wordcount/
  175. org.streampipes.processors.transformation.flink.field-converter/
  176. org.streampipes.processors.transformation.flink.field-mapper/
  177. org.streampipes.processors.transformation.flink.field-renamer/
  178. org.streampipes.processors.transformation.flink.fieldhasher/
  179. org.streampipes.processors.transformation.flink.measurement-unit-converter/
  180. org.streampipes.processors.transformation.flink.processor.boilerplate/
  181. org.streampipes.processors.transformation.jvm.changed-value/
  182. org.streampipes.processors.transformation.jvm.count-array/
  183. org.streampipes.processors.transformation.jvm.duration-value/
  184. org.streampipes.processors.transformation.jvm.processor.timestampextractor/
  185. org.streampipes.processors.transformation.jvm.split-array/
  186. org.streampipes.sinks.brokers.jvm.jms/
  187. org.streampipes.sinks.brokers.jvm.kafka/
  188. org.streampipes.sinks.brokers.jvm.rabbitmq/
  189. org.streampipes.sinks.brokers.jvm.rest/
  190. org.streampipes.sinks.databases.flink.elasticsearch/
  191. org.streampipes.sinks.databases.jvm.couchdb/
  192. org.streampipes.sinks.databases.jvm.influxdb/
  193. org.streampipes.sinks.databases.jvm.postgresql/
  194. org.streampipes.sinks.internal.jvm.dashboard/
  195. org.streampipes.sinks.internal.jvm.notification/
  196. org.streampipes.sinks.notifications.jvm.email/
  197. org.streampipes.sinks.notifications.jvm.onesignal/
  198. org.streampipes.sinks.notifications.jvm.slack/