You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2020/05/24 20:24:11 UTC
[incubator-streampipes-website] 02/03: Improve docs structure,
add new pipeline elements to documentation
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-website.git
commit e4a146c969ac7738328086f5854c2df79bf4f51a
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Sun May 24 22:21:16 2020 +0200
Improve docs structure, add new pipeline elements to documentation
---
.../documentation.md | 31 --
.../documentation.md | 35 ---
...pache.streampipes.connect.adapters.coindesk.md} | 23 +-
...g.apache.streampipes.connect.adapters.gdelt.md} | 23 +-
...pache.streampipes.connect.adapters.iex.news.md} | 26 +-
...che.streampipes.connect.adapters.iex.stocks.md} | 24 +-
...ache.streampipes.connect.adapters.image.set.md} | 23 +-
...e.streampipes.connect.adapters.image.stream.md} | 23 +-
...e.streampipes.connect.adapters.influxdb.set.md} | 20 +-
...treampipes.connect.adapters.influxdb.stream.md} | 20 +-
...org.apache.streampipes.connect.adapters.iss.md} | 22 +-
...ache.streampipes.connect.adapters.mysql.set.md} | 22 +-
...e.streampipes.connect.adapters.mysql.stream.md} | 22 +-
...che.streampipes.connect.adapters.netio.mqtt.md} | 23 +-
...che.streampipes.connect.adapters.netio.rest.md} | 23 +-
...connect.adapters.nswaustralia.trafficcamera.md} | 22 +-
...g.apache.streampipes.connect.adapters.opcua.md} | 19 +-
...pache.streampipes.connect.adapters.plc4x.s7.md} | 22 +-
...org.apache.streampipes.connect.adapters.ros.md} | 28 +-
...es.connect.adapters.simulator.randomdataset.md} | 22 +-
...connect.adapters.simulator.randomdatastream.md} | 22 +-
...g.apache.streampipes.connect.adapters.slack.md} | 19 +-
.../org.apache.streampipes.connect.adapters.ti.md} | 29 +-
...streampipes.connect.adapters.wikipedia.edit.md} | 22 +-
....streampipes.connect.adapters.wikipedia.new.md} | 22 +-
...he.streampipes.connect.protocol.stream.file.md} | 23 +-
...he.streampipes.connect.protocol.stream.http.md} | 23 +-
...e.streampipes.connect.protocol.stream.kafka.md} | 23 +-
...he.streampipes.connect.protocol.stream.mqtt.md} | 25 +-
....streampipes.connect.protocol.stream.pulsar.md} | 23 +-
.../org.apache.streampipes.processor.geo.flink.md} | 21 +-
...che.streampipes.processor.geo.jvm.geocoding.md} | 0
...eampipes.processor.geo.jvm.reversegeocoding.md} | 2 +
...reampipes.processor.geo.jvm.staticgeocoding.md} | 0
...sification.jvm.generic-image-classification.md} | 0
...essor.imageclassification.jvm.image-cropper.md} | 29 +-
...ssor.imageclassification.jvm.image-enricher.md} | 20 +-
...mpipes.processor.imageclassification.qrcode.md} | 0
...es.processors.aggregation.flink.aggregation.md} | 0
...eampipes.processors.aggregation.flink.count.md} | 14 +-
...pes.processors.aggregation.flink.eventcount.md} | 0
...reampipes.processors.aggregation.flink.rate.md} | 0
...essors.enricher.flink.processor.math.mathop.md} | 0
....enricher.flink.processor.math.staticmathop.md} | 0
...ssors.enricher.flink.processor.trigonometry.md} | 0
...s.enricher.flink.processor.urldereferencing.md} | 0
...ampipes.processors.enricher.flink.timestamp.md} | 0
...ampipes.processors.enricher.jvm.sizemeasure.md} | 27 +-
....streampipes.processors.filters.jvm.compose.md} | 0
...e.streampipes.processors.filters.jvm.enrich.md} | 0
...he.streampipes.processors.filters.jvm.merge.md} | 2 +-
...ipes.processors.filters.jvm.numericalfilter.md} | 0
....processors.filters.jvm.numericaltextfilter.md} | 0
....streampipes.processors.filters.jvm.project.md} | 0
...reampipes.processors.filters.jvm.textfilter.md} | 0
...treampipes.processors.filters.jvm.threshold.md} | 0
...processors.geo.jvm.jts.processor.latLngToGeo.md | 73 +++++
...es.processors.geo.jvm.jts.processor.setEPSG.md} | 32 +-
....processors.geo.jvm.jts.processor.trajectory.md | 83 +++++
...essors.geo.jvm.processor.distancecalculator.md} | 3 +-
...eampipes.processors.geo.jvm.processor.speed.md} | 34 +--
....geo.jvm.processor.staticdistancecalculator.md} | 15 +-
....processors.pattern-detection.flink.absence.md} | 10 +-
...ipes.processors.pattern-detection.flink.and.md} | 10 +-
...sors.pattern-detection.flink.peak-detection.md} | 0
...processors.pattern-detection.flink.sequence.md} | 10 +-
...che.streampipes.processors.siddhi.frequency.md} | 0
...reampipes.processors.siddhi.frequencychange.md} | 0
...ache.streampipes.processors.siddhi.increase.md} | 0
...reampipes.processors.siddhi.numericalfilter.md} | 0
...ache.streampipes.processors.siddhi.sequence.md} | 19 --
...g.apache.streampipes.processors.siddhi.stop.md} | 0
...cessors.statistics.flink.statistics-summary.md} | 33 +-
...ocessors.textmining.flink.languagedetection.md} | 0
...pipes.processors.textmining.flink.wordcount.md} | 0
...reampipes.processors.textmining.jvm.chunker.md} | 2 +
...processors.textmining.jvm.languagedetection.md} | 2 +
...mpipes.processors.textmining.jvm.namefinder.md} | 5 +-
...ipes.processors.textmining.jvm.partofspeech.md} | 2 +
...processors.textmining.jvm.sentencedetection.md} | 2 +
...ampipes.processors.textmining.jvm.tokenizer.md} | 2 +
...essors.transformation.flink.field-converter.md} | 0
...rocessors.transformation.flink.field-mapper.md} | 41 ++-
...ocessors.transformation.flink.field-renamer.md} | 0
...processors.transformation.flink.fieldhasher.md} | 2 +-
...sformation.flink.measurement-unit-converter.md} | 0
....transformation.flink.processor.boilerplate.md} | 15 +-
...ors.transformation.jvm.booloperator.counter.md} | 0
...rs.transformation.jvm.booloperator.inverter.md} | 0
...transformation.jvm.booloperator.timekeeping.md} | 0
...ssors.transformation.jvm.booloperator.timer.md} | 0
...processors.transformation.jvm.changed-value.md} | 14 +-
...s.processors.transformation.jvm.count-array.md} | 0
...es.processors.transformation.jvm.csvmetadata.md | 76 +++++
...rocessors.transformation.jvm.duration-value.md} | 15 +-
...sformation.jvm.processor.timestampextractor.md} | 0
...s.processors.transformation.jvm.split-array.md} | 0
...s.transformation.jvm.stringoperator.counter.md} | 30 +-
...ors.transformation.jvm.stringoperator.timer.md} | 26 +-
....processors.transformation.jvm.taskduration.md} | 0
...ors.transformation.jvm.transform-to-boolean.md} | 23 +-
.../org.apache.streampipes.protocol.set.file.md} | 20 +-
.../org.apache.streampipes.protocol.set.http.md} | 20 +-
...he.streampipes.sinks.brokers.jvm.bufferrest.md} | 0
...rg.apache.streampipes.sinks.brokers.jvm.jms.md} | 0
....apache.streampipes.sinks.brokers.jvm.kafka.md} | 0
...g.apache.streampipes.sinks.brokers.jvm.mqtt.md} | 18 +-
...apache.streampipes.sinks.brokers.jvm.pulsar.md} | 0
...ache.streampipes.sinks.brokers.jvm.rabbitmq.md} | 0
...g.apache.streampipes.sinks.brokers.jvm.rest.md} | 0
...rg.apache.streampipes.sinks.databases.ditto.md} | 14 +-
...ampipes.sinks.databases.flink.elasticsearch.md} | 0
...che.streampipes.sinks.databases.jvm.couchdb.md} | 0
...he.streampipes.sinks.databases.jvm.influxdb.md} | 0
...pache.streampipes.sinks.databases.jvm.iotdb.md} | 0
...pache.streampipes.sinks.databases.jvm.opcua.md} | 0
....streampipes.sinks.databases.jvm.postgresql.md} | 0
...he.streampipes.sinks.internal.jvm.dashboard.md} | 0
...che.streampipes.sinks.internal.jvm.datalake.md} | 0
...streampipes.sinks.internal.jvm.notification.md} | 0
...e.streampipes.sinks.notifications.jvm.email.md} | 0
...reampipes.sinks.notifications.jvm.onesignal.md} | 0
...e.streampipes.sinks.notifications.jvm.slack.md} | 0
documentation/docs/pipeline-elements.md | 2 +-
documentation/website/i18n/en.json | 334 ++++++++++++++++-----
documentation/website/sidebars.json | 126 +++++++-
documentation/website/siteConfig.js | 2 +-
.../icon.png | Bin 0 -> 17868 bytes
.../icon.png | Bin 0 -> 33450 bytes
.../icon.png | Bin 0 -> 15675 bytes
.../icon.png | Bin 0 -> 15675 bytes
.../icon.png | Bin 0 -> 5332 bytes
.../icon.png | Bin 0 -> 5332 bytes
.../icon.png | Bin 0 -> 9982 bytes
.../icon.png | Bin 0 -> 9982 bytes
.../icon.png | Bin 0 -> 42675 bytes
.../icon.png | Bin 0 -> 99909 bytes
.../icon.png | Bin 0 -> 99909 bytes
.../icon.png | Bin 0 -> 35364 bytes
.../icon.png | Bin 0 -> 35364 bytes
.../icon.png | Bin 0 -> 3016 bytes
.../icon.png | Bin 0 -> 5087 bytes
.../icon.png | Bin 0 -> 46022 bytes
.../icon.png | Bin 0 -> 4838 bytes
.../icon.png | Bin 0 -> 13079 bytes
.../icon.png | Bin 0 -> 13079 bytes
.../icon.png | Bin 0 -> 17473 bytes
.../icon.png | Bin 0 -> 12579 bytes
.../icon.png | Bin 0 -> 65221 bytes
.../icon.png | Bin 0 -> 65221 bytes
.../icon.png | Bin 0 -> 12881 bytes
.../icon.png | Bin 0 -> 17467 bytes
.../icon.png | Bin 0 -> 9110 bytes
.../icon.png | Bin 0 -> 22561 bytes
.../icon.png | Bin 0 -> 22890 bytes
.../icon.png | Bin 3475 -> 9425 bytes
.../icon.png | Bin 0 -> 4372 bytes
.../icon.png | Bin 0 -> 4738 bytes
.../icon.png | Bin 0 -> 20621 bytes
.../icon.png | Bin 0 -> 8710 bytes
.../icon.png | Bin 0 -> 9399 bytes
.../icon.png | Bin 0 -> 14632 bytes
.../icon.png | Bin
.../icon.png | Bin
.../icon.png | Bin 0 -> 2516 bytes
.../icon.png | Bin 0 -> 710 bytes
.../icon.png | Bin 0 -> 4378 bytes
.../icon.png | Bin 3475 -> 11398 bytes
.../icon.png | Bin 3475 -> 12389 bytes
.../icon.png | Bin 3475 -> 13055 bytes
.../icon.png | Bin 0 -> 16458 bytes
.../icon.png | Bin 0 -> 14398 bytes
.../icon.png | Bin 0 -> 12881 bytes
.../icon.png | Bin 0 -> 17467 bytes
.../icon.png | Bin 0 -> 68540 bytes
175 files changed, 1047 insertions(+), 887 deletions(-)
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.jvm.sizemeasure/documentation.md b/documentation/docs/org.apache.streampipes.processors.enricher.jvm.sizemeasure/documentation.md
deleted file mode 100644
index 89ad791..0000000
--- a/documentation/docs/org.apache.streampipes.processors.enricher.jvm.sizemeasure/documentation.md
+++ /dev/null
@@ -1,31 +0,0 @@
----
-id: org.apache.streampipes.processors.enricher.jvm.sizemeasure
-title: Size Measure
-sidebar_label: Size Measure
----
-
-
-
-<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.sizemeasure/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Measures the size of an incoming event and appends this number to the event by serializing it.
-
-***
-
-## Required input
-The size measure processor does not have any specific input requirements.
-
-***
-
-## Configuration
-
-You can specify if the size should be in Bytes, Kilobytes (1024 Bytes) or in Megabytes (1024 Kilobytes).
-
-## Output
-The size measure processor appends the size of the event (without the field, which is getting added) as a double. The rest of the event stays the same.
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/documentation.md b/documentation/docs/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/documentation.md
deleted file mode 100644
index 078ca8d..0000000
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/documentation.md
+++ /dev/null
@@ -1,35 +0,0 @@
----
-id: org.apache.streampipes.processors.transformation.jvm.transform-to-boolean
-title: Transform to boolean
-sidebar_label: Transform to boolean
----
-
-
-
-<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-This processor inverts a specific boolean
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md
index 3e1f1e4..082a400 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.coindesk
+title: Coindesk Bitcoin Price
+sidebar_label: Coindesk Bitcoin Price
---
<!--
@@ -25,27 +25,20 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.coindesk/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
+This adapter continuously provides the current bitcoin price from the Coindesk API.
-Calculates the frequency of the event stream.
+## Configuration
-***
+### Currency
-## Required input
+The current in which the price should be provided.
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md
index 3e1f1e4..d739cc4 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.gdelt
+title: GDELT
+sidebar_label: GDELT
---
<!--
@@ -25,27 +25,18 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.gdelt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
-
-
-***
+This adapter provides news events from the GDELT API.
## Configuration
-### 1st parameter
+(no futher configuration required)
-### 2nd parameter
+***
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.news.md
similarity index 67%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.news.md
index e01b688..aa420cb 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.news.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.connect.adapters.iex.news
+title: IEX Cloud News
+sidebar_label: IEX Cloud News
---
<!--
@@ -25,30 +25,24 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.news/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Groups spatial events into cells of a given size
-Add a detailed description here
-
-***
-
-## Required input
-
+This adapter provides news events from the IEXCloud news API. An API key from IEXCloud is required.
+Visit <a href='https://iexcloud.io'>IEX Cloud</a> for more info.
***
## Configuration
-Describe the configuration parameters here
-### 1st parameter
+### API Token
+A valid API token from the IEXCloud API.
+### Stock Symbol
+A stock symbol that should be monitored.
-### 2nd parameter
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md
similarity index 68%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md
index 3e1f1e4..042eba0 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.iex.stocks
+title: IEX Cloud Stock Quotes
+sidebar_label: IEX Cloud Stock Quotes
---
<!--
@@ -25,27 +25,23 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.stocks/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
-
+This adapter provides news events from the IEXCloud news API. An API key from IEXCloud is required.
+Visit <a href='https://iexcloud.io'>IEX Cloud</a> for more info.
***
## Configuration
-### 1st parameter
+### API Token
+A valid API token from the IEXCloud API.
-### 2nd parameter
+### Stock Symbol
+A stock symbol that should be monitored.
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.image.set.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.image.set.md
index 3e1f1e4..3bc8aa0 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.image.set.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.image.set
+title: Image Upload (Set)
+sidebar_label: Image Upload (Set)
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.set/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
+Upload a zip file of images and create an event per image
-Calculates the frequency of the event stream.
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md
index 3e1f1e4..12516e3 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.image.stream
+title: Image Upload (Stream)
+sidebar_label: Image Upload (Stream)
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.stream/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
+Upload a zip file of images and create an event per image
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md
index 3e1f1e4..fa258e8 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.influxdb.set
+title: InfluxDB Set Adapter
+sidebar_label: InfluxDB Set Adapter
---
<!--
@@ -25,27 +25,17 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.set/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
-
+Creates a data set for an InfluxDB measurement.
***
## Configuration
-### 1st parameter
-
-### 2nd parameter
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md
index 3e1f1e4..53d226b 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.influxdb.stream
+title: InfluxDB Stream Adapter
+sidebar_label: InfluxDB Stream Adapter
---
<!--
@@ -25,27 +25,17 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.stream/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
-
+Creates a data stream for an InfluxDB measurement.
***
## Configuration
-### 1st parameter
-
-### 2nd parameter
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iss.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.iss.md
index 3e1f1e4..53cf6f5 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.iss.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.iss
+title: ISS Location
+sidebar_label: ISS Location
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.iss/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Shows the live position of the International Space Station (ISS), updated every two seconds.
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md
index 3e1f1e4..97b9a49 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.mysql.set
+title: MySQL Set Adapter
+sidebar_label: MySQL Set Adapter
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.set/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Creates a data set from an SQL table
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md
index 3e1f1e4..0ef2646 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.mysql.stream
+title: MySql Stream Adapter
+sidebar_label: MySql Stream Adapter
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.stream/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Creates a data stream for a SQL table
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md
similarity index 75%
copy from documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md
index 65a1e14..e81df5f 100644
--- a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.databases.jvm.couchdb
-title: CouchDB
-sidebar_label: CouchDB
+id: org.apache.streampipes.connect.adapters.netio.mqtt
+title: NETIO MQTT M2M
+sidebar_label: NETIO MQTT M2M
---
<!--
@@ -25,14 +25,15 @@ sidebar_label: CouchDB
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.databases.jvm.couchdb/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Stores events in an Apache CouchDB database.
+Connect Robots running on ROS
+
***
@@ -46,18 +47,18 @@ This sink does not have any requirements and works with any incoming event type.
Describe the configuration parameters here
-### Hostname
+### Ros Bridge
-The hostname of the CouchDB instance.
+Example: test-server.com (No protocol)
### Port
-The port of the CouchDB instance.
+The port of the ROS instance.
+
+### Topic
-### Database Name
+Example: /battery (Starts with /)
-The name of the database where events will be stored
## Output
-(not applicable for data sinks)
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md
similarity index 75%
copy from documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md
index 65a1e14..06cf7ab 100644
--- a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.databases.jvm.couchdb
-title: CouchDB
-sidebar_label: CouchDB
+id: org.apache.streampipes.connect.adapters.netio.rest
+title: NETIO http JSON
+sidebar_label: NETIO http JSON
---
<!--
@@ -25,14 +25,15 @@ sidebar_label: CouchDB
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.databases.jvm.couchdb/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.rest/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Stores events in an Apache CouchDB database.
+Connect Robots running on ROS
+
***
@@ -46,18 +47,18 @@ This sink does not have any requirements and works with any incoming event type.
Describe the configuration parameters here
-### Hostname
+### Ros Bridge
-The hostname of the CouchDB instance.
+Example: test-server.com (No protocol)
### Port
-The port of the CouchDB instance.
+The port of the ROS instance.
+
+### Topic
-### Database Name
+Example: /battery (Starts with /)
-The name of the database where events will be stored
## Output
-(not applicable for data sinks)
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md
index 3e1f1e4..eb441f9 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera
+title: NSW Traffic Cameras
+sidebar_label: NSW Traffic Cameras
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Traffic camera images produced by NSW Australia
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.opcua.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.opcua.md
index 3e7b038..c664fe1 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.opcua.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.jvm.csvmetadata
-title: CSV Metadata Enricher
-sidebar_label: CSV Metadata Enricher
+id: org.apache.streampipes.connect.adapters.opcua
+title: OPC UA
+sidebar_label: OPC UA
---
<!--
@@ -24,21 +24,16 @@ sidebar_label: CSV Metadata Enricher
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.opcua/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
***
## Description
-
-***
-
-## Required input
+Read values from an OPC-UA server
***
-## Configuration
-
-
-
-## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md
index 3e1f1e4..bd9f0f7 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.plc4x.s7
+title: PLC4X S7
+sidebar_label: PLC4X S7
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Shows the live position of the International Space Station (ISS), updated every two seconds.
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.ros.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.ros.md
index 138d979..707794a 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.ros.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.textmining.flink.wordcount
-title: Word Count
-sidebar_label: Word Count
+id: org.apache.streampipes.connect.adapters.ros
+title: ROS Bridge
+sidebar_label: ROS Bridge
---
<!--
@@ -25,30 +25,40 @@ sidebar_label: Word Count
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.textmining.flink.wordcount/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.ros/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Counts words on continuous text-based streams
-Add a detailed description here
+Connect Robots running on ROS
+
***
## Required input
+
***
## Configuration
Describe the configuration parameters here
-### 1st parameter
+### Ros Bridge
+
+Example: test-server.com (No protocol)
+
+### Port
+
+The port of the ROS instance.
+
+### Topic
+
+Example: /battery (Starts with /)
-### 2nd parameter
+## Output
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md
index 3e1f1e4..e0bb669 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.simulator.randomdataset
+title: Random Data Simulator (Set)
+sidebar_label: Random Data Simulator (Set)
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Publishes a bounded stream of random events.
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md
index 3e1f1e4..b8dc5d3 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.simulator.randomdatastream
+title: Random Data Simulator (Stream)
+sidebar_label: Random Data Simulator (Stream)
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Publishes a continuous stream of random events
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.slack.md
similarity index 75%
copy from documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.slack.md
index 3e7b038..904449c 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.slack.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.jvm.csvmetadata
-title: CSV Metadata Enricher
-sidebar_label: CSV Metadata Enricher
+id: org.apache.streampipes.connect.adapters.slack
+title: Slack
+sidebar_label: Slack
---
<!--
@@ -24,21 +24,16 @@ sidebar_label: CSV Metadata Enricher
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.slack/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
***
## Description
-
-***
-
-## Required input
+Subscribes to a Slack channel
***
-## Configuration
-
-
-
-## Output
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.ti.md
similarity index 71%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.ti.md
index e01b688..746f289 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.ti.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.connect.adapters.ti
+title: TI Sensor Tag
+sidebar_label: TI Sensor Tag
---
<!--
@@ -25,19 +25,14 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.ti/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Groups spatial events into cells of a given size
-Add a detailed description here
-
-***
-
-## Required input
+Consumes messages from a broker using the MQTT protocol
***
@@ -46,9 +41,17 @@ Add a detailed description here
Describe the configuration parameters here
-### 1st parameter
+### Broker Url
+
+Example: tcp://test-server.com:1883 (Protocol required. Port required)"
+
+### Topic
+
+Example: test/topic
+
+### Access Mode
+Unauthenticated or Authenticated (Username/Password)
-### 2nd parameter
+## Output
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md
index 3e1f1e4..084f512 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.wikipedia.edit
+title: Wikipedia Edits
+sidebar_label: Wikipedia Edits
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Continuously publishes recent Wikipedia edits
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md
index 3e1f1e4..b275165 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.adapters.wikipedia.new
+title: Wikipedia New Articles
+sidebar_label: Wikipedia New Articles
---
<!--
@@ -25,27 +25,15 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
+Continuously publishes articles created on Wikipedia
***
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
index 3e1f1e4..431f35c 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.protocol.stream.file
+title: File Stream
+sidebar_label: File Stream
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
+Continuously streams the content from a file
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.http.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.http.md
index 3e1f1e4..1d366fa 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.http.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.protocol.stream.http
+title: HTTP Stream
+sidebar_label: HTTP Stream
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.http/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
+Continuously fetched events from an HTTP REST endpoint.
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md
index 3e1f1e4..25bd5f1 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.protocol.stream.kafka
+title: Apache Kafka
+sidebar_label: Apache Kafka
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.kafka/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
+Consumes messages from an Apache Kafka broker
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md
similarity index 71%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md
index e01b688..4c1afa7 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.connect.protocol.stream.mqtt
+title: MQTT
+sidebar_label: MQTT
---
<!--
@@ -25,19 +25,14 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Groups spatial events into cells of a given size
-Add a detailed description here
-
-***
-
-## Required input
+Consumes messages from a broker using the MQTT protocol
***
@@ -46,9 +41,13 @@ Add a detailed description here
Describe the configuration parameters here
-### 1st parameter
+### Broker Url
+
+Example: tcp://test-server.com:1883 (Protocol required. Port required)"
+
+### Access Mode
+Unauthenticated or Authenticated (Username/Password)
-### 2nd parameter
+## Output
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md
similarity index 73%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md
index 3e1f1e4..cf18f45 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
+id: org.apache.streampipes.connect.protocol.stream.pulsar
+title: Apache Pulsar
+sidebar_label: Apache Pulsar
---
<!--
@@ -25,27 +25,14 @@ sidebar_label: Frequency Calculation
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.frequency/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.pulsar/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the frequency of the event stream.
+Consumes messages from an Apache Pulsar broker
***
-## Required input
-
-
-***
-
-## Configuration
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.geo.flink.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processor.geo.flink.md
index e01b688..2a81ad0 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processor.geo.flink.md
@@ -32,23 +32,20 @@ sidebar_label: Spatial Grid Enrichment
## Description
-Groups spatial events into cells of a given size
-Add a detailed description here
+Groups spatial events into cells of a given size.
+The result is like a chessboard pattern in which the geo coordinates are inserted. The user can define the coordinates of the first field.
***
## Required input
-
-
-***
+Requires a latitude and longitude in the data stream.
## Configuration
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
+* Latitude property
+* Longitude property
+* The size of the cell
+* Latitude and longitude of the first cell
-## Output
\ No newline at end of file
+## Output
+Appends the grid cell coordinates to the input event
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.jvm.geocoding/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.geocoding.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processor.geo.jvm.geocoding/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.geocoding.md
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.jvm.reversegeocoding/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md
similarity index 82%
rename from documentation/docs/org.apache.streampipes.processor.geo.jvm.reversegeocoding/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md
index 754096b..5b1a4e7 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.jvm.reversegeocoding/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md
@@ -33,6 +33,8 @@ sidebar_label: Reverse Geocoder
This processor computes place name based on given lat/lng coordinates that are transmitted as fields from an event.
+This processor automatically downloads the file cities1000.zip from Geonames (http://download.geonames.org/export/dump/cities1000.zip). This file is provided under the CC BY 4.0 license, see https://creativecommons.org/licenses/by/4.0/ for license details.
+
***
## Required input
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.jvm.staticgeocoding/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processor.geo.jvm.staticgeocoding/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding.md
diff --git a/documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md
diff --git a/documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
similarity index 70%
copy from documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
index 70c42f9..9bac240 100644
--- a/documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.imageclassification.jvm.image-enricher
-title: Image Enricher
-sidebar_label: Image Enricher
+id: org.apache.streampipes.processor.imageclassification.jvm.image-cropper
+title: Image Cropper
+sidebar_label: Image Cropper
---
<!--
@@ -23,32 +23,21 @@ sidebar_label: Image Enricher
-->
-
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-cropper/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Image Enrichment: Enriches an + image with + given bounding box coordinates
-Add a detailed description here
+Image Enrichment: Crops an + image based on + given bounding box coordinates
***
## Required input
+An image and an array with bounding boxes.
+A box consists of the x and y coordinates in the image as well as the height and width
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
+## Output
+A new event for each box containing the cropped image
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
similarity index 83%
rename from documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
index 70c42f9..d0ff9d2 100644
--- a/documentation/docs/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
@@ -33,22 +33,10 @@ sidebar_label: Image Enricher
## Description
Image Enrichment: Enriches an + image with + given bounding box coordinates
-Add a detailed description here
-
-***
## Required input
+An image and an array with bounding boxes.
+A box consists of the x and y coordinates in the image as well as the height and width
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
+## Output
+A new event containing the image with bounding boxes rendered according to the boxes of the input event
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.imageclassification.qrcode/documentation.md b/documentation/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processor.imageclassification.qrcode/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md
diff --git a/documentation/docs/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.aggregation.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.aggregation.md
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md
similarity index 68%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md
index e01b688..06533a5 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.processors.aggregation.flink.count
+title: Count Aggregation
+sidebar_label: Count Aggregation
---
<!--
@@ -25,15 +25,17 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.count/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Groups spatial events into cells of a given size
-Add a detailed description here
+Performs an aggregation based on a given field and outputs the number of occurrences.
+Example: Count the number of vehicle positions per vehicleId.
+The Count aggregation requires a time window, used to perform the count aggregation and a field used to aggregate
+ values.
***
diff --git a/documentation/docs/org.apache.streampipes.processors.aggregation.flink.eventcount/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.eventcount.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.aggregation.flink.eventcount/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.eventcount.md
diff --git a/documentation/docs/org.apache.streampipes.processors.aggregation.flink.rate/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.rate.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.aggregation.flink.rate/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.aggregation.flink.rate.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.math.mathop/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.math.mathop/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.trigonometry/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.trigonometry/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.timestamp/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.timestamp.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.enricher.flink.timestamp/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.enricher.flink.timestamp.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
similarity index 63%
copy from documentation/docs/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
index f91f6b9..79b9261 100644
--- a/documentation/docs/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.databases.flink.elasticsearch
-title: Elasticsearch
-sidebar_label: Elasticsearch
+id: org.apache.streampipes.processors.enricher.jvm.sizemeasure
+title: Size Measure
+sidebar_label: Size Measure
---
<!--
@@ -25,36 +25,25 @@ sidebar_label: Elasticsearch
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.databases.flink.elasticsearch/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.sizemeasure/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Stores data in an Elasticsearch database.
+Measures the size of an incoming event and appends this number to the event by serializing it.
***
## Required input
-
-This sink requires an event that provides a timestamp value (a field that is marked to be of type ``http://schema
-.org/DateTime``.
+The size measure processor does not have any specific input requirements.
***
## Configuration
-Describe the configuration parameters here
-
-### Timestamp Field
-
-The field which contains the required timestamp.
-
-### Index Name
-
-The name of the Elasticsearch index where events are stored to.
+You can specify if the size should be in Bytes, Kilobytes (1024 Bytes) or in Megabytes (1024 Kilobytes).
## Output
-
-(not applicable for data sinks)
\ No newline at end of file
+The size measure processor appends the size of the event (without the field, which is getting added) as a double. The rest of the event stays the same.
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.compose/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processors.filters.jvm.compose/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.enrich/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.enrich/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.merge/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
similarity index 89%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.merge/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
index 1ee7b6f..73bdee0 100644
--- a/documentation/docs/org.apache.streampipes.processors.filters.jvm.merge/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
@@ -38,7 +38,7 @@ Two events of the different streams are merged when they occure to the same time
The following figure shows how the events of the two data streams will be mergrged:
<p align="center">
- <img width="width: 50%;" src="/docs/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.merge/merge_description.png" class="pe-image-documentation"/>
+ <img width="300px;" src="/docs/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.merge/merge_description.png" class="pe-image-documentation"/>
</p>
***
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.numericalfilter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.numericalfilter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.numericaltextfilter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.numericaltextfilter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.numericaltextfilter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.numericaltextfilter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.project/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.project/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.textfilter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.textfilter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.threshold/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.threshold.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.threshold/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.filters.jvm.threshold.md
diff --git a/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md
new file mode 100644
index 0000000..b4de938
--- /dev/null
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md
@@ -0,0 +1,73 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo
+title: Creates JTS Point
+sidebar_label: Creates JTS Point
+---
+
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one or more
+ ~ contributor license agreements. See the NOTICE file distributed with
+ ~ this work for additional information regarding copyright ownership.
+ ~ The ASF licenses this file to You under the Apache License, Version 2.0
+ ~ (the "License"); you may not use this file except in compliance with
+ ~ the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ ~
+ -->
+
+
+
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+This processor creates a JTS Point geometry from latitude and longitude value.
+
+***
+
+## Required input
+
+* Ontology Vocabulary Latitude
+* Ontology Vocabulary Longitude
+* Integer value representing EPSG Code
+
+
+***
+
+## Configuration
+
+Creates a JTS Geometry Point from Longitude (x) and Latitude (y) values in the coordinate reference system represented by the EPSG code.
+An empty point geometry is created if latitude or longitude value is missing in the event (e.g. null value) or values are out of range. Allowed values for Longitude are between -180.00 and 180.00; Latitude values between -90.00 and 90.00.
+
+### 1st parameter
+Latitude value
+
+### 2nd parameter
+Longitude value
+
+### 3rd parameter
+EPSG code value
+
+***
+
+## Output
+
+Adds a point geometry in the Well Known Text notation and in Longitude (x) Latitude (y) axis order to the stream.
+
+### Example
+* Input stream: <br>
+ `{latitude=48.5622, longitude=-76.3501, EPSG=4326}`
+
+* Output Stream <br>
+ `{latitude=48.5622, longitude=-76.3501, EPSG=4326, geom_wkt=POINT (-76.3501 48.5622)}`
diff --git a/documentation/docs/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md
similarity index 53%
rename from documentation/docs/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md
index 45656e5..d5839f6 100644
--- a/documentation/docs/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.aggregation.flink.aggregation
-title: Aggregation
-sidebar_label: Aggregation
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG
+title: EPSG Code
+sidebar_label: EPSG Code
---
<!--
@@ -24,38 +24,36 @@ sidebar_label: Aggregation
-<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.aggregation/icon.png" width="150px;" class="pe-image-documentation"/>
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
+
***
## Description
-Performs different aggregation functions based on a sliding time window (e.g., average, sum, min, max)
+This processor adds ab integer value to the stream. This integer value represents
+an [EPSG Code](https://en.wikipedia.org/wiki/EPSG_Geodetic_Parameter_Dataset) as an Spatial Reference System Identifier [(SRID)](https://en.wikipedia.org/wiki/Spatial_reference_system#Identifier).
+
***
## Required input
-The aggregation processor requires a data stream that has at least one field containing a numerical value.
+None
***
## Configuration
-### Group by
-The aaggregation function can be calculated separately (partitioned) by the selected field value.
+Integer values, representing a spatial reference system [(SRS)](https://en.wikipedia.org/wiki/Spatial_reference_system#Identifier). Other possible values can be looked up under https://spatialreference.org/ref/epsg/.
-### Output every
-The frequency in which aggregated values are sent in seconds.
+### Parameter
-### Time window
-The size of the time window in seconds
-
-### Aggregated Value
-The field used for calculating the aggregation value.
+4- to 5-digit key integer number. Default value is 4326 representing the World Geodetic System [(WGS84)](https://en.wikipedia.org/wiki/World_Geodetic_System#WGS84).
+***
## Output
-This processor appends the latest aggregated value to every input event that arrives.
\ No newline at end of file
+Adds a number to the event.
diff --git a/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md
new file mode 100644
index 0000000..0200f27
--- /dev/null
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md
@@ -0,0 +1,83 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory
+title: Single Trajectory Creator
+sidebar_label: Single Trajectory Creator
+---
+
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one or more
+ ~ contributor license agreements. See the NOTICE file distributed with
+ ~ this work for additional information regarding copyright ownership.
+ ~ The ASF licenses this file to You under the Apache License, Version 2.0
+ ~ (the "License"); you may not use this file except in compliance with
+ ~ the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ ~
+ -->
+
+
+
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+This processor creates a JTS LineString geometry from JTS Points events, represent a trajectory. A trajectory is defined as the path that a moving object follows through space as a function of time. Each sub-point of this LineString represents a single event. The latest sub-point represents the latest geo-event. For each Point event it is also possible to store an additional m-value representing for example actually speed, distance, duration or direction of this event. A trajectory con [...]
+***
+
+## Required input
+
+* WKT String of a JTS Point Geometry
+* Integer value representing EPSG code
+* Number value for M-value
+
+
+***
+
+## Configuration
+
+Creates a JTS Geometry LineString from a JTS Point Geometries events representing a trajectory.
+
+
+### 1st parameter
+Point WKT String
+
+### 2nd parameter
+EPSG code value
+
+### 3rd parameter
+M-value for each sub-point of the trajectory
+
+### 4rd parameter
+String for a description text for the trajectory
+
+### 5rd parameter
+Number of allowed sub-points
+
+***
+
+## Output
+
+Adds a LineString geometry in the Well Known Text to the event, representing a trajectory. Also the description text is added to the event stream. The first existing event creates an empty LineString.
+
+### Example
+Creating a LineString with a threshold of 2 allowed sub-points:
+
+* First Event:
+ * Point(8.12 41.23) --> LineString <empty>
+* Second Event:
+ * Point(8.56 41.25) --> LineString(8.12 41.23, 8.56 41.25)
+* Second Event:
+ * Point(8.84 40.98) --> LineString(8.56 41.25, 8.84 40.98)
+
+M-value is not represented in the LineString but will be stored for internal use!
diff --git a/documentation/docs/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md
similarity index 93%
rename from documentation/docs/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md
index 1cfea35..d8425bd 100644
--- a/documentation/docs/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md
@@ -32,8 +32,7 @@ sidebar_label: Distance Calculator
## Description
-Groups spatial events into cells of a given size
-Add a detailed description here
+Calculates the distance between two latitude/longitude pairs in a single event.
***
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md
similarity index 54%
copy from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md
index 153339e..938a054 100644
--- a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.brokers.jvm.pulsar
-title: Pulsar Publisher
-sidebar_label: Pulsar Publisher
+id: org.apache.streampipes.processors.geo.jvm.processor.speed
+title: Speed Calculator
+sidebar_label: Speed Calculator
---
<!--
@@ -24,40 +24,32 @@ sidebar_label: Pulsar Publisher
-<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.pulsar/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
***
## Description
-Publishes events to Apache Pulsar.
+Calculates the speed (in km/h) based on latitude/longitude values in a data stream. Therefore it uses the GPS and timestamps values of consecutive events.
+It calculates the distance between two points (events) and how much time has passed. Based on those values the speed is calculated.
***
## Required input
-This sink does not have any requirements and works with any incoming event type.
+Requires a data stream that provides latitude and longitude values as well as a timestamp.
***
## Configuration
-### Pulsar Broker Hostname
-
-The hostname to connect to the broker.
-
-### Pulsar Broker Port
-
-The port to connect to the broker (e.g., 6650)
+### Timestamp field
+### Latitude field
-### Pulsar Topic
-
-The topic where events should be sent to.
+### Longitude field
+### Count window
+Describes the number of stored events, used for the calculation.
+E.g. a value of 5 means that thhe current event and the event (t-5) are used for the speed calculation.
## Output
-
-(not applicable for data sinks)
\ No newline at end of file
+Appends the calculated speed in km/h.
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.jvm.geocoding/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md
similarity index 73%
rename from documentation/docs/org.apache.streampipes.processor.geo.jvm.geocoding/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md
index 6c64412..46036f0 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.jvm.geocoding/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.jvm.geocoding
-title: Google Maps Geocoder
-sidebar_label: Google Maps Geocoder
+id: org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator
+title: Static Distance Calculator
+sidebar_label: Static Distance Calculator
---
<!--
@@ -24,21 +24,18 @@ sidebar_label: Google Maps Geocoder
-<p align="center">
-</p>
-
***
## Description
-This processor computes the latitude and longitude values from a location (a place name such as "Karlsruhe, Germany
-") and adds the result to the event.
+Calculates the distance (in km) between a fixed location (e.g., a place) and a latitude/longitude pair of an input
+ event.
***
## Required input
-
+Requires a data stream that provides latitude and longitude values.
***
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md
similarity index 77%
copy from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md
index e01b688..3d6e802 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.processors.pattern-detection.flink.absence
+title: Absence
+sidebar_label: Absence
---
<!--
@@ -25,14 +25,14 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.absence/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Groups spatial events into cells of a given size
+Detects whether an event does not arrive within a specified time after the occurrence of another event.
Add a detailed description here
***
diff --git a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md
similarity index 79%
rename from documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md
index e01b688..cb1b240 100644
--- a/documentation/docs/org.apache.streampipes.processor.geo.flink/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
+id: org.apache.streampipes.processors.pattern-detection.flink.and
+title: And
+sidebar_label: And
---
<!--
@@ -25,14 +25,14 @@ sidebar_label: Spatial Grid Enrichment
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Groups spatial events into cells of a given size
+Detects whether an event co-occurs with another event within a given time.
Add a detailed description here
***
diff --git a/documentation/docs/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md
index 7fe65e1..a57cbb4 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.flink.fieldhasher
-title: Field Hasher
-sidebar_label: Field Hasher
+id: org.apache.streampipes.processors.pattern-detection.flink.sequence
+title: Sequence
+sidebar_label: Sequence
---
<!--
@@ -25,14 +25,14 @@ sidebar_label: Field Hasher
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.fieldhasher/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-The Field Hasher uses an algorithm to encode values in a field. The Field Hasher can use MD5, SHA1 or SHA2 to hash field values.
+Detects a sequence of events in the following form: Event A followed by Event B within X seconds. In addition, both streams can be matched by a common property value (e.g., a.machineId = b.machineId)
Add a detailed description here
***
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.frequency.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.frequency/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.siddhi.frequency.md
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.frequencychange/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.frequencychange.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.frequencychange/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.siddhi.frequencychange.md
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.increase/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.increase.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.increase/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.siddhi.increase.md
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.numericalfilter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processors.siddhi.numericalfilter/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.sequence/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md
similarity index 87%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.sequence/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md
index 5525456..04119dd 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.sequence/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md
@@ -33,22 +33,3 @@ sidebar_label: Sequence Detection
## Description
Merges events from two event streams, when the top event arrives first and then the bottom event
-Add a detailed description here
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.stop/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.siddhi.stop.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.stop/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.siddhi.stop.md
diff --git a/documentation/docs/org.apache.streampipes.processors.siddhi.numericalfilter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md
similarity index 70%
rename from documentation/docs/org.apache.streampipes.processors.siddhi.numericalfilter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md
index 6851072..e2fdd59 100644
--- a/documentation/docs/org.apache.streampipes.processors.siddhi.numericalfilter/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.numericalfilter
-title: Numerical Filter (Siddhi)
-sidebar_label: Numerical Filter (Siddhi)
+id: org.apache.streampipes.processors.statistics.flink.statistics-summary
+title: Statistics Summary
+sidebar_label: Statistics Summary
---
<!--
@@ -25,30 +25,19 @@ sidebar_label: Numerical Filter (Siddhi)
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.siddhi.numericalfilter/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.statistics.flink.statistics-summary/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
+Calculate simple descriptive summary statistics for each selected list property.
-Add a detailed description here
+The statistics contain:
+* Minimum
+* Maximum
+* Sum
+* Standard Deviation
+* Variance
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.flink.languagedetection/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.flink.languagedetection.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.textmining.flink.languagedetection/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.flink.languagedetection.md
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.flink.wordcount.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.flink.wordcount.md
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.chunker/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.chunker.md
similarity index 94%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.chunker/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.chunker.md
index 8e50cf1..7dcaa19 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.chunker/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.chunker.md
@@ -47,6 +47,8 @@ Needs a stream with two string list properties:
## Configuration
Assign the tokens and the part of speech tags to the corresponding stream property.
+To use this component you have to download or train an openNLP model:
+https://opennlp.apache.org/models.html
## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.languagedetection/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.languagedetection.md
similarity index 97%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.languagedetection/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.languagedetection.md
index 5b45c1c..ff436a4 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.languagedetection/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.languagedetection.md
@@ -152,6 +152,8 @@ The longer the text, the higher the accuracy of the language detector.
## Configuration
Simply assign the correct output of the previous stream to the language detector input.
+To use this component you have to download or train an openNLP model:
+https://opennlp.apache.org/models.html
## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.namefinder/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.namefinder.md
similarity index 88%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.namefinder/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.namefinder.md
index 8b9d259..910f40a 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.namefinder/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.namefinder.md
@@ -34,8 +34,8 @@ sidebar_label: Name Finder
Loads a trained model which finds names like locations or organizations.
-A list of trained models can be found [here](http://opennlp.sourceforge.net/models-1.5/).\
-A guide on how to train a new model can be found [here](https://opennlp.apache.org/docs/1.9.1/manual/opennlp.html#tools.namefind.training).
+A list of trained models can be found here: http://opennlp.sourceforge.net/models-1.5/.\
+A guide on how to train a new model can be found here: https://opennlp.apache.org/docs/1.9.1/manual/opennlp.html#tools.namefind.training.
***
@@ -49,6 +49,7 @@ A stream with a list of tokens from a text.
Configure the Name finder so that the tokens are assigned to the "List of Tokens" property
+
#### Model parameter
The trained model which should be used to find the names.
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.partofspeech/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.partofspeech.md
similarity index 94%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.partofspeech/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.partofspeech.md
index b53380f..c93b8ac 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.partofspeech/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.partofspeech.md
@@ -46,6 +46,8 @@ A stream with a list property which contains the tokens.
## Configuration
Simply assign the correct output of the previous stream to the part of speech detector input.
+To use this component you have to download or train an openNLP model:
+https://opennlp.apache.org/models.html
## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.sentencedetection/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.sentencedetection.md
similarity index 94%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.sentencedetection/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.sentencedetection.md
index 96b4392..c5efc18 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.sentencedetection/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.sentencedetection.md
@@ -45,6 +45,8 @@ A stream with a string property which contains a text.
## Configuration
Simply assign the correct output of the previous stream to the tokenizer input.
+To use this component you have to download or train an openNLP model:
+https://opennlp.apache.org/models.html
## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.tokenizer/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.tokenizer.md
similarity index 93%
rename from documentation/docs/org.apache.streampipes.processors.textmining.jvm.tokenizer/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.tokenizer.md
index cd99989..ec07ccf 100644
--- a/documentation/docs/org.apache.streampipes.processors.textmining.jvm.tokenizer/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.textmining.jvm.tokenizer.md
@@ -45,6 +45,8 @@ A stream with a string property which contains a text.
## Configuration
Simply assign the correct output of the previous stream to the tokenizer input.
+To use this component you have to download or train an openNLP model:
+https://opennlp.apache.org/models.html
## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.field-converter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-converter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.field-converter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-converter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.field-mapper/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md
similarity index 68%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.field-mapper/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md
index 54416b0..e2814f0 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.flink.field-mapper/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md
@@ -32,23 +32,38 @@ sidebar_label: Field Mapper
## Description
-Replaces one or more field with a new field and computes a hash value of these fields
-Add a detailed description here
-
-***
-
-## Required input
-
+Replaces one or more fields with a new field and computes a hash value of these fields
***
## Configuration
-Describe the configuration parameters here
+* Fields: Fields that will be mapped into a property
+* Name of the new field
-### 1st parameter
-
-
-### 2nd parameter
+***
-## Output
\ No newline at end of file
+## Example
+Merge two fields into a hash value
+### Input event
+```
+{
+ "timestamp":1586380104915,
+ "mass_flow":4.3167,
+ "temperature":40.05,
+ "sensorId":"flowrate01"
+}
+```
+
+### Configuration
+* Fields: mass_flow, temperature
+* Name of new field: demo
+
+### Output event
+```
+{
+ "timestamp":1586380104915,
+ "sensorId":"flowrate01"
+ "demo":"8ae11f5c83610104408d485b73120832",
+}
+```
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.field-renamer/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-renamer.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.field-renamer/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.field-renamer.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md
similarity index 97%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md
index 7fe65e1..3f0b045 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md
@@ -38,7 +38,7 @@ Add a detailed description here
***
## Required input
-
+Any field of type string
***
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md
similarity index 83%
rename from documentation/docs/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md
index 99996bb..a98fe6f 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md
@@ -32,23 +32,18 @@ sidebar_label: Boilerplate Removal
## Description
-Removes boilerplate and extract fulltext from HTML
-Add a detailed description here
+Removes boilerplate tags from HTML and extracts fulltext
***
## Required input
-
+Requires a Text field containing the HTML
***
## Configuration
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
+Select the extractor type and output mode
-## Output
\ No newline at end of file
+## Output
+Appends a new text field containing the content of the html page without the boilerplate
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.counter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.counter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.timer/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.booloperator.timer/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.changed-value/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
similarity index 91%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.changed-value/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
index 8c2b598..824d049 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.changed-value/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
@@ -36,18 +36,10 @@ This processor sends out an event everytime a specific object changes. It also a
***
-## Required input
-
-
-***
-
## Configuration
+Select property to monitor for changes
Describe the configuration parameters here
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
\ No newline at end of file
+## Output
+Emit an event on change and append a timestamp when the change occured
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.count-array/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.processors.transformation.jvm.count-array/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md
diff --git a/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md
new file mode 100644
index 0000000..5dc226a
--- /dev/null
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md
@@ -0,0 +1,76 @@
+---
+id: org.apache.streampipes.processors.transformation.jvm.csvmetadata
+title: CSV Metadata Enricher
+sidebar_label: CSV Metadata Enricher
+---
+
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one or more
+ ~ contributor license agreements. See the NOTICE file distributed with
+ ~ this work for additional information regarding copyright ownership.
+ ~ The ASF licenses this file to You under the Apache License, Version 2.0
+ ~ (the "License"); you may not use this file except in compliance with
+ ~ the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ ~
+ -->
+
+
+Enrich a datastream with information provided in a CSV file.
+The data of the CSV file is matched by an id column with a property value of a String in the data stream.
+
+***
+
+## Description
+Upload a CSV file with static meta information that will be appended to each event.
+The file can contain different information for different keys in the stream.
+
+
+### Structure of CSV file
+The first row containes the runtime names for the properties to insert.
+Once the file is uploaded the user can select which column to use for the matching property and which values should be appended.
+Delimiter: ';'
+
+
+***
+
+## Example
+Add the location of a production line to the event
+
+### Input event
+```
+{
+ 'line_id': 'line1',
+ 'timestamp': 1586378041
+}
+```
+
+### CSV File
+```
+production_line;location
+line1;germany
+line2;uk
+line3;usa
+```
+
+### Configuration
+* The field that is used for the lookup (Example: line_id)
+* The CSV file (Example: Upload the csv file)
+* Field to match (Example: production_line)
+* Fields to append (Example: location)
+
+### Output event
+```
+{
+ 'line_id': 'line1',
+ 'timestamp': 1586378041,
+ 'location': 'germany'
+}
+```
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.duration-value/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
similarity index 87%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.duration-value/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
index ccd17f4..5ccbb2a 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.duration-value/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
@@ -33,22 +33,19 @@ sidebar_label: Calculate Duration
## Description
This processor calculates the duration for a given stream with a start timestamp and an end timestamp.
-Add a detailed description here
***
## Required input
-
+Two timestamp fields
***
## Configuration
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
+* Start Timestamp: The first timestamp (t1)
+* End Timestamp: The second timestamp (t2)
+* Time Unit of the result
-## Output
\ No newline at end of file
+## Output
+Appends a new field with the difference of t2 and t1
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.split-array/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.split-array/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md
diff --git a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
similarity index 52%
rename from documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
index 842add4..cc14ed6 100644
--- a/documentation/docs/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.enricher.flink.processor.urldereferencing
-title: URL Dereferencing
-sidebar_label: URL Dereferencing
+id: org.apache.streampipes.processors.transformation.jvm.stringoperator.counter
+title: String Counter
+sidebar_label: String Counter
---
<!--
@@ -25,27 +25,37 @@ sidebar_label: URL Dereferencing
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Parses and appends the html page as a string to event.
+This processor monitors a string field and counts how often the value of the string changes. Hereby, a change is characterized by
+the value of the field before and the value after the change, combined forming a pair. The processor keeps track of the counter for each pair.
***
## Required input
-The URL Dereferencing processor requires an input stream that provides an input field of type 'string', representing
-the URL to dereference.
+
+A string field is required in the data stream and can be selected with the field mapping.
+
+### String Field
+
+The string field to be monitored.
***
## Configuration
-### URL
-The field containing the URL to dereference.
+(no further configuration required)
## Output
-The processor appends the extracted HTML page to each input event.
\ No newline at end of file
+The following three fields are appended to the event:
+* [counter] numerical field with the current count value for the given value pair
+* [change_from] the value of the string before the change
+* [change_to] the value of the string after the change
+
+The event is emitted whenever the value of the string field changes.
+
diff --git a/documentation/docs/org.apache.streampipes.processors.filters.jvm.compose/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
similarity index 57%
rename from documentation/docs/org.apache.streampipes.processors.filters.jvm.compose/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
index 132c05f..9e14f3b 100644
--- a/documentation/docs/org.apache.streampipes.processors.filters.jvm.compose/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.filters.jvm.compose
-title: Compose
-sidebar_label: Compose
+id: org.apache.streampipes.processors.transformation.jvm.stringoperator.timer
+title: String Timer
+sidebar_label: String Timer
---
<!--
@@ -25,20 +25,25 @@ sidebar_label: Compose
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.compose/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Merges two event streams. Any time, a new input event arrives, it is merged with the last input event from the other
-event stream and forwarded.
+This processor measures how long a value of a string field does not change. Once the value is changes the event with the measured time and the corresponding string value is emitted.
+
***
## Required input
-The Compose processor does not have any specific input requirements.
+
+A string field is required in the data stream.
+
+### Field
+
+The string field which is monitored for any value changes.
***
@@ -47,4 +52,9 @@ The Compose processor does not have any specific input requirements.
(no further configuration required)
## Output
-The compose processor has a configurable output that can be selected by the user at pipeline modeling time.
\ No newline at end of file
+The following two fields are appended to the event:
+* [measured_time] the measured time for the string value to not change
+* [field_value] the corresponding string value
+
+The event is emitted whenever the value of the string field changes.
+
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.taskduration/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.taskduration.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.taskduration/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.taskduration.md
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.count-array/documentation.md b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
similarity index 62%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.count-array/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
index 1c69d5e..4792763 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.count-array/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.jvm.count-array
-title: Count Array
-sidebar_label: Count Array
+id: org.apache.streampipes.processors.transformation.jvm.transform-to-boolean
+title: Transform to boolean
+sidebar_label: Transform to boolean
---
<!--
@@ -25,31 +25,26 @@ sidebar_label: Count Array
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.count-array/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
+This processors transforms numbers and strings to boolean values.
-This processor takes a list field, computes the size of the list and appends the result to the event.
***
## Required input
-
-This processor works with any event that has a field of type ``list``.
+A string with the values "true", "True", "false", "False" or a number with value 1.0, 1, 0, or 0.0
***
## Configuration
-Describe the configuration parameters here
-
-### List Field
-
-The field containing the list that should be used.
+Select fields that should be converted to boolean.
## Output
-
-Outputs the incoming event while appending the list size (named ``countValue``) to the incoming event.
\ No newline at end of file
+Selected properties of input events are transformed to booleans.
+When the value is not valid an error message is logged and the event is discarde.
\ No newline at end of file
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md b/documentation/docs/pe/org.apache.streampipes.protocol.set.file.md
similarity index 74%
copy from documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.protocol.set.file.md
index 3e7b038..c9a0978 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.protocol.set.file.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.jvm.csvmetadata
-title: CSV Metadata Enricher
-sidebar_label: CSV Metadata Enricher
+id: org.apache.streampipes.protocol.set.file
+title: File Set
+sidebar_label: File Set
---
<!--
@@ -24,21 +24,15 @@ sidebar_label: CSV Metadata Enricher
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.protocol.set.file/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
***
## Description
+Reads the content from a local file.
***
-## Required input
-
-
-***
-
-## Configuration
-
-
-
-## Output
diff --git a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md b/documentation/docs/pe/org.apache.streampipes.protocol.set.http.md
similarity index 75%
rename from documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.protocol.set.http.md
index 3e7b038..a0330cf 100644
--- a/documentation/docs/org.apache.streampipes.processors.transformation.jvm.csvmetadata/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.protocol.set.http.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.jvm.csvmetadata
-title: CSV Metadata Enricher
-sidebar_label: CSV Metadata Enricher
+id: org.apache.streampipes.protocol.set.http
+title: HTTP Set
+sidebar_label: HTTP Set
---
<!--
@@ -24,21 +24,15 @@ sidebar_label: CSV Metadata Enricher
+<p align="center">
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.protocol.set.http/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
***
## Description
+Regularly poll an HTTP endpoint
***
-## Required input
-
-
-***
-
-## Configuration
-
-
-
-## Output
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.bufferrest/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.bufferrest/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.jms/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.jms/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md
similarity index 100%
copy from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md
copy to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
similarity index 73%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
index 09ee01f..1453ae4 100644
--- a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.brokers.jvm.kafka
-title: Kafka Publisher
-sidebar_label: Kafka Publisher
+id: org.apache.streampipes.sinks.brokers.jvm.mqtt
+title: MQTT Publisher
+sidebar_label: MQTT Publisher
---
<!--
@@ -25,14 +25,14 @@ sidebar_label: Kafka Publisher
<p align="center">
- <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.kafka/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/docs/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Publishes events to Apache Kafka.
+Publishes events to MQTT.
***
@@ -44,14 +44,14 @@ This sink does not have any requirements and works with any incoming event type.
## Configuration
-### Kafka Broker Settings
+### MQTT Broker Settings
The basic settings to connect to the broker.
-The Kafka broker URL indicates the URL of the broker (e.g., localhost), the port indicates the port of the broker
- (e.g., 9092)
+The MQTT broker URL indicates the URL of the broker (e.g., localhost), the port indicates the port of the broker
+(e.g., 9092)
-### Kafka Topic
+### MQTT Topic
The topic where events should be sent to.
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.rabbitmq/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.rabbitmq/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.brokers.jvm.rest/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.brokers.jvm.rest/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.ditto/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
similarity index 84%
rename from documentation/docs/org.apache.streampipes.sinks.databases.ditto/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
index ea888e4..cc686ae 100644
--- a/documentation/docs/org.apache.streampipes.sinks.databases.ditto/documentation.md
+++ b/documentation/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
@@ -44,19 +44,7 @@ This sink does not have any requirements and works with any incoming event type.
## Configuration
-Describe the configuration parameters here
-
-### Hostname
-
-The hostname of the CouchDB instance.
-
-### Port
-
-The port of the CouchDB instance.
-
-### Database Name
-
-The name of the database where events will be stored
+(tbd)
## Output
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.flink.elasticsearch.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.flink.elasticsearch.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.jvm.couchdb/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.influxdb/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.influxdb.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.jvm.influxdb/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.influxdb.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.iotdb/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.jvm.iotdb/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.opcua/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.jvm.opcua/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.databases.jvm.postgresql/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.postgresql.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.databases.jvm.postgresql/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.databases.jvm.postgresql.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.internal.jvm.dashboard/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.internal.jvm.dashboard/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.internal.jvm.datalake/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.internal.jvm.datalake/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.internal.jvm.notification/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.internal.jvm.notification/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.notifications.jvm.email/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.notifications.jvm.email/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.notifications.jvm.onesignal/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.notifications.jvm.onesignal/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md
diff --git a/documentation/docs/org.apache.streampipes.sinks.notifications.jvm.slack/documentation.md b/documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md
similarity index 100%
rename from documentation/docs/org.apache.streampipes.sinks.notifications.jvm.slack/documentation.md
rename to documentation/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md
diff --git a/documentation/docs/pipeline-elements.md b/documentation/docs/pipeline-elements.md
index 7cc1e94..111b462 100644
--- a/documentation/docs/pipeline-elements.md
+++ b/documentation/docs/pipeline-elements.md
@@ -4,4 +4,4 @@ title: Overview
sidebar_label: Overview
---
-<div class="pe-grid-container"><div class="pe-container-item pe-container-item-processor"><div class="pe-container-item-header"><div class="pe-container-item-icon pe-icon-processor"><img class="pe-icon" src="/docs/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.aggregation/icon.png"></div><div class="pe-container-item-header-pe"><div class="pe-container-item-label pe-container-item-label-processor">Data Processor</div><div class="pe-container-item-label-name">Ag [...]
\ No newline at end of file
+<div class="pe-grid-container"><div class="pe-container-item pe-container-item-processor"><div class="pe-container-item-header"><div class="pe-container-item-icon pe-icon-processor"><img class="pe-icon" src="/docs/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.absence/icon.png"></div><div class="pe-container-item-header-pe"><div class="pe-container-item-label pe-container-item-label-processor">Data Processor</div><div class="pe-container-item-label-name"> [...]
\ No newline at end of file
diff --git a/documentation/website/i18n/en.json b/documentation/website/i18n/en.json
index 4e7d31f..89adca5 100644
--- a/documentation/website/i18n/en.json
+++ b/documentation/website/i18n/en.json
@@ -80,311 +80,487 @@
"license": {
"title": "license"
},
- "org.apache.streampipes.processor.geo.flink/org.apache.streampipes.processor.geo.flink": {
+ "pe/org.apache.streampipes.connect.adapters.coindesk": {
+ "title": "Coindesk Bitcoin Price",
+ "sidebar_label": "Coindesk Bitcoin Price"
+ },
+ "pe/org.apache.streampipes.connect.adapters.gdelt": {
+ "title": "GDELT",
+ "sidebar_label": "GDELT"
+ },
+ "pe/org.apache.streampipes.connect.adapters.iex.news": {
+ "title": "IEX Cloud News",
+ "sidebar_label": "IEX Cloud News"
+ },
+ "pe/org.apache.streampipes.connect.adapters.iex.stocks": {
+ "title": "IEX Cloud Stock Quotes",
+ "sidebar_label": "IEX Cloud Stock Quotes"
+ },
+ "pe/org.apache.streampipes.connect.adapters.image.set": {
+ "title": "Image Upload (Set)",
+ "sidebar_label": "Image Upload (Set)"
+ },
+ "pe/org.apache.streampipes.connect.adapters.image.stream": {
+ "title": "Image Upload (Stream)",
+ "sidebar_label": "Image Upload (Stream)"
+ },
+ "pe/org.apache.streampipes.connect.adapters.influxdb.set": {
+ "title": "InfluxDB Set Adapter",
+ "sidebar_label": "InfluxDB Set Adapter"
+ },
+ "pe/org.apache.streampipes.connect.adapters.influxdb.stream": {
+ "title": "InfluxDB Stream Adapter",
+ "sidebar_label": "InfluxDB Stream Adapter"
+ },
+ "pe/org.apache.streampipes.connect.adapters.iss": {
+ "title": "ISS Location",
+ "sidebar_label": "ISS Location"
+ },
+ "pe/org.apache.streampipes.connect.adapters.mysql.set": {
+ "title": "MySQL Set Adapter",
+ "sidebar_label": "MySQL Set Adapter"
+ },
+ "pe/org.apache.streampipes.connect.adapters.mysql.stream": {
+ "title": "MySql Stream Adapter",
+ "sidebar_label": "MySql Stream Adapter"
+ },
+ "pe/org.apache.streampipes.connect.adapters.netio.mqtt": {
+ "title": "NETIO MQTT M2M",
+ "sidebar_label": "NETIO MQTT M2M"
+ },
+ "pe/org.apache.streampipes.connect.adapters.netio.rest": {
+ "title": "NETIO http JSON",
+ "sidebar_label": "NETIO http JSON"
+ },
+ "pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera": {
+ "title": "NSW Traffic Cameras",
+ "sidebar_label": "NSW Traffic Cameras"
+ },
+ "pe/org.apache.streampipes.connect.adapters.opcua": {
+ "title": "OPC UA",
+ "sidebar_label": "OPC UA"
+ },
+ "pe/org.apache.streampipes.connect.adapters.plc4x.s7": {
+ "title": "PLC4X S7",
+ "sidebar_label": "PLC4X S7"
+ },
+ "pe/org.apache.streampipes.connect.adapters.ros": {
+ "title": "ROS Bridge",
+ "sidebar_label": "ROS Bridge"
+ },
+ "pe/org.apache.streampipes.connect.adapters.simulator.randomdataset": {
+ "title": "Random Data Simulator (Set)",
+ "sidebar_label": "Random Data Simulator (Set)"
+ },
+ "pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream": {
+ "title": "Random Data Simulator (Stream)",
+ "sidebar_label": "Random Data Simulator (Stream)"
+ },
+ "pe/org.apache.streampipes.connect.adapters.slack": {
+ "title": "Slack",
+ "sidebar_label": "Slack"
+ },
+ "pe/org.apache.streampipes.connect.adapters.ti": {
+ "title": "TI Sensor Tag",
+ "sidebar_label": "TI Sensor Tag"
+ },
+ "pe/org.apache.streampipes.connect.adapters.wikipedia.edit": {
+ "title": "Wikipedia Edits",
+ "sidebar_label": "Wikipedia Edits"
+ },
+ "pe/org.apache.streampipes.connect.adapters.wikipedia.new": {
+ "title": "Wikipedia New Articles",
+ "sidebar_label": "Wikipedia New Articles"
+ },
+ "pe/org.apache.streampipes.connect.protocol.stream.file": {
+ "title": "File Stream",
+ "sidebar_label": "File Stream"
+ },
+ "pe/org.apache.streampipes.connect.protocol.stream.http": {
+ "title": "HTTP Stream",
+ "sidebar_label": "HTTP Stream"
+ },
+ "pe/org.apache.streampipes.connect.protocol.stream.kafka": {
+ "title": "Apache Kafka",
+ "sidebar_label": "Apache Kafka"
+ },
+ "pe/org.apache.streampipes.connect.protocol.stream.mqtt": {
+ "title": "MQTT",
+ "sidebar_label": "MQTT"
+ },
+ "pe/org.apache.streampipes.connect.protocol.stream.pulsar": {
+ "title": "Apache Pulsar",
+ "sidebar_label": "Apache Pulsar"
+ },
+ "pe/org.apache.streampipes.processor.geo.flink": {
"title": "Spatial Grid Enrichment",
"sidebar_label": "Spatial Grid Enrichment"
},
- "org.apache.streampipes.processor.geo.jvm.geocoding/org.apache.streampipes.processor.geo.jvm.geocoding": {
+ "pe/org.apache.streampipes.processor.geo.jvm.geocoding": {
"title": "Google Maps Geocoder",
"sidebar_label": "Google Maps Geocoder"
},
- "org.apache.streampipes.processor.geo.jvm.reversegeocoding/org.apache.streampipes.processor.geo.jvm.reversegeocoding": {
+ "pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding": {
"title": "Reverse Geocoder",
"sidebar_label": "Reverse Geocoder"
},
- "org.apache.streampipes.processor.geo.jvm.staticgeocoding/org.apache.streampipes.processor.geo.jvm.staticgeocoding": {
+ "pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding": {
"title": "Static Google Maps Geocoder",
"sidebar_label": "Static Google Maps Geocoder"
},
- "org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification": {
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification": {
"title": "Generic Image Classification",
"sidebar_label": "Generic Image Classification"
},
- "org.apache.streampipes.processor.imageclassification.jvm.image-enricher/org.apache.streampipes.processor.imageclassification.jvm.image-enricher": {
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper": {
+ "title": "Image Cropper",
+ "sidebar_label": "Image Cropper"
+ },
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher": {
"title": "Image Enricher",
"sidebar_label": "Image Enricher"
},
- "org.apache.streampipes.processor.imageclassification.qrcode/org.apache.streampipes.processor.imageclassification.qrcode": {
+ "pe/org.apache.streampipes.processor.imageclassification.qrcode": {
"title": "QR Code Reader",
"sidebar_label": "QR Code Reader"
},
- "org.apache.streampipes.processors.aggregation.flink.aggregation/org.apache.streampipes.processors.aggregation.flink.aggregation": {
+ "pe/org.apache.streampipes.processors.aggregation.flink.aggregation": {
"title": "Aggregation",
"sidebar_label": "Aggregation"
},
- "org.apache.streampipes.processors.aggregation.flink.eventcount/org.apache.streampipes.processors.aggregation.flink.eventcount": {
+ "pe/org.apache.streampipes.processors.aggregation.flink.count": {
+ "title": "Count Aggregation",
+ "sidebar_label": "Count Aggregation"
+ },
+ "pe/org.apache.streampipes.processors.aggregation.flink.eventcount": {
"title": "Event Counter",
"sidebar_label": "Event Counter"
},
- "org.apache.streampipes.processors.aggregation.flink.rate/org.apache.streampipes.processors.aggregation.flink.rate": {
+ "pe/org.apache.streampipes.processors.aggregation.flink.rate": {
"title": "Event Rate",
"sidebar_label": "Event Rate"
},
- "org.apache.streampipes.processors.enricher.flink.processor.math.mathop/org.apache.streampipes.processors.enricher.flink.processor.math.mathop": {
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop": {
"title": "Math",
"sidebar_label": "Math"
},
- "org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop": {
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop": {
"title": "Static Math",
"sidebar_label": "Static Math"
},
- "org.apache.streampipes.processors.enricher.flink.processor.trigonometry/org.apache.streampipes.processors.enricher.flink.processor.trigonometry": {
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry": {
"title": "Trigonometry Functions",
"sidebar_label": "Trigonometry Functions"
},
- "org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing": {
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing": {
"title": "URL Dereferencing",
"sidebar_label": "URL Dereferencing"
},
- "org.apache.streampipes.processors.enricher.flink.timestamp/org.apache.streampipes.processors.enricher.flink.timestamp": {
+ "pe/org.apache.streampipes.processors.enricher.flink.timestamp": {
"title": "Timestamp Enricher",
"sidebar_label": "Timestamp Enricher"
},
- "org.apache.streampipes.processors.enricher.jvm.sizemeasure/org.apache.streampipes.processors.enricher.jvm.sizemeasure": {
+ "pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure": {
"title": "Size Measure",
"sidebar_label": "Size Measure"
},
- "org.apache.streampipes.processors.filters.jvm.compose/org.apache.streampipes.processors.filters.jvm.compose": {
+ "pe/org.apache.streampipes.processors.filters.jvm.compose": {
"title": "Compose",
"sidebar_label": "Compose"
},
- "org.apache.streampipes.processors.filters.jvm.enrich/org.apache.streampipes.processors.filters.jvm.enrich": {
+ "pe/org.apache.streampipes.processors.filters.jvm.enrich": {
"title": "Merge By Enrich",
"sidebar_label": "Merge By Enrich"
},
- "org.apache.streampipes.processors.filters.jvm.merge/org.apache.streampipes.processors.filters.jvm.merge": {
+ "pe/org.apache.streampipes.processors.filters.jvm.merge": {
"title": "Merge By Time",
"sidebar_label": "Merge By Time"
},
- "org.apache.streampipes.processors.filters.jvm.numericalfilter/org.apache.streampipes.processors.filters.jvm.numericalfilter": {
+ "pe/org.apache.streampipes.processors.filters.jvm.numericalfilter": {
"title": "Numerical Filter",
"sidebar_label": "Numerical Filter"
},
- "org.apache.streampipes.processors.filters.jvm.numericaltextfilter/org.apache.streampipes.processors.filters.jvm.numericaltextfilter": {
+ "pe/org.apache.streampipes.processors.filters.jvm.numericaltextfilter": {
"title": "Numerical Text Filter",
"sidebar_label": "Numerical Text Filter"
},
- "org.apache.streampipes.processors.filters.jvm.project/org.apache.streampipes.processors.filters.jvm.project": {
+ "pe/org.apache.streampipes.processors.filters.jvm.project": {
"title": "Projection",
"sidebar_label": "Projection"
},
- "org.apache.streampipes.processors.filters.jvm.textfilter/org.apache.streampipes.processors.filters.jvm.textfilter": {
+ "pe/org.apache.streampipes.processors.filters.jvm.textfilter": {
"title": "Text Filter",
"sidebar_label": "Text Filter"
},
- "org.apache.streampipes.processors.filters.jvm.threshold/org.apache.streampipes.processors.filters.jvm.threshold": {
+ "pe/org.apache.streampipes.processors.filters.jvm.threshold": {
"title": "Threshold Detector",
"sidebar_label": "Threshold Detector"
},
- "org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator": {
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo": {
+ "title": "Creates JTS Point",
+ "sidebar_label": "Creates JTS Point"
+ },
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG": {
+ "title": "EPSG Code",
+ "sidebar_label": "EPSG Code"
+ },
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory": {
+ "title": "Single Trajectory Creator",
+ "sidebar_label": "Single Trajectory Creator"
+ },
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator": {
"title": "Distance Calculator",
"sidebar_label": "Distance Calculator"
},
- "org.apache.streampipes.processors.pattern-detection.flink.peak-detection/org.apache.streampipes.processors.pattern-detection.flink.peak-detection": {
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.speed": {
+ "title": "Speed Calculator",
+ "sidebar_label": "Speed Calculator"
+ },
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator": {
+ "title": "Static Distance Calculator",
+ "sidebar_label": "Static Distance Calculator"
+ },
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.absence": {
+ "title": "Absence",
+ "sidebar_label": "Absence"
+ },
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.and": {
+ "title": "And",
+ "sidebar_label": "And"
+ },
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection": {
"title": "Peak Detection",
"sidebar_label": "Peak Detection"
},
- "org.apache.streampipes.processors.siddhi.frequency/org.apache.streampipes.processors.siddhi.frequency": {
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.sequence": {
+ "title": "Sequence",
+ "sidebar_label": "Sequence"
+ },
+ "pe/org.apache.streampipes.processors.siddhi.frequency": {
"title": "Frequency Calculation",
"sidebar_label": "Frequency Calculation"
},
- "org.apache.streampipes.processors.siddhi.frequencychange/org.apache.streampipes.processors.siddhi.frequencychange": {
+ "pe/org.apache.streampipes.processors.siddhi.frequencychange": {
"title": "Frequency Change",
"sidebar_label": "Frequency Change"
},
- "org.apache.streampipes.processors.siddhi.increase/org.apache.streampipes.processors.siddhi.increase": {
+ "pe/org.apache.streampipes.processors.siddhi.increase": {
"title": "Trend",
"sidebar_label": "Trend"
},
- "org.apache.streampipes.processors.siddhi.numericalfilter/org.apache.streampipes.processors.siddhi.numericalfilter": {
+ "pe/org.apache.streampipes.processors.siddhi.numericalfilter": {
"title": "Numerical Filter (Siddhi)",
"sidebar_label": "Numerical Filter (Siddhi)"
},
- "org.apache.streampipes.processors.siddhi.sequence/org.apache.streampipes.processors.siddhi.sequence": {
+ "pe/org.apache.streampipes.processors.siddhi.sequence": {
"title": "Sequence Detection",
"sidebar_label": "Sequence Detection"
},
- "org.apache.streampipes.processors.siddhi.stop/org.apache.streampipes.processors.siddhi.stop": {
+ "pe/org.apache.streampipes.processors.siddhi.stop": {
"title": "Stream Stop Detection",
"sidebar_label": "Stream Stop Detection"
},
- "org.apache.streampipes.processors.textmining.flink.languagedetection/org.apache.streampipes.processors.textmining.flink.languagedetection": {
+ "pe/org.apache.streampipes.processors.statistics.flink.statistics-summary": {
+ "title": "Statistics Summary",
+ "sidebar_label": "Statistics Summary"
+ },
+ "pe/org.apache.streampipes.processors.textmining.flink.languagedetection": {
"title": "Language Detection",
"sidebar_label": "Language Detection"
},
- "org.apache.streampipes.processors.textmining.flink.wordcount/org.apache.streampipes.processors.textmining.flink.wordcount": {
+ "pe/org.apache.streampipes.processors.textmining.flink.wordcount": {
"title": "Word Count",
"sidebar_label": "Word Count"
},
- "org.apache.streampipes.processors.textmining.jvm.chunker/org.apache.streampipes.processors.textmining.jvm.chunker": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.chunker": {
"title": "Chunker (English)",
"sidebar_label": "Chunker (English)"
},
- "org.apache.streampipes.processors.textmining.jvm.languagedetection/org.apache.streampipes.processors.textmining.jvm.languagedetection": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.languagedetection": {
"title": "Language Detection",
"sidebar_label": "Language Detection"
},
- "org.apache.streampipes.processors.textmining.jvm.namefinder/org.apache.streampipes.processors.textmining.jvm.namefinder": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.namefinder": {
"title": "Name Finder",
"sidebar_label": "Name Finder"
},
- "org.apache.streampipes.processors.textmining.jvm.partofspeech/org.apache.streampipes.processors.textmining.jvm.partofspeech": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.partofspeech": {
"title": "Part of Speech (English)",
"sidebar_label": "Part of Speech (English)"
},
- "org.apache.streampipes.processors.textmining.jvm.sentencedetection/org.apache.streampipes.processors.textmining.jvm.sentencedetection": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.sentencedetection": {
"title": "Sentence Detection (English)",
"sidebar_label": "Sentence Detection (English)"
},
- "org.apache.streampipes.processors.textmining.jvm.tokenizer/org.apache.streampipes.processors.textmining.jvm.tokenizer": {
+ "pe/org.apache.streampipes.processors.textmining.jvm.tokenizer": {
"title": "Tokenizer (English)",
"sidebar_label": "Tokenizer (English)"
},
- "org.apache.streampipes.processors.transformation.flink.field-converter/org.apache.streampipes.processors.transformation.flink.field-converter": {
+ "pe/org.apache.streampipes.processors.transformation.flink.field-converter": {
"title": "Field Converter",
"sidebar_label": "Field Converter"
},
- "org.apache.streampipes.processors.transformation.flink.field-mapper/org.apache.streampipes.processors.transformation.flink.field-mapper": {
+ "pe/org.apache.streampipes.processors.transformation.flink.field-mapper": {
"title": "Field Mapper",
"sidebar_label": "Field Mapper"
},
- "org.apache.streampipes.processors.transformation.flink.field-renamer/org.apache.streampipes.processors.transformation.flink.field-renamer": {
+ "pe/org.apache.streampipes.processors.transformation.flink.field-renamer": {
"title": "Field Renamer",
"sidebar_label": "Field Renamer"
},
- "org.apache.streampipes.processors.transformation.flink.fieldhasher/org.apache.streampipes.processors.transformation.flink.fieldhasher": {
+ "pe/org.apache.streampipes.processors.transformation.flink.fieldhasher": {
"title": "Field Hasher",
"sidebar_label": "Field Hasher"
},
- "org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter": {
+ "pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter": {
"title": "Measurement Unit Converter",
"sidebar_label": "Measurement Unit Converter"
},
- "org.apache.streampipes.processors.transformation.flink.processor.boilerplate/org.apache.streampipes.processors.transformation.flink.processor.boilerplate": {
+ "pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate": {
"title": "Boilerplate Removal",
"sidebar_label": "Boilerplate Removal"
},
- "org.apache.streampipes.processors.transformation.jvm.booloperator.counter/org.apache.streampipes.processors.transformation.jvm.booloperator.counter": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter": {
"title": "Boolean Counter",
"sidebar_label": "Boolean Counter"
},
- "org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter": {
"title": "Boolean Inverter",
"sidebar_label": "Boolean Inverter"
},
- "org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping": {
"title": "Measure Time Between Two Sensors",
"sidebar_label": "Measure Time Between Two Sensors"
},
- "org.apache.streampipes.processors.transformation.jvm.booloperator.timer/org.apache.streampipes.processors.transformation.jvm.booloperator.timer": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer": {
"title": "Boolean Timer",
"sidebar_label": "Boolean Timer"
},
- "org.apache.streampipes.processors.transformation.jvm.changed-value/org.apache.streampipes.processors.transformation.jvm.changed-value": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.changed-value": {
"title": "Value Changed",
"sidebar_label": "Value Changed"
},
- "org.apache.streampipes.processors.transformation.jvm.count-array/org.apache.streampipes.processors.transformation.jvm.count-array": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.count-array": {
"title": "Count Array",
"sidebar_label": "Count Array"
},
- "org.apache.streampipes.processors.transformation.jvm.csvmetadata/org.apache.streampipes.processors.transformation.jvm.csvmetadata": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata": {
"title": "CSV Metadata Enricher",
"sidebar_label": "CSV Metadata Enricher"
},
- "org.apache.streampipes.processors.transformation.jvm.duration-value/org.apache.streampipes.processors.transformation.jvm.duration-value": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.duration-value": {
"title": "Calculate Duration",
"sidebar_label": "Calculate Duration"
},
- "org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor": {
"title": "Timestamp Extractor",
"sidebar_label": "Timestamp Extractor"
},
- "org.apache.streampipes.processors.transformation.jvm.split-array/org.apache.streampipes.processors.transformation.jvm.split-array": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.split-array": {
"title": "Split Array",
"sidebar_label": "Split Array"
},
- "org.apache.streampipes.processors.transformation.jvm.taskduration/org.apache.streampipes.processors.transformation.jvm.taskduration": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter": {
+ "title": "String Counter",
+ "sidebar_label": "String Counter"
+ },
+ "pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer": {
+ "title": "String Timer",
+ "sidebar_label": "String Timer"
+ },
+ "pe/org.apache.streampipes.processors.transformation.jvm.taskduration": {
"title": "Task Duration",
"sidebar_label": "Task Duration"
},
- "org.apache.streampipes.processors.transformation.jvm.transform-to-boolean/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean": {
+ "pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean": {
"title": "Transform to boolean",
"sidebar_label": "Transform to boolean"
},
- "org.apache.streampipes.sinks.brokers.jvm.bufferrest/org.apache.streampipes.sinks.brokers.jvm.bufferrest": {
+ "pe/org.apache.streampipes.protocol.set.file": {
+ "title": "File Set",
+ "sidebar_label": "File Set"
+ },
+ "pe/org.apache.streampipes.protocol.set.http": {
+ "title": "HTTP Set",
+ "sidebar_label": "HTTP Set"
+ },
+ "pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest": {
"title": "Buffered REST Publisher",
"sidebar_label": "Buffered REST Publisher"
},
- "org.apache.streampipes.sinks.brokers.jvm.jms/org.apache.streampipes.sinks.brokers.jvm.jms": {
+ "pe/org.apache.streampipes.sinks.brokers.jvm.jms": {
"title": "JMS Publisher",
"sidebar_label": "JMS Publisher"
},
- "org.apache.streampipes.sinks.brokers.jvm.kafka/org.apache.streampipes.sinks.brokers.jvm.kafka": {
+ "pe/org.apache.streampipes.sinks.brokers.jvm.kafka": {
"title": "Kafka Publisher",
"sidebar_label": "Kafka Publisher"
},
- "org.apache.streampipes.sinks.brokers.jvm.pulsar/org.apache.streampipes.sinks.brokers.jvm.pulsar": {
+ "pe/org.apache.streampipes.sinks.brokers.jvm.mqtt": {
+ "title": "MQTT Publisher",
+ "sidebar_label": "MQTT Publisher"
+ },
+ "pe/org.apache.streampipes.sinks.brokers.jvm.pulsar": {
"title": "Pulsar Publisher",
"sidebar_label": "Pulsar Publisher"
},
- "org.apache.streampipes.sinks.brokers.jvm.rabbitmq/org.apache.streampipes.sinks.brokers.jvm.rabbitmq": {
+ "pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq": {
"title": "RabbitMQ Publisher",
"sidebar_label": "RabbitMQ Publisher"
},
- "org.apache.streampipes.sinks.brokers.jvm.rest/org.apache.streampipes.sinks.brokers.jvm.rest": {
+ "pe/org.apache.streampipes.sinks.brokers.jvm.rest": {
"title": "REST Publisher",
"sidebar_label": "REST Publisher"
},
- "org.apache.streampipes.sinks.databases.ditto/org.apache.streampipes.sinks.databases.ditto": {
+ "pe/org.apache.streampipes.sinks.databases.ditto": {
"title": "Eclipse Ditto",
"sidebar_label": "Eclipse Ditto"
},
- "org.apache.streampipes.sinks.databases.flink.elasticsearch/org.apache.streampipes.sinks.databases.flink.elasticsearch": {
+ "pe/org.apache.streampipes.sinks.databases.flink.elasticsearch": {
"title": "Elasticsearch",
"sidebar_label": "Elasticsearch"
},
- "org.apache.streampipes.sinks.databases.jvm.couchdb/org.apache.streampipes.sinks.databases.jvm.couchdb": {
+ "pe/org.apache.streampipes.sinks.databases.jvm.couchdb": {
"title": "CouchDB",
"sidebar_label": "CouchDB"
},
- "org.apache.streampipes.sinks.databases.jvm.influxdb/org.apache.streampipes.sinks.databases.jvm.influxdb": {
+ "pe/org.apache.streampipes.sinks.databases.jvm.influxdb": {
"title": "InfluxDB",
"sidebar_label": "InfluxDB"
},
- "org.apache.streampipes.sinks.databases.jvm.iotdb/org.apache.streampipes.sinks.databases.jvm.iotdb": {
+ "pe/org.apache.streampipes.sinks.databases.jvm.iotdb": {
"title": "IoTDB",
"sidebar_label": "IoTDB"
},
- "org.apache.streampipes.sinks.databases.jvm.opcua/org.apache.streampipes.sinks.databases.jvm.opcua": {
+ "pe/org.apache.streampipes.sinks.databases.jvm.opcua": {
"title": "OPC-UA",
"sidebar_label": "OPC-UA"
},
- "org.apache.streampipes.sinks.databases.jvm.postgresql/org.apache.streampipes.sinks.databases.jvm.postgresql": {
+ "pe/org.apache.streampipes.sinks.databases.jvm.postgresql": {
"title": "PostgreSQL",
"sidebar_label": "PostgreSQL"
},
- "org.apache.streampipes.sinks.internal.jvm.dashboard/org.apache.streampipes.sinks.internal.jvm.dashboard": {
+ "pe/org.apache.streampipes.sinks.internal.jvm.dashboard": {
"title": "Dashboard Sink",
"sidebar_label": "Dashboard Sink"
},
- "org.apache.streampipes.sinks.internal.jvm.datalake/org.apache.streampipes.sinks.internal.jvm.datalake": {
+ "pe/org.apache.streampipes.sinks.internal.jvm.datalake": {
"title": "Data Lake",
"sidebar_label": "Data Lake"
},
- "org.apache.streampipes.sinks.internal.jvm.notification/org.apache.streampipes.sinks.internal.jvm.notification": {
+ "pe/org.apache.streampipes.sinks.internal.jvm.notification": {
"title": "Notification",
"sidebar_label": "Notification"
},
- "org.apache.streampipes.sinks.notifications.jvm.email/org.apache.streampipes.sinks.notifications.jvm.email": {
+ "pe/org.apache.streampipes.sinks.notifications.jvm.email": {
"title": "Email Notification",
"sidebar_label": "Email Notification"
},
- "org.apache.streampipes.sinks.notifications.jvm.onesignal/org.apache.streampipes.sinks.notifications.jvm.onesignal": {
+ "pe/org.apache.streampipes.sinks.notifications.jvm.onesignal": {
"title": "OneSignal",
"sidebar_label": "OneSignal"
},
- "org.apache.streampipes.sinks.notifications.jvm.slack/org.apache.streampipes.sinks.notifications.jvm.slack": {
+ "pe/org.apache.streampipes.sinks.notifications.jvm.slack": {
"title": "Slack Notification",
"sidebar_label": "Slack Notification"
},
@@ -1184,18 +1360,18 @@
"links": {
"User Guide": "User Guide",
"Developer Guide": "Developer Guide",
- "Pipeline Elements": "Pipeline Elements",
"FAQ": "FAQ",
"Blog": "Blog"
},
"categories": {
- "User Guide": "User Guide",
+ "Getting Started": "Getting Started",
"Pipeline Elements": "Pipeline Elements",
"Basics": "Basics",
"Tutorials": "Tutorials",
"SDK Reference": "SDK Reference",
"Configuration": "Configuration",
"FAQ": "FAQ",
+ "User Guide": "User Guide",
"Developer Guide": "Developer Guide"
}
},
diff --git a/documentation/website/sidebars.json b/documentation/website/sidebars.json
index 1915077..bcfd964 100644
--- a/documentation/website/sidebars.json
+++ b/documentation/website/sidebars.json
@@ -1,13 +1,135 @@
{
"user-guide": {
- "User Guide": [
+ "Getting Started": [
"user-guide-introduction",
"user-guide-tour",
"user-guide-installation",
"user-guide-first-steps"
+ ],
+ "Pipeline Elements": [
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.absence",
+ "pe/org.apache.streampipes.processors.aggregation.flink.aggregation",
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.and",
+ "pe/org.apache.streampipes.connect.protocol.stream.kafka",
+ "pe/org.apache.streampipes.connect.protocol.stream.pulsar",
+ "pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate",
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter",
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter",
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest",
+ "pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata",
+ "pe/org.apache.streampipes.processors.transformation.jvm.duration-value",
+ "pe/org.apache.streampipes.processors.textmining.jvm.chunker",
+ "pe/org.apache.streampipes.connect.adapters.coindesk",
+ "pe/org.apache.streampipes.processors.filters.jvm.compose",
+ "pe/org.apache.streampipes.sinks.databases.jvm.couchdb",
+ "pe/org.apache.streampipes.processors.aggregation.flink.count",
+ "pe/org.apache.streampipes.processors.transformation.jvm.count-array",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo",
+ "pe/org.apache.streampipes.sinks.internal.jvm.dashboard",
+ "pe/org.apache.streampipes.sinks.internal.jvm.datalake",
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG",
+ "pe/org.apache.streampipes.sinks.databases.ditto",
+ "pe/org.apache.streampipes.sinks.databases.flink.elasticsearch",
+ "pe/org.apache.streampipes.sinks.notifications.jvm.email",
+ "pe/org.apache.streampipes.processors.aggregation.flink.eventcount",
+ "pe/org.apache.streampipes.processors.aggregation.flink.rate",
+ "pe/org.apache.streampipes.processors.transformation.flink.field-converter",
+ "pe/org.apache.streampipes.processors.transformation.flink.fieldhasher",
+ "pe/org.apache.streampipes.processors.transformation.flink.field-mapper",
+ "pe/org.apache.streampipes.processors.transformation.flink.field-renamer",
+ "pe/org.apache.streampipes.protocol.set.file",
+ "pe/org.apache.streampipes.connect.protocol.stream.file",
+ "pe/org.apache.streampipes.processors.siddhi.frequency",
+ "pe/org.apache.streampipes.processors.siddhi.frequencychange",
+ "pe/org.apache.streampipes.connect.adapters.gdelt",
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification",
+ "pe/org.apache.streampipes.processor.geo.jvm.geocoding",
+ "pe/org.apache.streampipes.protocol.set.http",
+ "pe/org.apache.streampipes.connect.protocol.stream.http",
+ "pe/org.apache.streampipes.connect.adapters.iex.news",
+ "pe/org.apache.streampipes.connect.adapters.iex.stocks",
+ "pe/org.apache.streampipes.connect.adapters.iss",
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper",
+ "pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher",
+ "pe/org.apache.streampipes.connect.adapters.image.set",
+ "pe/org.apache.streampipes.connect.adapters.image.stream",
+ "pe/org.apache.streampipes.sinks.databases.jvm.influxdb",
+ "pe/org.apache.streampipes.connect.adapters.influxdb.set",
+ "pe/org.apache.streampipes.connect.adapters.influxdb.stream",
+ "pe/org.apache.streampipes.sinks.databases.jvm.iotdb",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.jms",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.kafka",
+ "pe/org.apache.streampipes.processors.textmining.flink.languagedetection",
+ "pe/org.apache.streampipes.processors.textmining.jvm.languagedetection",
+ "pe/org.apache.streampipes.connect.protocol.stream.mqtt",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.mqtt",
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop",
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping",
+ "pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter",
+ "pe/org.apache.streampipes.processors.filters.jvm.enrich",
+ "pe/org.apache.streampipes.processors.filters.jvm.merge",
+ "pe/org.apache.streampipes.connect.adapters.mysql.set",
+ "pe/org.apache.streampipes.connect.adapters.mysql.stream",
+ "pe/org.apache.streampipes.connect.adapters.netio.mqtt",
+ "pe/org.apache.streampipes.connect.adapters.netio.rest",
+ "pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera",
+ "pe/org.apache.streampipes.processors.textmining.jvm.namefinder",
+ "pe/org.apache.streampipes.sinks.internal.jvm.notification",
+ "pe/org.apache.streampipes.processors.filters.jvm.numericalfilter",
+ "pe/org.apache.streampipes.processors.siddhi.numericalfilter",
+ "pe/org.apache.streampipes.processors.filters.jvm.numericaltextfilter",
+ "pe/org.apache.streampipes.connect.adapters.opcua",
+ "pe/org.apache.streampipes.sinks.databases.jvm.opcua",
+ "pe/org.apache.streampipes.sinks.notifications.jvm.onesignal",
+ "pe/org.apache.streampipes.connect.adapters.plc4x.s7",
+ "pe/org.apache.streampipes.processors.textmining.jvm.partofspeech",
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection",
+ "pe/org.apache.streampipes.sinks.databases.jvm.postgresql",
+ "pe/org.apache.streampipes.processors.filters.jvm.project",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.pulsar",
+ "pe/org.apache.streampipes.processor.imageclassification.qrcode",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.rest",
+ "pe/org.apache.streampipes.connect.adapters.ros",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq",
+ "pe/org.apache.streampipes.connect.adapters.simulator.randomdataset",
+ "pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream",
+ "pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding",
+ "pe/org.apache.streampipes.processors.textmining.jvm.sentencedetection",
+ "pe/org.apache.streampipes.processors.pattern-detection.flink.sequence",
+ "pe/org.apache.streampipes.processors.siddhi.sequence",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory",
+ "pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure",
+ "pe/org.apache.streampipes.connect.adapters.slack",
+ "pe/org.apache.streampipes.sinks.notifications.jvm.slack",
+ "pe/org.apache.streampipes.processor.geo.flink",
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.speed",
+ "pe/org.apache.streampipes.processors.transformation.jvm.split-array",
+ "pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator",
+ "pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding",
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop",
+ "pe/org.apache.streampipes.processors.statistics.flink.statistics-summary",
+ "pe/org.apache.streampipes.processors.siddhi.stop",
+ "pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter",
+ "pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer",
+ "pe/org.apache.streampipes.connect.adapters.ti",
+ "pe/org.apache.streampipes.processors.transformation.jvm.taskduration",
+ "pe/org.apache.streampipes.processors.filters.jvm.textfilter",
+ "pe/org.apache.streampipes.processors.filters.jvm.threshold",
+ "pe/org.apache.streampipes.processors.enricher.flink.timestamp",
+ "pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor",
+ "pe/org.apache.streampipes.processors.textmining.jvm.tokenizer",
+ "pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean",
+ "pe/org.apache.streampipes.processors.siddhi.increase",
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry",
+ "pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing",
+ "pe/org.apache.streampipes.processors.transformation.jvm.changed-value",
+ "pe/org.apache.streampipes.connect.adapters.wikipedia.edit",
+ "pe/org.apache.streampipes.connect.adapters.wikipedia.new",
+ "pe/org.apache.streampipes.processors.textmining.flink.wordcount"
]
},
- "pipeline-elements":{"Pipeline Elements":["pipeline-elements","org.apache.streampipes.processors.aggregation.flink.aggregation/org.apache.streampipes.processors.aggregation.flink.aggregation","org.apache.streampipes.processors.transformation.flink.processor.boilerplate/org.apache.streampipes.processors.transformation.flink.processor.boilerplate","org.apache.streampipes.processors.transformation.jvm.booloperator.counter/org.apache.streampipes.processors.transformation.jvm.booloperator.c [...]
"developer-guide": {
"Basics": [
"dev-guide-introduction",
diff --git a/documentation/website/siteConfig.js b/documentation/website/siteConfig.js
index 21df5e1..ac4584e 100644
--- a/documentation/website/siteConfig.js
+++ b/documentation/website/siteConfig.js
@@ -30,7 +30,6 @@ const siteConfig = {
headerLinks: [
{doc: 'user-guide-introduction', label: 'User Guide'},
{doc: 'dev-guide-introduction', label: 'Developer Guide'},
- {doc: 'pipeline-elements', label: 'Pipeline Elements'},
{doc: 'faq-common-problems', label: 'FAQ'},
{blog: true, label: 'Blog'},
{search: true},
@@ -44,6 +43,7 @@ const siteConfig = {
gaGtag: true,
disableHeaderTitle: true,
+ docsSideNavCollapsible: true,
headerIcon: 'img/sp-logo-color-docs.png',
footerIcon: 'img/sp-logo-color.png',
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.coindesk/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.coindesk/icon.png
new file mode 100644
index 0000000..420be61
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.coindesk/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.gdelt/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.gdelt/icon.png
new file mode 100644
index 0000000..b9ec80c
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.gdelt/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.news/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.news/icon.png
new file mode 100644
index 0000000..48afa81
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.news/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.stocks/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.stocks/icon.png
new file mode 100644
index 0000000..48afa81
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.stocks/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.set/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.set/icon.png
new file mode 100644
index 0000000..52f3575
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.set/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.stream/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.stream/icon.png
new file mode 100644
index 0000000..52f3575
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.stream/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.set/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.set/icon.png
new file mode 100644
index 0000000..1f9bb88
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.set/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.stream/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.stream/icon.png
new file mode 100644
index 0000000..1f9bb88
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.stream/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iss/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iss/icon.png
new file mode 100644
index 0000000..e4d1008
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.iss/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.set/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.set/icon.png
new file mode 100644
index 0000000..084246f
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.set/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.stream/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.stream/icon.png
new file mode 100644
index 0000000..084246f
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.stream/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.mqtt/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.mqtt/icon.png
new file mode 100644
index 0000000..b202048
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.mqtt/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.rest/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.rest/icon.png
new file mode 100644
index 0000000..b202048
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.rest/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png
new file mode 100644
index 0000000..f9ab06c
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.opcua/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.opcua/icon.png
new file mode 100644
index 0000000..ab68d43
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.opcua/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png
new file mode 100644
index 0000000..cfb6339
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ros/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ros/icon.png
new file mode 100644
index 0000000..ae0e943
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ros/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png
new file mode 100644
index 0000000..05cc7c3
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png
new file mode 100644
index 0000000..05cc7c3
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.slack/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.slack/icon.png
new file mode 100644
index 0000000..4a86273
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.slack/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ti/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ti/icon.png
new file mode 100644
index 0000000..06c06f9
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.ti/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png
new file mode 100644
index 0000000..46112dc
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png
new file mode 100644
index 0000000..46112dc
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png
new file mode 100644
index 0000000..2b3a037
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.http/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.http/icon.png
new file mode 100644
index 0000000..b44424d
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.http/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.kafka/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.kafka/icon.png
new file mode 100644
index 0000000..8b72662
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.kafka/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png
new file mode 100644
index 0000000..88f2035
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.pulsar/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.pulsar/icon.png
new file mode 100644
index 0000000..d1b1228
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.pulsar/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png
index dcd55fc..f7411da 100644
Binary files a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-cropper/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-cropper/icon.png
new file mode 100644
index 0000000..c35c817
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-cropper/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.count/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.count/icon.png
new file mode 100644
index 0000000..82f2384
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.count/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/icon.png
new file mode 100644
index 0000000..d37330b
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/icon.png
new file mode 100644
index 0000000..d2a81e7
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png
new file mode 100644
index 0000000..7389006
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.speed/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.speed/icon.png
new file mode 100644
index 0000000..7254648
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.speed/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator/icon.png
similarity index 100%
copy from documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png
copy to documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator/icon.png
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.absence/icon.png
similarity index 100%
copy from documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png
copy to documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.absence/icon.png
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png
new file mode 100644
index 0000000..23bdcbf
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png
new file mode 100644
index 0000000..aaab7bd
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.statistics.flink.statistics-summary/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.statistics.flink.statistics-summary/icon.png
new file mode 100644
index 0000000..c809464
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.statistics.flink.statistics-summary/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png
index dcd55fc..2eafc5f 100644
Binary files a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.csvmetadata/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.csvmetadata/icon.png
index dcd55fc..70a1c91 100644
Binary files a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.csvmetadata/icon.png and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.csvmetadata/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png
index dcd55fc..e52b42e 100644
Binary files a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png
new file mode 100644
index 0000000..acf8fd2
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png
new file mode 100644
index 0000000..3272e33
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.file/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.file/icon.png
new file mode 100644
index 0000000..2b3a037
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.file/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.http/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.http/icon.png
new file mode 100644
index 0000000..b44424d
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.protocol.set.http/icon.png differ
diff --git a/documentation/website/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png
new file mode 100644
index 0000000..cf7b22f
Binary files /dev/null and b/documentation/website/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png differ