Sign in
apache
/
streampipes-website
/
6d69150b17d472e783092151bbf1851773200ed6
/
.
/
website
/
img
/
pipeline-elements
tree: d9f6b429b3c007f8569983aa9053e397d7af76ce [
path history
]
[
tgz
]
org.apache.streampipes.connect.adapters.coindesk/
org.apache.streampipes.connect.adapters.flic.mqtt/
org.apache.streampipes.connect.adapters.gdelt/
org.apache.streampipes.connect.adapters.iex.news/
org.apache.streampipes.connect.adapters.iex.stocks/
org.apache.streampipes.connect.adapters.image.set/
org.apache.streampipes.connect.adapters.image.stream/
org.apache.streampipes.connect.adapters.influxdb.set/
org.apache.streampipes.connect.adapters.influxdb.stream/
org.apache.streampipes.connect.adapters.iss/
org.apache.streampipes.connect.adapters.mysql.set/
org.apache.streampipes.connect.adapters.mysql.stream/
org.apache.streampipes.connect.adapters.netio.mqtt/
org.apache.streampipes.connect.adapters.netio.rest/
org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/
org.apache.streampipes.connect.adapters.opcua/
org.apache.streampipes.connect.adapters.plc4x.modbus/
org.apache.streampipes.connect.adapters.plc4x.s7/
org.apache.streampipes.connect.adapters.ros/
org.apache.streampipes.connect.adapters.simulator.machine/
org.apache.streampipes.connect.adapters.simulator.randomdataset/
org.apache.streampipes.connect.adapters.simulator.randomdatastream/
org.apache.streampipes.connect.adapters.slack/
org.apache.streampipes.connect.adapters.ti/
org.apache.streampipes.connect.adapters.wikipedia.edit/
org.apache.streampipes.connect.adapters.wikipedia.new/
org.apache.streampipes.connect.protocol.stream.file/
org.apache.streampipes.connect.protocol.stream.http/
org.apache.streampipes.connect.protocol.stream.httpserver/
org.apache.streampipes.connect.protocol.stream.kafka/
org.apache.streampipes.connect.protocol.stream.mqtt/
org.apache.streampipes.connect.protocol.stream.pulsar/
org.apache.streampipes.processor.geo.flink/
org.apache.streampipes.processor.geo.jvm.geocoding/
org.apache.streampipes.processor.geo.jvm.reversegeocoding/
org.apache.streampipes.processor.geo.jvm.staticgeocoding/
org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/
org.apache.streampipes.processor.imageclassification.jvm.image-cropper/
org.apache.streampipes.processor.imageclassification.jvm.image-enricher/
org.apache.streampipes.processor.imageclassification.qrcode/
org.apache.streampipes.processors.aggregation.flink.aggregation/
org.apache.streampipes.processors.aggregation.flink.count/
org.apache.streampipes.processors.aggregation.flink.eventcount/
org.apache.streampipes.processors.aggregation.flink.rate/
org.apache.streampipes.processors.changedetection.jvm.cusum/
org.apache.streampipes.processors.enricher.flink.processor.math.mathop/
org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/
org.apache.streampipes.processors.enricher.flink.processor.trigonometry/
org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/
org.apache.streampipes.processors.enricher.flink.timestamp/
org.apache.streampipes.processors.enricher.jvm.jseval/
org.apache.streampipes.processors.enricher.jvm.sizemeasure/
org.apache.streampipes.processors.filters.jvm.compose/
org.apache.streampipes.processors.filters.jvm.enrich/
org.apache.streampipes.processors.filters.jvm.limit/
org.apache.streampipes.processors.filters.jvm.merge/
org.apache.streampipes.processors.filters.jvm.numericalfilter/
org.apache.streampipes.processors.filters.jvm.numericaltextfilter/
org.apache.streampipes.processors.filters.jvm.project/
org.apache.streampipes.processors.filters.jvm.textfilter/
org.apache.streampipes.processors.filters.jvm.threshold/
org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/
org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/
org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/
org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/
org.apache.streampipes.processors.geo.jvm.processor.speed/
org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator/
org.apache.streampipes.processors.pattern-detection.flink.absence/
org.apache.streampipes.processors.pattern-detection.flink.and/
org.apache.streampipes.processors.pattern-detection.flink.peak-detection/
org.apache.streampipes.processors.pattern-detection.flink.sequence/
org.apache.streampipes.processors.siddhi.frequency/
org.apache.streampipes.processors.siddhi.frequencychange/
org.apache.streampipes.processors.siddhi.increase/
org.apache.streampipes.processors.siddhi.numericalfilter/
org.apache.streampipes.processors.siddhi.sequence/
org.apache.streampipes.processors.siddhi.stop/
org.apache.streampipes.processors.statistics.flink.statistics-summary/
org.apache.streampipes.processors.textmining.flink.languagedetection/
org.apache.streampipes.processors.textmining.flink.wordcount/
org.apache.streampipes.processors.textmining.jvm.chunker/
org.apache.streampipes.processors.textmining.jvm.languagedetection/
org.apache.streampipes.processors.textmining.jvm.namefinder/
org.apache.streampipes.processors.textmining.jvm.partofspeech/
org.apache.streampipes.processors.textmining.jvm.sentencedetection/
org.apache.streampipes.processors.textmining.jvm.tokenizer/
org.apache.streampipes.processors.transformation.flink.field-converter/
org.apache.streampipes.processors.transformation.flink.field-mapper/
org.apache.streampipes.processors.transformation.flink.field-renamer/
org.apache.streampipes.processors.transformation.flink.fieldhasher/
org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/
org.apache.streampipes.processors.transformation.flink.processor.boilerplate/
org.apache.streampipes.processors.transformation.jvm.booloperator.counter/
org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/
org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/
org.apache.streampipes.processors.transformation.jvm.booloperator.timer/
org.apache.streampipes.processors.transformation.jvm.changed-value/
org.apache.streampipes.processors.transformation.jvm.count-array/
org.apache.streampipes.processors.transformation.jvm.csvmetadata/
org.apache.streampipes.processors.transformation.jvm.duration-value/
org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge/
org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state/
org.apache.streampipes.processors.transformation.jvm.processor.state.buffer/
org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/
org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number/
org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state/
org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/
org.apache.streampipes.processors.transformation.jvm.split-array/
org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/
org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/
org.apache.streampipes.processors.transformation.jvm.taskduration/
org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/
org.apache.streampipes.protocol.set.file/
org.apache.streampipes.protocol.set.http/
org.apache.streampipes.sinks.brokers.jvm.bufferrest/
org.apache.streampipes.sinks.brokers.jvm.jms/
org.apache.streampipes.sinks.brokers.jvm.kafka/
org.apache.streampipes.sinks.brokers.jvm.mqtt/
org.apache.streampipes.sinks.brokers.jvm.nats/
org.apache.streampipes.sinks.brokers.jvm.pulsar/
org.apache.streampipes.sinks.brokers.jvm.rabbitmq/
org.apache.streampipes.sinks.brokers.jvm.rest/
org.apache.streampipes.sinks.databases.ditto/
org.apache.streampipes.sinks.databases.flink.elasticsearch/
org.apache.streampipes.sinks.databases.jvm.couchdb/
org.apache.streampipes.sinks.databases.jvm.influxdb/
org.apache.streampipes.sinks.databases.jvm.iotdb/
org.apache.streampipes.sinks.databases.jvm.mysql/
org.apache.streampipes.sinks.databases.jvm.opcua/
org.apache.streampipes.sinks.databases.jvm.postgresql/
org.apache.streampipes.sinks.databases.jvm.redis/
org.apache.streampipes.sinks.internal.jvm.dashboard/
org.apache.streampipes.sinks.internal.jvm.datalake/
org.apache.streampipes.sinks.internal.jvm.notification/
org.apache.streampipes.sinks.notifications.jvm.email/
org.apache.streampipes.sinks.notifications.jvm.onesignal/
org.apache.streampipes.sinks.notifications.jvm.slack/
org.apache.streampipes.sinks.notifications.jvm.telegram/
org.streampipes.processor.geo.flink/
org.streampipes.processor.imageclassification.image-rectifier/
org.streampipes.processor.imageclassification.jvm.generic-image-classification/
org.streampipes.processor.imageclassification.jvm.image-cropper/
org.streampipes.processor.imageclassification.jvm.image-enricher/
org.streampipes.processor.imageclassification.qrcode/
org.streampipes.processors.aggregation.flink.aggregation/
org.streampipes.processors.aggregation.flink.count/
org.streampipes.processors.aggregation.flink.rate/
org.streampipes.processors.enricher.flink.processor.math.mathop/
org.streampipes.processors.enricher.flink.processor.math.staticmathop/
org.streampipes.processors.enricher.flink.processor.trigonometry/
org.streampipes.processors.enricher.flink.processor.urldereferencing/
org.streampipes.processors.enricher.flink.timestamp/
org.streampipes.processors.filters.jvm.compose/
org.streampipes.processors.filters.jvm.numericalfilter/
org.streampipes.processors.filters.jvm.processor.mergestartandend/
org.streampipes.processors.filters.jvm.processor.pallettransportdetection/
org.streampipes.processors.filters.jvm.project/
org.streampipes.processors.filters.jvm.textfilter/
org.streampipes.processors.geo.jvm.geocoder/
org.streampipes.processors.geo.jvm.google-routing/
org.streampipes.processors.pattern-detection.flink.absence/
org.streampipes.processors.pattern-detection.flink.and/
org.streampipes.processors.pattern-detection.flink.increase/
org.streampipes.processors.pattern-detection.flink.peak-detection/
org.streampipes.processors.pattern-detection.flink.sequence/
org.streampipes.processors.siddhi.frequency/
org.streampipes.processors.siddhi.frequencychange/
org.streampipes.processors.siddhi.increase/
org.streampipes.processors.siddhi.numericalfilter/
org.streampipes.processors.siddhi.sequence/
org.streampipes.processors.siddhi.stop/
org.streampipes.processors.statistics.flink.statistics-summary/
org.streampipes.processors.textmining.flink.languagedetection/
org.streampipes.processors.textmining.flink.wordcount/
org.streampipes.processors.transformation.flink.field-converter/
org.streampipes.processors.transformation.flink.field-mapper/
org.streampipes.processors.transformation.flink.field-renamer/
org.streampipes.processors.transformation.flink.fieldhasher/
org.streampipes.processors.transformation.flink.measurement-unit-converter/
org.streampipes.processors.transformation.flink.processor.boilerplate/
org.streampipes.processors.transformation.jvm.changed-value/
org.streampipes.processors.transformation.jvm.count-array/
org.streampipes.processors.transformation.jvm.duration-value/
org.streampipes.processors.transformation.jvm.processor.timestampextractor/
org.streampipes.processors.transformation.jvm.split-array/
org.streampipes.sinks.brokers.jvm.jms/
org.streampipes.sinks.brokers.jvm.kafka/
org.streampipes.sinks.brokers.jvm.rabbitmq/
org.streampipes.sinks.brokers.jvm.rest/
org.streampipes.sinks.databases.flink.elasticsearch/
org.streampipes.sinks.databases.jvm.couchdb/
org.streampipes.sinks.databases.jvm.influxdb/
org.streampipes.sinks.databases.jvm.postgresql/
org.streampipes.sinks.internal.jvm.dashboard/
org.streampipes.sinks.internal.jvm.notification/
org.streampipes.sinks.notifications.jvm.email/
org.streampipes.sinks.notifications.jvm.onesignal/
org.streampipes.sinks.notifications.jvm.slack/