chore(extensions-docs): update extensions doc assets to recent development state (#111)
Co-authored-by: dominikriemer <dominikriemer@users.noreply.github.com>
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md b/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md
deleted file mode 100644
index 26cd99b..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.coindesk.md
+++ /dev/null
@@ -1,44 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.coindesk
-title: Coindesk Bitcoin Price
-sidebar_label: Coindesk Bitcoin Price
----
-
-<!--
- ~ 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="/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.
-
-## Configuration
-
-### Currency
-
-The current in which the price should be provided.
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.flic.mqtt.md b/docs/pe/org.apache.streampipes.connect.adapters.flic.mqtt.md
deleted file mode 100644
index fa4a640..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.flic.mqtt.md
+++ /dev/null
@@ -1,59 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.flic.mqtt
-title: Flic MQTT
-sidebar_label: Flic MQTT
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.flic.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Connect Flic Smart Button over MQTT
-
-***
-
-## Required input
-
-This adapter uses the MQTT protocol and requires the data in following exemplary JSON format:
-{ "timestamp": 1584973344615, "click_type": SINGLE, "button_id": button1 }.
-***
-
-## Configuration
-
-### Broker URL
-
-Example: tcp://test-server.com:1883 (Protocol required. Port required)
-
-### Access Mode
-
-The user can choose between unauthenticated or authenticated access.
-
-### TOPIC
-The topic the MQTT broker publishes to.
-
-## Output
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md b/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md
deleted file mode 100644
index 537f2a8..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.gdelt.md
+++ /dev/null
@@ -1,42 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.gdelt
-title: GDELT
-sidebar_label: GDELT
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.gdelt/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-This adapter provides news events from the GDELT API.
-
-## Configuration
-
-(no futher configuration required)
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md b/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md
deleted file mode 100644
index cee7ae6..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.iex.stocks.md
+++ /dev/null
@@ -1,47 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.iex.stocks
-title: IEX Cloud Stock Quotes
-sidebar_label: IEX Cloud Stock Quotes
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.stocks/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-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
-
-
-### API Token
-A valid API token from the IEXCloud API.
-
-### Stock Symbol
-A stock symbol that should be monitored.
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.image.set.md b/docs/pe/org.apache.streampipes.connect.adapters.image.set.md
deleted file mode 100644
index fc79002..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.image.set.md
+++ /dev/null
@@ -1,38 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.image.set
-title: Image Upload (Set)
-sidebar_label: Image Upload (Set)
----
-
-<!--
- ~ 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="/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
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md b/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md
deleted file mode 100644
index a03806d..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.image.stream.md
+++ /dev/null
@@ -1,38 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.image.stream
-title: Image Upload (Stream)
-sidebar_label: Image Upload (Stream)
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.image.stream/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Upload a zip file of images and create an event per image
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md b/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md
deleted file mode 100644
index 13914d5..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.influxdb.set.md
+++ /dev/null
@@ -1,41 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.influxdb.set
-title: InfluxDB Set Adapter
-sidebar_label: InfluxDB Set Adapter
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.set/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-Creates a data set for an InfluxDB measurement.
-
-***
-
-## Configuration
-
-
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.iss.md b/docs/pe/org.apache.streampipes.connect.adapters.iss.md
deleted file mode 100644
index ab27d57..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.iss.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.iss
-title: ISS Location
-sidebar_label: ISS Location
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.iss/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Shows the live position of the International Space Station (ISS), updated every two seconds.
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md b/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md
deleted file mode 100644
index 7f63861..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.mysql.set.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.mysql.set
-title: MySQL Set Adapter
-sidebar_label: MySQL Set Adapter
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.set/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Creates a data set from an SQL table
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md b/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md
deleted file mode 100644
index 426242b..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.mysql.stream.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.mysql.stream
-title: MySql Stream Adapter
-sidebar_label: MySql Stream Adapter
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.mysql.stream/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Creates a data stream for a SQL table
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md b/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md
deleted file mode 100644
index 6c61fc5..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.netio.mqtt.md
+++ /dev/null
@@ -1,64 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.netio.mqtt
-title: NETIO MQTT M2M
-sidebar_label: NETIO MQTT M2M
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Connect Robots running on ROS
-
-
-***
-
-## Required input
-
-This sink does not have any requirements and works with any incoming event type.
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### Ros Bridge
-
-Example: test-server.com (No protocol)
-
-### Port
-
-The port of the ROS instance.
-
-### Topic
-
-Example: /battery (Starts with /)
-
-
-## Output
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md b/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md
deleted file mode 100644
index 583ce04..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.netio.rest.md
+++ /dev/null
@@ -1,64 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.netio.rest
-title: NETIO http JSON
-sidebar_label: NETIO http JSON
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.netio.rest/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Connect Robots running on ROS
-
-
-***
-
-## Required input
-
-This sink does not have any requirements and works with any incoming event type.
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### Ros Bridge
-
-Example: test-server.com (No protocol)
-
-### Port
-
-The port of the ROS instance.
-
-### Topic
-
-Example: /battery (Starts with /)
-
-
-## Output
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md b/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md
deleted file mode 100644
index fa6136c..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera
-title: NSW Traffic Cameras
-sidebar_label: NSW Traffic Cameras
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Traffic camera images produced by NSW Australia
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md b/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md
deleted file mode 100644
index d0f4889..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdataset.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.simulator.randomdataset
-title: Random Data Simulator (Set)
-sidebar_label: Random Data Simulator (Set)
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Publishes a bounded stream of random events.
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md b/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md
deleted file mode 100644
index b16614e..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.simulator.randomdatastream
-title: Random Data Simulator (Stream)
-sidebar_label: Random Data Simulator (Stream)
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Publishes a continuous stream of random events
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.slack.md b/docs/pe/org.apache.streampipes.connect.adapters.slack.md
deleted file mode 100644
index 6f38240..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.slack.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.slack
-title: Slack
-sidebar_label: Slack
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.slack/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Subscribes to a Slack channel
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.ti.md b/docs/pe/org.apache.streampipes.connect.adapters.ti.md
deleted file mode 100644
index c495db2..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.ti.md
+++ /dev/null
@@ -1,57 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.ti
-title: TI Sensor Tag
-sidebar_label: TI Sensor Tag
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.ti/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Consumes messages from a broker using the MQTT protocol
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### Broker Url
-
-Example: tcp://test-server.com:1883 (Protocol required. Port required)"
-
-### Topic
-
-Example: test/topic
-
-### Access Mode
-
-Unauthenticated or Authenticated (Username/Password)
-
-## Output
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md b/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md
deleted file mode 100644
index f0c0a5c..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.edit.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.wikipedia.edit
-title: Wikipedia Edits
-sidebar_label: Wikipedia Edits
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Continuously publishes recent Wikipedia edits
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md b/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md
deleted file mode 100644
index c041e11..0000000
--- a/docs/pe/org.apache.streampipes.connect.adapters.wikipedia.new.md
+++ /dev/null
@@ -1,39 +0,0 @@
----
-id: org.apache.streampipes.connect.adapters.wikipedia.new
-title: Wikipedia New Articles
-sidebar_label: Wikipedia New Articles
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Continuously publishes articles created on Wikipedia
-
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.influxdb.stream.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.influxdb.stream.md
index 1331f48..d01a6ac 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.influxdb.stream.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.influxdb.stream.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.influxdb.stream
+id: org.apache.streampipes.connect.iiot.adapters.influxdb.stream
title: InfluxDB Stream Adapter
sidebar_label: InfluxDB Stream Adapter
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.influxdb.stream/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.iiot.adapters.iolink.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.iolink.md
new file mode 100644
index 0000000..38363c9
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.iolink.md
@@ -0,0 +1,90 @@
+---
+id: org.apache.streampipes.connect.iiot.adapters.iolink
+title: ifm IOLink
+sidebar_label: ifm IOLink
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.iolink/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+This adapter enables the integration of IO-Link sensor data produced by an ifm IO-Link Master
+(e.g., AL1350) with Apache StreamPipes. To use this adapter, you need to configure your IO-Link
+master to publish events to an MQTT broker. This can be achieved through a REST interface or via
+the browser at `http://##IP_OF_IO_LINK_MASTER##/web/subscribe`. For detailed instructions,
+please refer to the ifm documentation.
+
+### Requirements
+The JSON events should include the following information:
+- `deviceinfo.serialnumber`
+- Only the pdin value is required for each port (e.g., `port[0]`).
+- The event `timer[1].datachanged` can be used as a trigger.
+Using this adapter, you can create a stream for sensors of the same type.
+
+### Restrictions
+This version supports a single IO-Link master. If you want to connect multiple masters, they must have the same setup.
+If you have different requirements, please inform us through the mailing list or GitHub discussions.
+
+***
+
+## Configuration
+
+Here is a list of the configuration parameters you must provide.
+
+### Broker URL
+
+Enter the URL of the broker, including the protocol (e.g. `tcp://10.20.10.3:1883`)
+
+### Access Mode
+
+If necessary, provide broker credentials.
+
+### Ports
+
+Select the ports that are connected to the IO-Link sensors.
+
+### Sensor Type
+
+Choose the type of sensor you want to connect. (**IMPORTANT:** Currently, only the VVB001 is supported)
+
+## Output
+
+The output includes all values from the selected sensor type. Here is an example for the `VVB001 sensor`:
+```
+{
+ "aPeak": 6.6,
+ "aRms": 1.8,
+ "crest": 3.7,
+ "out1": true,
+ "out2": true,
+ "port": "000000001234",
+ "status": 0,
+ "temperature": 22,
+ "timestamp": 1685525380729,
+ "vRms": 0.0023
+}
+```
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.opcua.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.opcua.md
similarity index 93%
rename from docs/pe/org.apache.streampipes.connect.adapters.opcua.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.opcua.md
index 5c859b7..76a65ca 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.opcua.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.opcua.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.opcua
+id: org.apache.streampipes.connect.iiot.adapters.opcua
title: OPC UA
sidebar_label: OPC UA
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.opcua/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.opcua/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.plc4x.modbus.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.adapters.plc4x.modbus.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus.md
index 630069a..679af9d 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.plc4x.modbus.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.plc4x.modbus
+id: org.apache.streampipes.connect.iiot.adapters.plc4x.modbus
title: PLC4X MODBUS
sidebar_label: PLC4X MODBUS
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.modbus/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.s7.md
similarity index 88%
rename from docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.s7.md
index caeee16..a8dde67 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.plc4x.s7.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.plc4x.s7.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.plc4x.s7
+id: org.apache.streampipes.connect.iiot.adapters.plc4x.s7
title: PLC4X S7
sidebar_label: PLC4X S7
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.ros.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.ros.md
similarity index 90%
rename from docs/pe/org.apache.streampipes.connect.adapters.ros.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.ros.md
index aa3c88d..aeac399 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.ros.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.ros.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.ros
+id: org.apache.streampipes.connect.iiot.adapters.ros
title: ROS Bridge
sidebar_label: ROS Bridge
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.ros/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.ros/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.simulator.machine.md b/docs/pe/org.apache.streampipes.connect.iiot.adapters.simulator.machine.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.adapters.simulator.machine.md
rename to docs/pe/org.apache.streampipes.connect.iiot.adapters.simulator.machine.md
index 40c360f..ab03d5a 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.simulator.machine.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.adapters.simulator.machine.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.adapters.simulator.machine
+id: org.apache.streampipes.connect.iiot.adapters.simulator.machine
title: Machine Data Simulator
sidebar_label: Machine Data Simulator
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.simulator.machine/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.simulator.machine/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -37,4 +37,4 @@
* flowrate
* pressure
* waterlevel
-***
+***
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.file.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.file.md
index 152b1fa..e91e846 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.file.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.file
+id: org.apache.streampipes.connect.iiot.protocol.stream.file
title: File Stream
sidebar_label: File Stream
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.file/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.http.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.http.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.http.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.http.md
index 3761f7f..e24df3a 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.http.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.http.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.http
+id: org.apache.streampipes.connect.iiot.protocol.stream.http
title: HTTP Stream
sidebar_label: HTTP Stream
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.http/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.http/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.httpserver.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.httpserver.md
similarity index 86%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.httpserver.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.httpserver.md
index 75a8fcc..a7ac3a8 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.httpserver.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.httpserver.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.httpserver
+id: org.apache.streampipes.connect.iiot.protocol.stream.httpserver
title: HTTP Server
sidebar_label: HTTP Server
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.httpserver/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.httpserver/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.kafka.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.kafka.md
index 97b1484..d2b380f 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.kafka.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.kafka.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.kafka
+id: org.apache.streampipes.connect.iiot.protocol.stream.kafka
title: Apache Kafka
sidebar_label: Apache Kafka
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.kafka/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.kafka/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.mqtt.md
similarity index 89%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.mqtt.md
index bd47545..d3f374c 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.mqtt.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.mqtt.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.mqtt
+id: org.apache.streampipes.connect.iiot.protocol.stream.mqtt
title: MQTT
sidebar_label: MQTT
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.nats.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.nats.md
new file mode 100644
index 0000000..0e43cf5
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.nats.md
@@ -0,0 +1,69 @@
+---
+id: org.apache.streampipes.connect.iiot.protocol.stream.nats
+title: NATS
+sidebar_label: NATS
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+Consumes events from a NATS broker.
+
+***
+
+## Configuration
+
+### NATS Subject
+
+The subject (topic) where events should be received from. When using wildcard subjects, all messages need to have the same format currently.
+
+### NATS Broker URL
+
+The URL to connect to the NATS broker. It can be provided multiple urls separated by commas(,).
+(e.g., nats://localhost:4222,nats://localhost:4223)
+
+### Username
+
+The username to authenticate the client with NATS broker.
+
+It is an optional configuration.
+
+### NATS Broker URL
+
+The password to authenticate the client with NATS broker.
+
+It is an optional configuration.
+
+### NATS Connection Properties
+
+All other possible connection configurations that the nats client can be created with.
+It can be provided as key value pairs separated by colons(:) and commas(,).
+(e.g., io.nats.client.reconnect.max:1, io.nats.client.timeout:1000)
+
+It is an optional configuration.
+
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.pulsar.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.pulsar.md
index 7f35a24..f9adc56 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.pulsar.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.pulsar.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.connect.protocol.stream.pulsar
+id: org.apache.streampipes.connect.iiot.protocol.stream.pulsar
title: Apache Pulsar
sidebar_label: Apache Pulsar
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.pulsar/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
diff --git a/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq.md
similarity index 78%
copy from docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
copy to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq.md
index 152b1fa..d6c5cb3 100644
--- a/docs/pe/org.apache.streampipes.connect.protocol.stream.file.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.connect.protocol.stream.file
-title: File Stream
-sidebar_label: File Stream
+id: org.apache.streampipes.connect.iiot.protocol.stream.rocketmq
+title: Apache RocketMQ
+sidebar_label: Apache RocketMQ
---
<!--
@@ -25,14 +25,14 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.protocol.stream.file/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Continuously streams the content from a file
+Consumes messages from an Apache RocketMQ broker
***
diff --git a/docs/pe/org.apache.streampipes.connect.adapters.iex.news.md b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.tubemq.md
similarity index 63%
rename from docs/pe/org.apache.streampipes.connect.adapters.iex.news.md
rename to docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.tubemq.md
index 97bcf1b..0f32133 100644
--- a/docs/pe/org.apache.streampipes.connect.adapters.iex.news.md
+++ b/docs/pe/org.apache.streampipes.connect.iiot.protocol.stream.tubemq.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.connect.adapters.iex.news
-title: IEX Cloud News
-sidebar_label: IEX Cloud News
+id: org.apache.streampipes.connect.iiot.protocol.stream.tubemq
+title: Apache TubeMQ (InLong)
+sidebar_label: Apache TubeMQ (InLong)
---
<!--
@@ -25,24 +25,30 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.connect.adapters.iex.news/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-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.
+
+Consumes messages from an Apache TubeMQ broker.
***
## Configuration
+### TubeMQ Master Information
-### API Token
-A valid API token from the IEXCloud API.
+This field describes the endpoints of all the TubeMQ masters.
-### Stock Symbol
-A stock symbol that should be monitored.
+The format should be like `ip1:port1,ip2:port2,ip3:port3`.
+### TubeMQ Topic
+
+The topic where events should be sent to.
+
+### TubeMQ Consumer Group
+
+The consumer group of the TubeMQ Consumer.
diff --git a/docs/pe/org.apache.streampipes.processor.geo.flink.md b/docs/pe/org.apache.streampipes.processor.geo.flink.md
deleted file mode 100644
index 8de5166..0000000
--- a/docs/pe/org.apache.streampipes.processor.geo.flink.md
+++ /dev/null
@@ -1,51 +0,0 @@
----
-id: org.apache.streampipes.processor.geo.flink
-title: Spatial Grid Enrichment
-sidebar_label: Spatial Grid Enrichment
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processor.geo.flink/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-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
-
-* Latitude property
-* Longitude property
-* The size of the cell
-* Latitude and longitude of the first cell
-
-## Output
-Appends the grid cell coordinates to the input event
diff --git a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md
index b9c9898..fb42a1a 100644
--- a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md
+++ b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification.md
@@ -23,7 +23,7 @@
-->
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -49,4 +49,4 @@
Field that contains the image.
-## Output
+## Output
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
index f78bc07..e2cd6b0 100644
--- a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
+++ b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper.md
@@ -23,7 +23,7 @@
-->
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-cropper/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -37,7 +37,7 @@
## 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
+A box consists of the x and y coordinates in the image as well as the height and width
## Output
-A new event for each box containing the cropped image
+A new event for each box containing the cropped image
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
index bc7ffa7..8a09f3a 100644
--- a/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
+++ b/docs/pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.jvm.image-enricher/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,12 +32,12 @@
## Description
-Image Enrichment: Enriches an + image with + given bounding box coordinates
+Image Enrichment: Enriches an + image with + given bounding box coordinates
## Required input
+
An image and an array with bounding boxes, an array with scores and an array with labels.
A box consists of the x and y coordinates in the image as well as the height and width, and the classindex with score
-
## Output
-A new event containing the image with bounding boxes rendered according to the boxes of the input event
+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/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md b/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md
index c7000c8..74f1234 100644
--- a/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md
+++ b/docs/pe/org.apache.streampipes.processor.imageclassification.qrcode.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processor.imageclassification.qrcode/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -63,6 +63,6 @@
```
{
'qrvalue': 'http://githhub.com/',
- 'timestamp': 1621244783151
+ 'timestamp': 1621244783151
}
-```
+```
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.aggregation.flink.aggregation.md b/docs/pe/org.apache.streampipes.processors.aggregation.flink.aggregation.md
deleted file mode 100644
index 410635b..0000000
--- a/docs/pe/org.apache.streampipes.processors.aggregation.flink.aggregation.md
+++ /dev/null
@@ -1,61 +0,0 @@
----
-id: org.apache.streampipes.processors.aggregation.flink.aggregation
-title: Aggregation
-sidebar_label: Aggregation
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.aggregation/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)
-
-***
-
-## Required input
-
-The aggregation processor requires a data stream that has at least one field containing a numerical value.
-
-***
-
-## Configuration
-
-### Group by
-The aggregation function can be calculated separately (partitioned) by the selected field value.
-
-### Output every
-The frequency in which aggregated values are sent in seconds.
-
-### Time window
-The size of the time window in seconds
-
-### Aggregated Value
-The field used for calculating the aggregation value.
-
-## Output
-
-This processor appends the latest aggregated value to every input event that arrives.
diff --git a/docs/pe/org.apache.streampipes.processors.aggregation.flink.eventcount.md b/docs/pe/org.apache.streampipes.processors.aggregation.flink.eventcount.md
deleted file mode 100644
index 9d53deb..0000000
--- a/docs/pe/org.apache.streampipes.processors.aggregation.flink.eventcount.md
+++ /dev/null
@@ -1,56 +0,0 @@
----
-id: org.apache.streampipes.processors.aggregation.flink.eventcount
-title: Event Counter
-sidebar_label: Event Counter
----
-
-<!--
- ~ 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.
- ~
- -->
-
-
-
-
-
-***
-
-## Description
-Counts the number of events arriving within a time window. An event is emitted every time the time window expires.
-
-***
-
-## Required input
-There is no specific input required.
-
-***
-
-## Configuration
-Time Window: The scale and size of the time window.
-
-### TimeWindowSize
-Specifies the size of the time window.
-
-### Time Window Scale
-Specifies the scale/unit of the time window. There are three different time scales to choose from: seconds, minutes or hours.
-
-## Output
-```
-{
- 'timestamp': 1601301980014,
- 'count': 12
-}
-```
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.aggregation.flink.rate.md b/docs/pe/org.apache.streampipes.processors.aggregation.flink.rate.md
deleted file mode 100644
index 7817511..0000000
--- a/docs/pe/org.apache.streampipes.processors.aggregation.flink.rate.md
+++ /dev/null
@@ -1,54 +0,0 @@
----
-id: org.apache.streampipes.processors.aggregation.flink.rate
-title: Event Rate
-sidebar_label: Event Rate
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.rate/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-Computes the current event rate. Output is a number representing events per second.
-
-***
-
-## Required input
-The event rate processor works with any stream and does not have any specific requirements.
-
-***
-
-## Configuration
-
-
-### Time Baseline
-Specifies the size of the window used used for calculating the rate in seconds. This parameters also determines the output rate.
-
-## Output
-```
-{
- 'rate': 0.8
-}
-```
diff --git a/docs/pe/org.apache.streampipes.processors.changedetection.jvm.cusum.md b/docs/pe/org.apache.streampipes.processors.changedetection.jvm.cusum.md
deleted file mode 100644
index b890dc0..0000000
--- a/docs/pe/org.apache.streampipes.processors.changedetection.jvm.cusum.md
+++ /dev/null
@@ -1,65 +0,0 @@
----
-id: org.apache.streampipes.processors.changedetection.jvm.cusum
-title: Cusum
-sidebar_label: Cusum
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.changedetection.jvm.cusum/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
--->
-
-***
-
-## Description
-
-Performs change detection on a single dimension of the incoming data stream. A change is detected if the cumulative deviation from the mean exceeds a certain threshold. This implementation tracks the mean and the standard deviation using Welford's algorithm, which is well suited for data streams.
-
-***
-
-## Required input
-
-The cusum processor requires a data stream that has at least one field containing a numerical value.
-
-***
-
-## Configuration
-
-### Value to observe
-Specify the dimension of the data stream (e.g. the temperature) on which to perform change detection.
-
-### Parameter `k`
-`k` controls the sensitivity of the change detector. Its unit are standard deviations. For an observation `x_n`, the Cusum value is `S_n = max(0, S_{n-1} - z-score(x_n) - k)`. Thus, the cusum-score `S` icnreases if `S_{n-1} - z-score(x_n) > k`.
-
-### Parameter `h`
-The alarm theshold in standard deviations. An alarm occurs if `S_n > h`
-
-## Output
-
-This processor outputs the original data stream plus
-
-- `cusumLow`: The cusum value for negative changes
-- `cusumHigh`: The cusum value for positive changes
-- `changeDetectedLow`: Boolean indicating if a negative change was detected
-- `changeDetectedHigh`: Boolean indicating if a positive change was detected
diff --git a/docs/pe/org.apache.streampipes.processors.changedetection.jvm.welford.md b/docs/pe/org.apache.streampipes.processors.changedetection.jvm.welford.md
new file mode 100644
index 0000000..10f9536
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.changedetection.jvm.welford.md
@@ -0,0 +1,72 @@
+---
+id: org.apache.streampipes.processors.changedetection.jvm.welford
+title: Welford Change Detection
+sidebar_label: Welford Change Detection
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.changedetection.jvm.welford/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+-->
+
+***
+
+## Description
+
+Performs change detection on a single dimension of the incoming data stream. This implementation tracks the mean and the
+standard deviation using Welford's algorithm, which is well suited for data streams. A change is detected if the
+cumulative deviation from the mean exceeds a certain threshold.
+
+***
+
+## Required input
+
+The welford change dectection processor requires a data stream that has at least one field containing a numerical value.
+
+***
+
+## Configuration
+
+### Value to observe
+
+Specify the dimension of the data stream (e.g. the temperature) on which to perform change detection.
+
+### Parameter `k`
+
+`k` controls the sensitivity of the change detector. Its unit are standard deviations. For an observation `x_n`, the
+Cusum value is `S_n = max(0, S_{n-1} - z-score(x_n) - k)`. Thus, the cusum-score `S` icnreases
+if `S_{n-1} - z-score(x_n) > k`.
+
+### Parameter `h`
+
+The alarm theshold in standard deviations. An alarm occurs if `S_n > h`
+
+## Output
+
+This processor outputs the original data stream plus
+
+- `cumSumLow`: The cumulative sum value for negative changes
+- `cumSumHigh`: The cumulative sum value for positive changes
+- `changeDetectedLow`: Boolean indicating if a negative change was detected
+- `changeDetectedHigh`: Boolean indicating if a positive change was detected
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.md b/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.md
deleted file mode 100644
index b8100bf..0000000
--- a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.md
+++ /dev/null
@@ -1,51 +0,0 @@
----
-id: org.apache.streampipes.processors.enricher.flink.processor.urldereferencing
-title: URL Dereferencing
-sidebar_label: URL Dereferencing
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Parses and appends the html page as a string to event.
-
-***
-
-## Required input
-The URL Dereferencing processor requires an input stream that provides an input field of type 'string', representing
-the URL to dereference.
-
-***
-
-## Configuration
-
-### URL
-The field containing the URL to dereference.
-
-## Output
-The processor appends the extracted HTML page to each input event.
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.jvm.jseval.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.jseval.md
new file mode 100644
index 0000000..3fe0183
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.jseval.md
@@ -0,0 +1,55 @@
+---
+id: org.apache.streampipes.processors.enricher.jvm.jseval
+title: JavaScript Eval
+sidebar_label: JavaScript Eval
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.jseval/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+A pipeline element that allows writing user defined JavaScript function to enrich events.
+
+***
+
+## Required input
+This processor does not have any specific input requirements.
+
+***
+
+## Configuration
+User can specify their custom enrichment logic within the `process` method. Please note that the `process` function
+must be in the following format and it must return a map of data which is compatible with the output schema.
+```javascript
+ function process(event) {
+ // do processing here.
+ // return a map with fields that matched defined output schema.
+ return {id: event.id, tempInCelsius: (event.tempInKelvin - 273.15)};
+ }
+```
+
+## Output
+A new event with the user defined output schema.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop.md
similarity index 89%
rename from docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop.md
rename to docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop.md
index 41ade71..8597089 100644
--- a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop.md
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.enricher.flink.processor.math.mathop
+id: org.apache.streampipes.processors.enricher.jvm.processor.math.mathop
title: Math
sidebar_label: Math
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.processor.math.mathop/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -53,4 +53,4 @@
The math operation that should be performed.
## Output
-The processor appends the calculation result to each input event.
+The processor appends the calculation result to each input event.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop.md
similarity index 88%
rename from docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop.md
rename to docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop.md
index 19e423e..ce274a8 100644
--- a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop.md
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop
+id: org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop
title: Static Math
sidebar_label: Static Math
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.processor.math.staticmathop/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -53,4 +53,4 @@
The math operation that should be performed.
## Output
-The processor appends the calculation result to each input event.
+The processor appends the calculation result to each input event.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry.md
similarity index 89%
rename from docs/pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry.md
rename to docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry.md
index 9631af3..f5d55cc 100644
--- a/docs/pe/org.apache.streampipes.processors.enricher.flink.processor.trigonometry.md
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.enricher.flink.processor.trigonometry
+id: org.apache.streampipes.processors.enricher.jvm.processor.trigonometry
title: Trigonometry Functions
sidebar_label: Trigonometry Functions
---
@@ -25,7 +25,7 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.processor.trigonometry/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -53,4 +53,4 @@
The trigonometric function that should be calculated.
## Output
-The processor appends the calculation result to each input event.
+The processor appends the calculation result to each input event.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
index 64e254b..cb49f5b 100644
--- a/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure.md
@@ -46,4 +46,4 @@
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.
+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/docs/pe/org.apache.streampipes.processors.enricher.flink.timestamp.md b/docs/pe/org.apache.streampipes.processors.enricher.jvm.valuechange.md
similarity index 69%
rename from docs/pe/org.apache.streampipes.processors.enricher.flink.timestamp.md
rename to docs/pe/org.apache.streampipes.processors.enricher.jvm.valuechange.md
index 0457d97..92718d8 100644
--- a/docs/pe/org.apache.streampipes.processors.enricher.flink.timestamp.md
+++ b/docs/pe/org.apache.streampipes.processors.enricher.jvm.valuechange.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.enricher.flink.timestamp
-title: Timestamp Enricher
-sidebar_label: Timestamp Enricher
+id: org.apache.streampipes.processors.enricher.jvm.valuechange
+title: Value Change
+sidebar_label: Value Change
---
<!--
@@ -19,30 +19,34 @@
~ 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="/img/pipeline-elements/org.apache.streampipes.processors.enricher.flink.timestamp/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.valuechange/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Appends the current time in ms to the event payload.
+
+The processing element should be able to detect when a numeric property change from one configured value to another.
***
## Required input
-The timestamp enricher works with any input event.
+The required input is a number.
***
## Configuration
+Value of last event (example: 0)
-(no further configuration required)
+Value of current event (example: 5)
+
## Output
-This processor appends the current system time to every input event.
+A boolean value is returned when the input changes.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md
index 0addcf1..8cb6698 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.compose.md
@@ -47,4 +47,4 @@
(no further configuration required)
## Output
-The compose processor has a configurable output that can be selected by the user at pipeline modeling time.
+The compose processor has a configurable output that can be selected by the user at pipeline modeling time.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md
index 7ebfc14..5dfb0d9 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.enrich.md
@@ -44,4 +44,4 @@
* The last event of the stream is hold in state and each event of the other stream is enriched by the properties the user selected
## Output
-The compose processor has a configurable output that can be selected by the user at pipeline modeling time.
+The compose processor has a configurable output that can be selected by the user at pipeline modeling time.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
index 2a683ff..569b5ee 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.merge.md
@@ -54,4 +54,4 @@
* The Time Interval describes the maximum value between two events to decide whether they are a match. To be a valid match the following function must be true: | timestamp_stream_1 - timestamp_stream_2 | < interval
## Output
-The Compose processor has a configurable output that can be selected by the user at pipeline modeling time.
+The Compose processor has a configurable output that can be selected by the user at pipeline modeling time.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.movingaverage.md
similarity index 67%
copy from docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
copy to docs/pe/org.apache.streampipes.processors.filters.jvm.movingaverage.md
index 1485fd0..2b6cad6 100644
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.movingaverage.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.pattern-detection.flink.peak-detection
-title: Peak Detection
-sidebar_label: Peak Detection
+id: org.apache.streampipes.processors.filters.jvm.movingaverage
+title: Moving Average
+sidebar_label: Moving Average
---
<!--
@@ -23,31 +23,24 @@
-->
-
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
***
+
## Description
-Detect peaks in time series data.
+Smooths the data stream by the mean/median of the last n values.
***
## Required input
-
-
+A numerical field is required.
***
## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
+### N Value
+Specifies the number of previous data points which are used to smooth the data.
+### Method
+Specifies the method which is used to smooth the data. Choose between mean and median.
## Output
+Appends a field with the smoothed data.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md
index 56dd341..55c3208 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.numericalfilter.md
@@ -53,4 +53,4 @@
Specifies the threshold value.
## Output
-The processor outputs the input event if it satisfies the filter expression.
+The processor outputs the input event if it satisfies the filter expression.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-converter.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter.md
similarity index 61%
rename from docs/pe/org.apache.streampipes.processors.transformation.flink.field-converter.md
rename to docs/pe/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter.md
index a4ec93f..1f2d714 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-converter.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.transformation.flink.field-converter
-title: Field Converter
-sidebar_label: Field Converter
+id: org.apache.streampipes.processors.filters.jvm.processor.booleanfilter
+title: Boolean Filter
+sidebar_label: Boolean Filter
---
<!--
@@ -25,30 +25,28 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-converter/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-
-Converts a string value to a number data type.
-
+The Boolean Filter processor filters based on a boolean value field
***
-## Required input
-This processor requires an event that contains at least one string valued field.
+## Required Input
+The processor works with any input event that has one field containing a boolean value
***
## Configuration
### Field
-Specifies the string field that is converted.
+Specifies the field name where the filter operation should be applied on.
-### Datatype
-Specifies the target datatype depending on the previously specified string field.
+### Field Value
+Events with the selected field value are forwarded
## Output
-Output event in the specified target datatype.
+The processor outputs the input event if the event value is equals the selected field value
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md
index bcbc2ff..69a0616 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.project.md
@@ -45,4 +45,4 @@
(no further configuration required)
## Output
-The output depends on the fields selected at pipeline development time.
+The output depends on the fields selected at pipeline development time.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.schema.md
similarity index 67%
copy from docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
copy to docs/pe/org.apache.streampipes.processors.filters.jvm.schema.md
index 1485fd0..ebdfc66 100644
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.schema.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.pattern-detection.flink.peak-detection
-title: Peak Detection
-sidebar_label: Peak Detection
+id: org.apache.streampipes.processors.filters.jvm.schema
+title: Merge stream with same schema
+sidebar_label: Merge stream with same schema
---
<!--
@@ -24,30 +24,23 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-***
## Description
-Detect peaks in time series data.
+Merges two events by their schema.
+It checks two whether the schemas of two events are equal or not.
+If the schemas are not equal we can throw SpRuntimeException otherwise we can collect them.
***
## Required input
-
-
+Two events are needed.
***
## Configuration
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
+For each stream schema info should be present
## Output
+Events with same schemas.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.sdt.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.sdt.md
new file mode 100644
index 0000000..02de521
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.sdt.md
@@ -0,0 +1,85 @@
+---
+id: org.apache.streampipes.processors.filters.jvm.sdt
+title: Swinging Door Trending (SDT) Filter Processor
+sidebar_label: Swinging Door Trending (SDT) Filter Processor
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.sdt/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+
+***
+
+## Description
+
+The **Swinging Door Trending (SDT)** algorithm is a linear trend compression algorithm.
+In essence, it replaces a series of continuous `(timestamp, value)` points with a straight line determined by the start and end points.
+
+The **Swinging Door Trending (SDT) Filter Processor** can extract and forward the characteristic events of the original stream.
+In general, this filter can also be used to reduce the frequency of original data in a lossy way.
+
+***
+
+## Required Inputs
+
+The processor works with any input event that has **one field containing a timestamp** and
+**one field containing a numerical value**.
+
+***
+
+## Configuration
+
+### Timestamp Field
+Specifies the timestamp field name where the SDT algorithm should be applied on.
+
+### Value Field
+Specifies the value field name where the SDT algorithm should be applied on.
+
+### Compression Deviation
+**Compression Deviation** is the most important parameter in SDT that represents the maximum difference
+between the current sample and the current linear trend.
+
+**Compression Deviation** needs to be greater than 0 to perform compression.
+
+### Compression Minimum Time Interval
+**Compression Minimum Time Interval** is a parameter measures the time distance between two stored data points,
+which is used for noisy reduction.
+
+If the time interval between the current point and the last stored point is less than or equal to its value,
+current point will NOT be stored regardless of compression deviation.
+
+The default value is `0` with time unit ms.
+
+### Compression Maximum Time Interval
+**Compression Maximum Time Interval** is a parameter measure the time distance between two stored data points.
+
+If the time interval between the current point and the last stored point is greater than or equal to its value,
+current point will be stored regardless of compression deviation.
+
+The default value is `9,223,372,036,854,775,807`(`Long.MAX_VALUE`) with time unit ms.
+
+***
+
+## Output
+The characteristic event stream forwarded by the SDT filter.
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md
index 07526d0..ce5c254 100644
--- a/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.textfilter.md
@@ -50,4 +50,4 @@
The operation used by the filter processor (equals or matches)
## Output
-The processor outputs the input event if it satisfies the filter expression.
+The processor outputs the input event if it satisfies the filter expression.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.filters.jvm.throughputmon.md b/docs/pe/org.apache.streampipes.processors.filters.jvm.throughputmon.md
new file mode 100644
index 0000000..f97b5f2
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.filters.jvm.throughputmon.md
@@ -0,0 +1,56 @@
+---
+id: org.apache.streampipes.processors.filters.jvm.throughputmon
+title: Throughput Monitor
+sidebar_label: Throughput Monitor
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.throughputmon/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+The Throughput Monitoring processor computes throughput statistics.
+
+***
+
+## Required Input
+The processor works with any input event.
+
+***
+
+## Configuration
+
+### Batch Window Size
+Specifies the number of events that should be used for calculating throughput statistics.
+
+
+## Output
+The processor outputs a new event containing:
+* The current timestamp (timestamp)
+* The start time of the batch window (starttime)
+* The end time of the batch window (endtime)
+* The duration between both windows (duration)
+* The number of events collected in the window (should be equal to batch size)
+* The throughput in events per second
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry.md
new file mode 100644
index 0000000..a022374
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry.md
@@ -0,0 +1,95 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry
+title: Geo Buffer Geometry
+sidebar_label: Geo Buffer Geometry
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+Creates a buffer polygon geometry from a geometry
+***
+
+## Required inputs
+
+* JTS Geometry
+* EPSG Code
+* Distance
+* Cap Style
+* Join Style
+* Mitre-Limit
+* Side
+* Simplify Factor
+* Quadrant Segments
+***
+
+## Configuration
+
+### Geometry field
+Input Geometry
+
+### EPSG field
+Integer value representing EPSG code
+
+### Distance
+The buffer distance around in geometry in meter
+
+### Cap Style
+Defines the endcap style of the buffer.
+* CAP_ROUND - the usual round end caps
+* CAP_FLAT - end caps are truncated flat at the line ends
+* CAP_SQUARE - end caps are squared off at the buffer distance beyond the line ends
+
+### Simplify Factor
+The default simplify factor Provides an accuracy of about 1%, which matches the accuracy of the
+default Quadrant Segments parameter.
+
+### Quadrant Segments
+The default number of facets into which to divide a fillet of 90 degrees.
+
+### Join Style
+Defines the corners in a buffer
+* JOIN_ROUND - the usual round join
+* JOIN_MITRE - corners are "sharp" (up to a distance limit)
+* JOIN_BEVEL - corners are beveled (clipped off).
+
+### Mitre-Limit
+Mitre ratio limit (only affects mitered join style)
+
+### Side
+`left` or `right` performs a single-sided buffer on the geometry, with the buffered side
+relative to the direction of the line or polygon.
+
+***
+
+## Output
+A polygon geometry with EPSG code. Shape is defined by input parameters.
+
+
+### Example
+
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint.md
new file mode 100644
index 0000000..04346ce
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint.md
@@ -0,0 +1,82 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint
+title: Geo Buffer Point
+sidebar_label: Geo Buffer 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+Creates a buffer polygon geometry from a point geometry
+***
+
+## Required inputs
+
+* JTS Geometry
+* EPSG Code
+* Distance
+* Cap Style
+* Simplify Factor
+* Quadrant Segments
+***
+
+## Configuration
+
+### Geometry Field
+Input Point Geometry
+
+### EPSG field
+Integer value representing EPSG code
+
+### Distance
+The buffer distance around the geometry in meter
+
+### Cap Style
+Defines the endcap style of the buffer.
+CAP_ROUND - the usual round end caps
+CAP_SQUARE - end caps are squared off at the buffer distance beyond the line ends
+
+
+### Simplify Factor
+The default simplify factor provides an accuracy of about 1%, which matches the accuracy of the
+default Quadrant Segments parameter.
+
+### Quadrant Segments
+The default number of facets into which to divide a fillet of 90 degrees.
+
+***
+
+## Output
+A polygon geometry with EPSG code. Shape is defined by input parameters.
+
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/output.png" width="400px;" class="pe-image-documentation"/>
+</p>
+
+### Example
+
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg.md
new file mode 100644
index 0000000..294124c
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg.md
@@ -0,0 +1,64 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.epsg
+title: Geo EPSG Code
+sidebar_label: Geo EPSG Code
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+
+***
+
+## Description
+
+This processor adds an integer value to the event. This integer value represents
+an <a href="https://en.wikipedia.org/wiki/EPSG_Geodetic_Parameter_Dataset" target="_blank">EPSG Code</a> as an Spatial Reference System Identifier
+an <a href="https://en.wikipedia.org/wiki/Spatial_reference_system#Identifier" target="_blank">(SRID)</a>.
+
+
+***
+
+## Required inputs
+
+None
+
+***
+
+## Configuration
+
+Integer values, representing a spatial reference system
+<a href="https://en.wikipedia.org/wiki/Spatial_reference_system#Identifier" target="_blank">SRID</a>.
+Other possible values can be looked up via
+<a href="https://spatialreference.org/ref/epsg/" target="_blank">spatialreference.org</a>.
+
+### Parameter
+
+4- to 5-digit key integer number. Default value is 4326 representing the World Geodetic System
+<a href="https://en.wikipedia.org/wiki/World_Geodetic_System#WGS84" target="_blank">(WGS84)</a>.
+
+***
+## Output
+
+Adds the epsg number to the event.
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint.md
similarity index 84%
rename from docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint.md
index d113434..acc0192 100644
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo
-title: Creates JTS Point
-sidebar_label: Creates JTS Point
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint
+title: Geo Create JTS Point
+sidebar_label: Geo Create JTS Point
---
<!--
@@ -25,18 +25,18 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-This processor creates a JTS Point geometry from latitude and longitude value.
+This processor creates a JTS Point geometry from latitude and longitude value.
***
-## Required input
+## Required inputs
* Ontology Vocabulary Latitude
* Ontology Vocabulary Longitude
diff --git a/docs/pe/org.apache.streampipes.processors.textmining.flink.languagedetection.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection.md
similarity index 62%
rename from docs/pe/org.apache.streampipes.processors.textmining.flink.languagedetection.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection.md
index 4e2b543..99ea9b9 100644
--- a/docs/pe/org.apache.streampipes.processors.textmining.flink.languagedetection.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection.md
@@ -1,10 +1,10 @@
---
-id: org.apache.streampipes.processors.textmining.flink.languagedetection
-title: Language Detection
-sidebar_label: Language Detection
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection
+title: Geo CRS Reprojection
+sidebar_label: Geo CRS Reprojection
---
-<!--
+ <!--
~ 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.
@@ -24,30 +24,45 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.textmining.flink.languagedetection/icon.png" width="150px;" class="pe-image-documentation"/>
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Detects the language of a written text.
+Change of CRS due reprojection
***
## Required input
+* WKT String of a JTS Point Geometry
+* Integer value representing Source EPSG code
+* Integer value representing Target EPSG code
+
***
## Configuration
-Describe the configuration parameters here
+Manual Input of target EPSG Code and WKT will be reporjected.
### 1st parameter
-
+Geometry WKT String
### 2nd parameter
+Source EPSG code
+
+### 3rd parameter
+Target EPSG code
+
+***
## Output
+
+Update of event with new EPSG udn WKT-Literal in the dependent target epsg.
+
+### Example
+
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md
deleted file mode 100644
index bbb8f31..0000000
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG.md
+++ /dev/null
@@ -1,59 +0,0 @@
----
-id: org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG
-title: EPSG Code
-sidebar_label: EPSG Code
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-
-***
-
-## Description
-
-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
-
-None
-
-***
-
-## Configuration
-
-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/.
-
-### Parameter
-
-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
-
-Adds a number to the event.
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md
index 4402d47..ee602fe 100644
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory.md
@@ -1,7 +1,7 @@
---
id: org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory
-title: Single Trajectory Creator
-sidebar_label: Single Trajectory Creator
+title: Geo Single Trajectory Creator
+sidebar_label: Geo Single Trajectory Creator
---
<!--
@@ -35,7 +35,7 @@
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 consists of at least two sub-point and can't be infinitive, so a threshold of maximum allowed sub-points is required. When the sub-point threshold is exceeded, the oldest point is removed from the LineString.
***
-## Required input
+## Required inputs
* WKT String of a JTS Point Geometry
* Integer value representing EPSG code
@@ -74,7 +74,7 @@
Creating a LineString with a threshold of 2 allowed sub-points:
* First Event:
- * Point(8.12 41.23) --> LineString (empty)
+ * 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:
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex.md
new file mode 100644
index 0000000..9cd2db4
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex.md
@@ -0,0 +1,86 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex
+title: Geo Geometry Topology Validation Filter
+sidebar_label: Geo Geometry Topology Validation Filter
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+Validates geometry of topology
+<a href="https://locationtech.github.io/jts/javadoc/org/locationtech/jts/operation/valid/TopologyValidationError.html" target="_blank">erros from JTS</a>.
+
+* **HOLE_OUTSIDE_SHELL**: Indicates that a hole of a polygon lies partially or completely in the exterior of the shell
+* **NESTED_HOLES**: Indicates that a hole lies in the interior of another hole in the same polygon
+* **DISCONNECTED_INTERIOR**: Indicates that the interior of a polygon is disjoint (often caused by set of contiguous holes splitting the polygon into two parts)
+* **SELF_INTERSECTION**: Indicates that two rings of a polygonal geometry intersect
+* **RING_SELF_INTERSECTION**: Indicates that a ring self-intersects
+* **NESTED_SHELLS**: Indicates that a polygon component of a MultiPolygon lies inside another polygonal component
+* **DUPLICATE_RINGS**: Indicates that a polygonal geometry contains two rings which are identical
+* **TOO_FEW_POINTS**: Indicates that either a LineString contains a single point or a LinearRing contains 2 or 3 points
+* **RING_NOT_CLOSED**: Indicates that a ring is not correctly closed (the first and the last coordinate are different)
+
+
+***
+
+## Required inputs
+
+* JTS Geometry
+* EPSG Code
+* Validation Type
+* Log Output Option
+
+
+***
+
+## Configuration
+
+### Point Geometry Field
+Input Point Geometry
+
+### EPSG field
+Integer value representing EPSG code
+
+### Validation Output
+Chose the output result of the filter.
+* Valid - all valid events are parsed through
+* Invalid - all invalid events are parsed through
+
+
+### Log Output Option
+Options to activate Log-Output to the Pipeline Logger Window with detailed reason why Geometry is invalid
+
+
+***
+
+### Default Validation Checks
+
+## Output
+
+All events that match the validation output.
+
+### Example
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple.md
new file mode 100644
index 0000000..21c77b1
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple.md
@@ -0,0 +1,80 @@
+---
+id: org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple
+title: Geo Geometry Validation Filter
+sidebar_label: Geo Geometry Validation Filter
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+Checks the geometry event if the geometry is simple and / or empty.
+
+***
+
+## Required inputs
+
+* JTS Geometry
+* EPSG Code
+* Validation Type
+* Validation Output
+
+
+***
+
+## Configuration
+
+Validates geometry of different validations categories.
+
+
+### Point Geometry Field
+Input Point Geometry
+
+### EPSG field
+Integer value representing EPSG code
+
+### Validation Type
+* IsEmpty - Geometry is empty.
+* IsSimple - Geometry is simple. The SFS definition of simplicity follows the general rule that a Geometry is simple if it has no points of self-tangency, self-intersection or other anomalous points.
+ * Valid polygon geometries are simple, since their rings must not self-intersect.
+ * Linear rings have the same semantics.
+ * Linear geometries are simple if they do not self-intersect at points other than boundary points.
+ * Zero-dimensional geometries (points) are simple if they have no repeated points.
+ * Empty Geometries are always simple!
+
+### Validation Output
+Chose the output result of the filter.
+* Valid - all valid events are parsed through
+* Invalid - all invalid events are parsed through
+
+***
+
+## Output
+
+All events that match the validation output.
+
+### Example
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine.md
similarity index 79%
rename from docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine.md
index b5f7a0a..075dd23 100644
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.geo.jvm.processor.distancecalculator
-title: Distance Calculator
-sidebar_label: Distance Calculator
+id: org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine
+title: Geo Distance Calculator (Haversine)
+sidebar_label: Geo Distance Calculator (Haversine)
---
<!--
@@ -25,17 +25,18 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Calculates the distance between two latitude/longitude pairs in a single event.
+Calculates the distance between two latitude/longitude pairs in a single event with the
+<a href="https://en.wikipedia.org/wiki/Haversine_formula" target="_blank">Haversine formula</a>.
***
-## Required input
+## Required inputs
Requires a position of point on the Earth's surface specified by the two geographic coordinates: the longitude and latitude of the point.
***
@@ -57,4 +58,4 @@
## Output
{
'distance': 12.2
-}
+}
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic.md
similarity index 66%
rename from docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic.md
index 54421ce..0cd8b8c 100644
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.geo.jvm.processor.staticdistancecalculator
-title: Static Distance Calculator
-sidebar_label: Static Distance Calculator
+id: org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic
+title: Geo Distance Calculator Static (Haversine)
+sidebar_label: Geo Distance Calculator Static (Haversine)
---
<!--
@@ -24,16 +24,20 @@
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
***
## Description
-Calculates the distance (in km) between a fixed location (e.g., a place) and a latitude/longitude pair of an input
+Calculates the distance with the <a href="https://en.wikipedia.org/wiki/Haversine_formula" target="_blank">Haversine formula</a> between a fixed location (e.g., a place) and a latitude/longitude pair of an input
event.
***
-## Required input
+## Required inputs
Requires a data stream that provides latitude and longitude values.
diff --git a/docs/pe/org.apache.streampipes.processor.geo.jvm.geocoding.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps.md
similarity index 77%
rename from docs/pe/org.apache.streampipes.processor.geo.jvm.geocoding.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps.md
index 3537492..ce310f5 100644
--- a/docs/pe/org.apache.streampipes.processor.geo.jvm.geocoding.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps.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.latlong.processor.geocoder.googlemaps
+title: Geo Google Maps Geocoder
+sidebar_label: Geo Google Maps Geocoder
---
<!--
@@ -24,7 +24,8 @@
-<p align="center">
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -36,7 +37,7 @@
***
-## Required input
+## Required inputs
Input event requires to have a field which contains the name of a place.
diff --git a/docs/pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic.md
similarity index 76%
rename from docs/pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic.md
index 2fc27e2..6f5a443 100644
--- a/docs/pe/org.apache.streampipes.processor.geo.jvm.staticgeocoding.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.jvm.staticgeocoding
-title: Static Google Maps Geocoder
-sidebar_label: Static Google Maps Geocoder
+id: org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic
+title: Geo Google Maps Static Geocoder
+sidebar_label: Geo Google Maps Static Geocoder
---
<!--
@@ -24,7 +24,8 @@
-<p align="center">
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -37,7 +38,7 @@
***
-## Required input
+## Required inputs
Input event requires to have a field which contains the name of a place.
diff --git a/docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname.md
similarity index 61%
rename from docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname.md
index a0d0edd..8375bb7 100644
--- a/docs/pe/org.apache.streampipes.processor.geo.jvm.reversegeocoding.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processor.geo.jvm.reversegeocoding
-title: Reverse Geocoder
-sidebar_label: Reverse Geocoder
+id: org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname
+title: Geo City Name Reverse Decoder
+sidebar_label: Geo City Name Reverse Decoder
---
<!--
@@ -24,20 +24,23 @@
-<p align="center">
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-This processor computes place name based on given lat/lng coordinates that are transmitted as fields from an event.
+This processor computes city name based on given lat/lng coordinates that are transmitted as fields from an event.
+This processor automatically downloads the file cities1000.zip from <a href="http://download.geonames.org/export/dump/cities1000.zip)" target="_blank">Geonames</a>
+ ( This file is provided under the <a href="https://creativecommons.org/licenses/by/4.0/)" target="_blank">CC BY 4.0 license</a>).
-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
+## Required inputs
Input event requires to have latitude and longitude values.
@@ -59,6 +62,6 @@
```
{
- 'place': 'Colombo'
+ 'geoname': 'Colombo'
}
```
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator.md
similarity index 70%
rename from docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md
rename to docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator.md
index 938a054..543f26c 100644
--- a/docs/pe/org.apache.streampipes.processors.geo.jvm.processor.speed.md
+++ b/docs/pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.geo.jvm.processor.speed
-title: Speed Calculator
-sidebar_label: Speed Calculator
+id: org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator
+title: Geo Speed Calculator
+sidebar_label: Geo Speed Calculator
---
<!--
@@ -24,16 +24,20 @@
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
***
## Description
-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.
+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
+## Required inputs
Requires a data stream that provides latitude and longitude values as well as a timestamp.
@@ -49,7 +53,7 @@
### 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.
+E.g. a value of 5 means that the current event and the event (t-5) are used for the speed calculation.
## Output
Appends the calculated speed in km/h.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md b/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md
deleted file mode 100644
index 13aa2c2..0000000
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.absence.md
+++ /dev/null
@@ -1,53 +0,0 @@
----
-id: org.apache.streampipes.processors.pattern-detection.flink.absence
-title: Absence
-sidebar_label: Absence
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.absence/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Detects whether an event does not arrive within a specified time after the occurrence of another event.
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md b/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md
deleted file mode 100644
index a1b637f..0000000
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.and.md
+++ /dev/null
@@ -1,53 +0,0 @@
----
-id: org.apache.streampipes.processors.pattern-detection.flink.and
-title: And
-sidebar_label: And
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Detects whether an event co-occurs with another event within a given time.
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md b/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md
deleted file mode 100644
index e235199..0000000
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.sequence.md
+++ /dev/null
@@ -1,53 +0,0 @@
----
-id: org.apache.streampipes.processors.pattern-detection.flink.sequence
-title: Sequence
-sidebar_label: Sequence
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-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).
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
diff --git a/docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md b/docs/pe/org.apache.streampipes.processors.siddhi.count.md
similarity index 83%
rename from docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md
rename to docs/pe/org.apache.streampipes.processors.siddhi.count.md
index a056cea..c2f593f 100644
--- a/docs/pe/org.apache.streampipes.processors.aggregation.flink.count.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.count.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.aggregation.flink.count
-title: Count Aggregation
-sidebar_label: Count Aggregation
+id: org.apache.streampipes.processors.siddhi.count
+title: Count Value Occurrence
+sidebar_label: Count Value Occurrence
---
<!--
@@ -24,9 +24,7 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.aggregation.flink.count/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
+Performs count aggregation with Siddhi CEP engine.
***
@@ -40,11 +38,13 @@
***
## Required input
-There is no specific input required.
+
+Does not have any specific input requirements.
***
## Configuration
+
### FieldToCount
Specifies the field containing the values that should be counted.
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.frequency.md b/docs/pe/org.apache.streampipes.processors.siddhi.frequency.md
deleted file mode 100644
index 36f0b54..0000000
--- a/docs/pe/org.apache.streampipes.processors.siddhi.frequency.md
+++ /dev/null
@@ -1,55 +0,0 @@
----
-id: org.apache.streampipes.processors.siddhi.frequency
-title: Frequency Calculation
-sidebar_label: Frequency Calculation
----
-
-<!--
- ~ 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.
- ~
- -->
-
-
-
-Frequency calculation with Siddhi CEP engine.
-
-***
-
-## Description
-
-Calculates the frequency of the event stream.
-
-***
-
-## Required input
-
-Does not have any specific input requirements.
-
-***
-
-## Configuration
-
-### Time Unit
-
-The time unit of the window. e.g, hrs, min and sec
-
-### Time window length
-
-The time duration of the window in seconds.
-
-## Output
-
-Outputs the events according to the frequency specified.
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.frequencychange.md b/docs/pe/org.apache.streampipes.processors.siddhi.frequencychange.md
deleted file mode 100644
index 257eac3..0000000
--- a/docs/pe/org.apache.streampipes.processors.siddhi.frequencychange.md
+++ /dev/null
@@ -1,58 +0,0 @@
----
-id: org.apache.streampipes.processors.siddhi.frequencychange
-title: Frequency Change
-sidebar_label: Frequency Change
----
-
-<!--
- ~ 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.
- ~
- -->
-
-
-Notifies if there is a frequency change in events.
-
-***
-
-## Description
-
-Detects when the frequency of the event stream changes.
-
-***
-
-## Required input
-
-Does not have any specific input requirements.
-
-***
-
-## Configuration
-
-### Time Unit
-
-The time unit of the window. e.g, hrs, min and sec
-
-### Percentage of Increase/Decrease
-
-Specifies the increase in percent (e.g., 100 indicates an increase by 100 percent within the specified time window).
-
-### Time window length
-
-The time duration of the window in seconds.
-
-## Output
-
-Outputs event if there is a frequency change according to the provided configuration.
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.increase.md b/docs/pe/org.apache.streampipes.processors.siddhi.increase.md
index 0f58b56..200a7f8 100644
--- a/docs/pe/org.apache.streampipes.processors.siddhi.increase.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.increase.md
@@ -62,4 +62,4 @@
## Output
-Outputs the events if there is a trend observed according to the configuration defined.
+Outputs the events if there is a trend observed according to the configuration defined.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.stop.md b/docs/pe/org.apache.streampipes.processors.siddhi.listcollector.md
similarity index 71%
rename from docs/pe/org.apache.streampipes.processors.siddhi.stop.md
rename to docs/pe/org.apache.streampipes.processors.siddhi.listcollector.md
index 27ed245..f789c1c 100644
--- a/docs/pe/org.apache.streampipes.processors.siddhi.stop.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.listcollector.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.siddhi.stop
-title: Stream Stop Detection
-sidebar_label: Stream Stop Detection
+id: org.apache.streampipes.processors.siddhi.listcollector
+title: List Collector
+sidebar_label: List Collector
---
<!--
@@ -28,7 +28,7 @@
## Description
-Triggers an event when the input data stream stops sending events
+Collects all values from a field within a specified batch window into a list.
***
@@ -40,17 +40,12 @@
## Configuration
-### Time Window Length (Seconds)
+### Field
-Specifies the size of the time window in seconds.
+The field where values should be collected into a list.
-## Output
+### Batch Window Size
-Outputs a similar event like below.
+The batch window size.
-```
-{
- 'timestamp': 1621243855401,
- 'message': 'Event stream has stopped'
-}
-```
\ No newline at end of file
+## Output
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md b/docs/pe/org.apache.streampipes.processors.siddhi.listfilter.md
similarity index 76%
copy from docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
copy to docs/pe/org.apache.streampipes.processors.siddhi.listfilter.md
index 1485fd0..2526408 100644
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.listfilter.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.pattern-detection.flink.peak-detection
-title: Peak Detection
-sidebar_label: Peak Detection
+id: org.apache.streampipes.processors.siddhi.listfilter
+title: List Filter
+sidebar_label: List Filter
---
<!--
@@ -25,14 +25,14 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listfilter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Detect peaks in time series data.
+Detects the increase of a numerical field over a customizable time window. Example: A temperature value increases by 10 percent within 5 minutes.
***
@@ -50,4 +50,4 @@
### 2nd parameter
-## Output
+## Output
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md b/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md
index ad69acf..fb20b10 100644
--- a/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.numericalfilter.md
@@ -60,4 +60,4 @@
Specifies the threshold value.
## Output
-The processor outputs the input event if it satisfies the filter expression.
+The processor outputs the input event if it satisfies the filter expression.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md b/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md
deleted file mode 100644
index ab8882e..0000000
--- a/docs/pe/org.apache.streampipes.processors.siddhi.sequence.md
+++ /dev/null
@@ -1,35 +0,0 @@
----
-id: org.apache.streampipes.processors.siddhi.sequence
-title: Sequence Detection
-sidebar_label: Sequence Detection
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.siddhi.sequence/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Merges events from two event streams, when the top event arrives first and then the bottom event
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md b/docs/pe/org.apache.streampipes.processors.siddhi.topk.md
similarity index 77%
rename from docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
rename to docs/pe/org.apache.streampipes.processors.siddhi.topk.md
index 1485fd0..beb0d88 100644
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
+++ b/docs/pe/org.apache.streampipes.processors.siddhi.topk.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.pattern-detection.flink.peak-detection
-title: Peak Detection
-sidebar_label: Peak Detection
+id: org.apache.streampipes.processors.siddhi.topk
+title: Top k
+sidebar_label: Top k
---
<!--
@@ -25,14 +25,14 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.siddhi.topk/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-Detect peaks in time series data.
+Detects the increase of a numerical field over a customizable time window. Example: A temperature value increases by 10 percent within 5 minutes.
***
@@ -50,4 +50,4 @@
### 2nd parameter
-## Output
+## Output
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md b/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md
deleted file mode 100644
index 8112c58..0000000
--- a/docs/pe/org.apache.streampipes.processors.statistics.flink.statistics-summary.md
+++ /dev/null
@@ -1,43 +0,0 @@
----
-id: org.apache.streampipes.processors.statistics.flink.statistics-summary
-title: Statistics Summary
-sidebar_label: Statistics Summary
----
-
-<!--
- ~ 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="/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.
-
-The statistics contain:
-* Minimum
-* Maximum
-* Sum
-* Standard Deviation
-* Variance
-
diff --git a/docs/pe/org.apache.streampipes.processors.textmining.flink.wordcount.md b/docs/pe/org.apache.streampipes.processors.textmining.flink.wordcount.md
deleted file mode 100644
index afdd9a1..0000000
--- a/docs/pe/org.apache.streampipes.processors.textmining.flink.wordcount.md
+++ /dev/null
@@ -1,53 +0,0 @@
----
-id: org.apache.streampipes.processors.textmining.flink.wordcount
-title: Word Count
-sidebar_label: Word Count
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.textmining.flink.wordcount/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Count words on continuous text-based streams.
-
-***
-
-## Required input
-
-
-***
-
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
-## Output
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md b/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md
deleted file mode 100644
index ab91e6d..0000000
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.processor.boilerplate.md
+++ /dev/null
@@ -1,49 +0,0 @@
----
-id: org.apache.streampipes.processors.transformation.flink.processor.boilerplate
-title: Boilerplate Removal
-sidebar_label: Boilerplate Removal
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Removes boilerplate tags from HTML and extracts fulltext
-
-***
-
-## Required input
-Requires a Text field containing the HTML
-
-***
-
-## Configuration
-
-Select the extractor type and output mode
-
-## Output
-Appends a new text field containing the content of the html page without the boilerplate
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md
index bc500a7..9964916 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.counter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,7 +32,7 @@
## Description
-This processor monitors a boolean value and counts how often the value of the boolean changes.
+This processor monitors a boolean value and counts how often the value of the boolean changes.
A user can configure whether the changes from FALSE to TRUE, TRUE to FALSE, or BOTH changes should be counted.
***
@@ -49,16 +49,18 @@
## Configuration
-A user can configure whether the changes from TRUE to FALSE, FALSE to TRUE, or all changes of the boolean value should be counted.
+A user can configure whether the changes from TRUE to FALSE, FALSE to TRUE, or all changes of the
+boolean value should be counted.
### Flank parameter
Either:
-* TRUE -> FALSE: Increase counter on a true followed by a false
+* TRUE -> FALSE: Increase counter on a true followed by a false
* FALSE -> TRUE: Increase counter on a false followed by a true
* BOTH: Increase counter on each change of the boolean value on two consecutive events
## Output
-Adds an additional numerical field with the current count value to the event. Events are just emitted when the counter changes.
-Runtime Name: countField
+Adds an additional numerical field with the current count value to the event.
+Events are just emitted when the counter changes.
+Runtime Name: countField
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md
index 7f3111f..07ccaf2 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -48,4 +48,4 @@
No further configuration required
## Output
-The output schema is the same as the input schema. Just the value of the property is changed.
+The output schema is the same as the input schema. Just the value of the property is changed.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.logical.md
similarity index 63%
copy from docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
copy to docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.logical.md
index 1485fd0..9cf0d92 100644
--- a/docs/pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.logical.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.processors.pattern-detection.flink.peak-detection
-title: Peak Detection
-sidebar_label: Peak Detection
+id: org.apache.streampipes.processors.transformation.jvm.booloperator.logical
+title: Boolean Logical Operator
+sidebar_label: Boolean Logical Operator
---
<!--
@@ -24,30 +24,19 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
## Description
-Detect peaks in time series data.
+This processor performs the logical boolean operation b/w the vales of set of properties.
+A user can select the type of operation and set of properties.
***
## Required input
+Type of logical boolean operator and set of properties on which operator needs to perform.
***
-## Configuration
-
-Describe the configuration parameters here
-
-### 1st parameter
-
-
-### 2nd parameter
-
## Output
+
+Outputs the incoming event while appending the result (``boolean-operations-result``) to the incoming event.
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md
index 2cc4909..ff35360 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -34,13 +34,13 @@
This processor can be used to measure the time between two boolean sensors.
For example on a conveyor, where one sensor is placed on the left and one senor placed on the right.
-Parts are transported on the conveyor and the sensors are boolean sensors detecting those parts.
-The time is measured between the two sensors as well as the amount of complete transportation's is counted.
+Parts are transported on the conveyor and the sensors are boolean sensors detecting those parts.
+The time is measured between the two sensors as well as the amount of complete transportation's is counted.
The measurement is initialized once the left sensor is true and stopped once the right sensor is true.
There can also be multiple parts on the conveyor as long as the individual parts do not change.
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/time_measure_example.png" width="300px;" class="pe-image-documentation"/>
</p>
@@ -67,4 +67,4 @@
The timer field is a numeric value representing the time between the two sensors. Runtime name: measured_time
### Counter
-The counter indicated how many events where emitted by this component. Runtime name: counter
+The counter indicated how many events where emitted by this component. Runtime name: counter
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md
index c52db41..0448104 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timer/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,7 +32,8 @@
## Description
-This processor measures how long a boolean value does not change. Once the value is changes the event with the measured time is emitted.
+This processor measures how long a boolean value does not change.
+Once the value is changes the event with the measured time is emitted.
***
@@ -53,4 +54,5 @@
Define whether it should be measured how long the value is true or how long the value is false.
## Output
-Appends a field with the time how long the value did not change. Is emitted on the change of the boolean value. Runtime name: measured_time
+Appends a field with the time how long the value did not change.
+Is emitted on the change of the boolean value. Runtime name: measured_time
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
index 822a64f..9b5f1ac 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.changed-value.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.changed-value/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,7 +32,8 @@
## Description
-This processor sends out an event everytime a specific object changes. It also adds a timestamp in ms from the system time.
+This processor sends out an event everytime a specific object changes.
+It also adds a timestamp in ms from the system time.
***
@@ -42,4 +43,4 @@
Describe the configuration parameters here
## Output
-Emit an event on change and append a timestamp when the change occured
+Emit an event on change and append a timestamp when the change occured
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md
index a38df7f..b32bb78 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.count-array.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.count-array/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -52,4 +52,4 @@
## Output
-Outputs the incoming event while appending the list size (named ``countValue``) to the incoming event.
+Outputs the incoming event while appending the list size (named ``countValue``) to the incoming event.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md
index 5dc226a..9c4871a 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.csvmetadata.md
@@ -35,7 +35,8 @@
### 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.
+Once the file is uploaded the user can select which column to use for the matching property
+and which values should be appended.
Delimiter: ';'
@@ -47,7 +48,7 @@
### Input event
```
{
- 'line_id': 'line1',
+ 'line_id': 'line1',
'timestamp': 1586378041
}
```
@@ -66,11 +67,11 @@
* Field to match (Example: production_line)
* Fields to append (Example: location)
-### Output event
+### Output event
```
{
- 'line_id': 'line1',
- 'timestamp': 1586378041,
+ 'line_id': 'line1',
+ 'timestamp': 1586378041,
'location': 'germany'
}
```
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
index f02fd12..0d1a66b 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.duration-value.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.duration-value/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -48,4 +48,4 @@
* Time Unit of the result
## Output
-Appends a new field with the difference of t2 and t1
+Appends a new field with the difference of t2 and t1
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.field-mapper.md
similarity index 87%
rename from docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md
rename to docs/pe/org.apache.streampipes.processors.transformation.jvm.field-mapper.md
index 4140a1f..b903eb2 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-mapper.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.field-mapper.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.transformation.flink.field-mapper
+id: org.apache.streampipes.processors.transformation.jvm.field-mapper
title: Field Mapper
sidebar_label: Field Mapper
---
@@ -24,8 +24,8 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png" width="150px;" class="pe-image-documentation"/>
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.field-mapper/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -44,8 +44,11 @@
***
## Example
+
Merge two fields into a hash value
+
### Input event
+
```
{
"timestamp":1586380104915,
@@ -56,14 +59,16 @@
```
### Configuration
+
* Fields: mass_flow, temperature
* Name of new field: demo
-### Output event
+### Output event
+
```
{
"timestamp":1586380104915,
"sensorId":"flowrate01"
"demo":"8ae11f5c83610104408d485b73120832",
}
-```
+```
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldhasher.md
similarity index 84%
rename from docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md
rename to docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldhasher.md
index 5fbb42f..b4b0d69 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.fieldhasher.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldhasher.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.transformation.flink.fieldhasher
+id: org.apache.streampipes.processors.transformation.jvm.fieldhasher
title: Field Hasher
sidebar_label: Field Hasher
---
@@ -24,15 +24,16 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.fieldhasher/icon.png" width="150px;" class="pe-image-documentation"/>
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldhasher/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.
+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.
***
@@ -51,4 +52,4 @@
are available: SHA2, MD5 or SHA1.
## Output
-The encoded string field.
+The encoded string field.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-renamer.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldrename.md
similarity index 69%
rename from docs/pe/org.apache.streampipes.processors.transformation.flink.field-renamer.md
rename to docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldrename.md
index 94a1463..8d8e463 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.field-renamer.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.fieldrename.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.transformation.flink.field-renamer
+id: org.apache.streampipes.processors.transformation.jvm.fieldrename
title: Field Renamer
sidebar_label: Field Renamer
---
@@ -24,27 +24,18 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.field-renamer/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
***
## Description
-Replaces the runtime name of an event property with a custom defined name. Useful for data ingestion purposes where a specific event schema is required.
+Replaces the runtime name of an event property with a custom defined name.
+Useful for data ingestion purposes where a specific event schema is required.
***
-## Required input
-There is no specific input required.
-
-***
-
-## Configuration
-
-### Field
+### OldFieldName
Specifies the field to rename.
### NewFieldName
@@ -56,13 +47,13 @@
Old Output:
```
{
- 'timestamp': 16003000,
+ 'timestamp': 16003000,
}
```
New Ouput:
```
{
- 'time': 16003000,
+ 'time': 16003000,
}
-```
+```
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter.md
similarity index 84%
rename from docs/pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter.md
rename to docs/pe/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter.md
index 3ab6cd6..303309c 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter.md
@@ -1,5 +1,5 @@
---
-id: org.apache.streampipes.processors.transformation.flink.measurement-unit-converter
+id: org.apache.streampipes.processors.transformation.jvm.measurementunitconverter
title: Measurement Unit Converter
sidebar_label: Measurement Unit Converter
---
@@ -24,8 +24,8 @@
-<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.flink.measurement-unit-converter/icon.png" width="150px;" class="pe-image-documentation"/>
+<p align="center">
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -50,4 +50,4 @@
### 2nd parameter
-## Output
+## Output
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge.md
index 7f42384..09c0a44 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -45,13 +45,14 @@
## Configuration
### Kind of edge
-* Detect rising edges
-* Detect falling edges
+* Detect rising edges
+* Detect falling edges
* Detect both
-
+
### Delay
Defines for how many events the signal must be stable before result is emitted.
-(E.g. if set to 2, the result is not emitted if value toggles between true and false, it fires when two consecutive events are detected after the flank)
+(E.g. if set to 2, the result is not emitted if value toggles between true and false,
+it fires when two consecutive events are detected after the flank)
## Output
Emits input event, when the signal edge is detected
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state.md
index 0274b73..7eb96ae 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -40,19 +40,24 @@
## Required input
### Boolean Fields
+
Boolean fields that are converted to the state when true
### Default State
-When all boolean values are false, a default state can be defined
+
+When all boolean values are false, a default state can be defined
### Mapping Configuration
+
Configuration to provide a string mapping for each possible value.
On the left ist the value of the runtime name and on the right the new value (e.g. {"runtimeName": "newValue"}).
***
## Configuration
+
No further configuration required
## Output
+
The output contains a new value with the string values of the state
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer.md
deleted file mode 100644
index d694260..0000000
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer.md
+++ /dev/null
@@ -1,54 +0,0 @@
----
-id: org.apache.streampipes.processors.transformation.jvm.processor.state.buffer
-title: State Buffer
-sidebar_label: State Buffer
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Buffers values of a sensor, while state does not change.
-Select a state field in the event. Events are buffered as long as state field does not change. When it changes result event is emitted.
-
-***
-
-## Required input
-
-Define the state and sensor value field
-
-### Timestamp
-A mapping property for a timestamp field
-
-### State
-Select the field representing the state
-
-### Sensor value to cache
-Select the field with the numerical values to buffer
-
-## Output
-Emits a new event on state change, with the fields `timestamp`, `state`, and a list containing all `sensor values`.
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer.md
deleted file mode 100644
index b7557f6..0000000
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer.md
+++ /dev/null
@@ -1,69 +0,0 @@
----
-id: org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer
-title: State Buffer Labeler
-sidebar_label: State Buffer Labeler
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Apply a rule to a time-series recorded during a state of a machine. (E.g. when minimum value is lower then 10, add label `not ok` else add label `ok`)
-
-
-***
-
-## Required input
-
-Requires a list with sensor values and a field defining the state
-
-### Sensor values
-
-An array representing sensor values recorded during the state.
-
-### State field
-
-A field representing the state when the sensor values where recorded.
-
-***
-
-## Configuration
-
-### Select a specific state
-When you are interested in the values of a specific state add it here. All other states will be ignored. To get results of all states enter `*`
-
-### Operation
-Operation that will be performed on the sensor values (calculate `maximim`, or `average`, or `minimum`)
-
-### Condition
-Define a rule which label to add. Example: `<;5;nok` means when the calculated value is smaller then 5 add label ok.
-The default label can be defined with `*;nok`.
-The first rule that is true defines the label. Rules are applied in the same order as defined here.
-
-
-## Output
-Appends a new field with the label defined in the Condition Configuration
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number.md
index ff6aaee..021bee3 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state.md
index 52f5782..02fbfa2 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md
index 5219efb..6aa99cf 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -55,4 +55,4 @@
## Output
-The output of this processor is a new event that contains the fields selected by the ``Extract Fields`` parameter.
+The output of this processor is a new event that contains the fields selected by the ``Extract Fields`` parameter.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.round.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.round.md
index 9a183e8..3913f9f 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.round.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.round.md
@@ -22,10 +22,10 @@
~
-->
-## Number Rounder
+
<p align="center">
- <img src="icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.round/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
@@ -56,7 +56,7 @@
### Mode of Rounding
-Specify the mode of rounding.
+Specify the mode of rounding.
Supported rounding modes:
* `UP`: Rounding mode to round away from zero. Always increments the digit prior to a non-zero discarded fraction. Note that this rounding mode never decreases the magnitude of the calculated value.
* `DOWN`: Rounding mode to round towards zero. Never increments the digit prior to a discarded fraction (i.e., truncates). Note that this rounding mode never increases the magnitude of the calculated value.
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md
index 5b0332a..47e0b6d 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.split-array.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.split-array/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,7 +32,8 @@
## Description
-This processor takes an array of event properties and creates an event for each of them. Further property of the events can be added to each element.
+This processor takes an array of event properties and creates an event for each of them.
+Further property of the events can be added to each element.
***
@@ -56,4 +57,4 @@
## Output
This data processor produces an event with all fields selected by the ``Keep Fields`` parameter and all fields of the
- selected list field.
+ selected list field.
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
index b1e7b1c..2b5b1a7 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,8 +32,10 @@
## Description
-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.
+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.
***
@@ -52,10 +54,12 @@
(no further configuration required)
## Output
+
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
+* [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/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
index 8a5f6eb..6ce9c78 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -32,7 +32,8 @@
## Description
-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.
+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.
***
@@ -50,14 +51,16 @@
## Configuration
-### Output Frequency
+### Output Frequency
Define when an event should be emitted, either on each input event or just when the string value changes.
## Output
+
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
+* [field_value] the corresponding string value
The event is emitted whenever the value of the string field changes.
diff --git a/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md b/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
index 8dccc9e..8195cb3 100644
--- a/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
+++ b/docs/pe/org.apache.streampipes.processors.transformation.jvm.transform-to-boolean.md
@@ -24,19 +24,21 @@
-<p align="center">
+<p align="center">
<img src="/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.
***
## Required input
+
A string with the values "true", "True", "false", "False" or a number with value 1.0, 1, 0, or 0.0
***
@@ -46,5 +48,6 @@
Select fields that should be converted to boolean.
## Output
+
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.
+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/docs/pe/org.apache.streampipes.protocol.set.file.md b/docs/pe/org.apache.streampipes.protocol.set.file.md
deleted file mode 100644
index c080245..0000000
--- a/docs/pe/org.apache.streampipes.protocol.set.file.md
+++ /dev/null
@@ -1,38 +0,0 @@
----
-id: org.apache.streampipes.protocol.set.file
-title: File Set
-sidebar_label: File Set
----
-
-<!--
- ~ 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="/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.
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.protocol.set.http.md b/docs/pe/org.apache.streampipes.protocol.set.http.md
deleted file mode 100644
index 9630542..0000000
--- a/docs/pe/org.apache.streampipes.protocol.set.http.md
+++ /dev/null
@@ -1,38 +0,0 @@
----
-id: org.apache.streampipes.protocol.set.http
-title: HTTP Set
-sidebar_label: HTTP Set
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.protocol.set.http/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Regularly poll an HTTP endpoint
-
-***
-
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md
index 26097b6..d1ddcf1 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest.md
@@ -55,4 +55,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md
index 8fdef11..9116688 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.jms.md
@@ -57,4 +57,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md
index a2bd06f..3fa00b5 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.kafka.md
@@ -58,4 +58,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
similarity index 70%
copy from docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
copy to docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
index b00baca..962082c 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.mqtt.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.internal.jvm.dashboard
-title: Dashboard Sink
-sidebar_label: Dashboard Sink
+id: org.apache.streampipes.sinks.brokers.jvm.mqtt
+title: MQTT Publisher
+sidebar_label: MQTT Publisher
---
<!--
@@ -25,15 +25,14 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.sinks.internal.jvm.dashboard/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-This sink visualizes data streams in the StreamPipes dashboard.
-Visualizations can be configured in Live Dashboard of StreamPipes after the pipeline has been started.
+Publishes events to MQTT.
***
@@ -45,8 +44,18 @@
## Configuration
-No further configuration necessary, individual visualizations can be configured in the Dashboard itself.
+### MQTT Broker Settings
+
+The basic settings to connect to the broker.
+The MQTT broker URL indicates the URL of the broker (e.g., localhost), the port indicates the port of the broker
+(e.g., 1883)
+
+
+### MQTT Topic
+
+The topic where events should be sent to.
+
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.nats.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.nats.md
index 983661d..7f1c932 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.nats.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.nats.md
@@ -75,4 +75,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md
index 85c532d..ea444d5 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.pulsar.md
@@ -60,4 +60,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md
index fd9bf64..0da1aa8 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq.md
@@ -24,7 +24,7 @@
-<p align="center">
+<p align="center">
<img src="/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.rabbitmq/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
@@ -70,4 +70,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md
index 4415c04..71d7923 100644
--- a/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rest.md
@@ -49,4 +49,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rocketmq.md
similarity index 70%
rename from docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
rename to docs/pe/org.apache.streampipes.sinks.brokers.jvm.rocketmq.md
index b00baca..a3e0e27 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.rocketmq.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.internal.jvm.dashboard
-title: Dashboard Sink
-sidebar_label: Dashboard Sink
+id: org.apache.streampipes.sinks.brokers.jvm.rocketmq
+title: RocketMQ Publisher
+sidebar_label: RocketMQ Publisher
---
<!--
@@ -25,15 +25,14 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.sinks.internal.jvm.dashboard/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-This sink visualizes data streams in the StreamPipes dashboard.
-Visualizations can be configured in Live Dashboard of StreamPipes after the pipeline has been started.
+Publishes events to Apache RocketMQ.
***
@@ -45,8 +44,16 @@
## Configuration
-No further configuration necessary, individual visualizations can be configured in the Dashboard itself.
+### RocketMQ Endpoint
+
+The endpoint to connect to the broker.
+
+
+### RocketMQ Topic
+
+The topic where events should be sent to.
+
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.tubemq.md
similarity index 69%
copy from docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
copy to docs/pe/org.apache.streampipes.sinks.brokers.jvm.tubemq.md
index b00baca..34dc022 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.tubemq.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.internal.jvm.dashboard
-title: Dashboard Sink
-sidebar_label: Dashboard Sink
+id: org.apache.streampipes.sinks.brokers.jvm.tubemq
+title: TubeMQ (InLong) Publisher
+sidebar_label: TubeMQ (InLong) Publisher
---
<!--
@@ -25,19 +25,18 @@
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.sinks.internal.jvm.dashboard/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png" width="150px;" class="pe-image-documentation"/>
</p>
***
## Description
-This sink visualizes data streams in the StreamPipes dashboard.
-Visualizations can be configured in Live Dashboard of StreamPipes after the pipeline has been started.
+Publishes events to Apache TubeMQ (InLong).
***
-## Required input
+## Required Inputs
This sink does not have any requirements and works with any incoming event type.
@@ -45,7 +44,17 @@
## Configuration
-No further configuration necessary, individual visualizations can be configured in the Dashboard itself.
+### TubeMQ Master Information
+
+This field describes the endpoints of all the TubeMQ masters.
+
+The format should be like `ip1:port1,ip2:port2,ip3:port3`.
+
+
+### TubeMQ Topic
+
+The topic where events should be sent to.
+
## Output
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.websocket.md
similarity index 70%
copy from docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
copy to docs/pe/org.apache.streampipes.sinks.brokers.jvm.websocket.md
index b00baca..8070652 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.dashboard.md
+++ b/docs/pe/org.apache.streampipes.sinks.brokers.jvm.websocket.md
@@ -1,7 +1,7 @@
---
-id: org.apache.streampipes.sinks.internal.jvm.dashboard
-title: Dashboard Sink
-sidebar_label: Dashboard Sink
+id: org.apache.streampipes.sinks.brokers.jvm.websocket
+title: Websocket Server
+sidebar_label: Websocket Server
---
<!--
@@ -23,17 +23,15 @@
-->
+***
<p align="center">
- <img src="/img/pipeline-elements/org.apache.streampipes.sinks.internal.jvm.dashboard/icon.png" width="150px;" class="pe-image-documentation"/>
+ <img src="/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.websocket/icon.png" width="266" class="pe-image-documentation"/>
</p>
-***
-
## Description
-This sink visualizes data streams in the StreamPipes dashboard.
-Visualizations can be configured in Live Dashboard of StreamPipes after the pipeline has been started.
+Send a message to a connected websocket client
***
@@ -45,7 +43,9 @@
## Configuration
-No further configuration necessary, individual visualizations can be configured in the Dashboard itself.
+### Port
+
+The port on which the websocket listens for connections
## Output
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.ditto.md b/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
index 3b9857e..0726af1 100644
--- a/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
+++ b/docs/pe/org.apache.streampipes.sinks.databases.ditto.md
@@ -70,4 +70,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.flink.elasticsearch.md b/docs/pe/org.apache.streampipes.sinks.databases.flink.elasticsearch.md
deleted file mode 100644
index 2ce7486..0000000
--- a/docs/pe/org.apache.streampipes.sinks.databases.flink.elasticsearch.md
+++ /dev/null
@@ -1,60 +0,0 @@
----
-id: org.apache.streampipes.sinks.databases.flink.elasticsearch
-title: Elasticsearch
-sidebar_label: Elasticsearch
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.sinks.databases.flink.elasticsearch/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Stores data in an Elasticsearch database.
-
-***
-
-## 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``.
-
-***
-
-## 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.
-
-## Output
-
-(not applicable for data sinks)
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md b/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md
index 071fad6..eb84223 100644
--- a/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md
+++ b/docs/pe/org.apache.streampipes.sinks.databases.jvm.couchdb.md
@@ -60,4 +60,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md b/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md
index a14eb9f..7771262 100644
--- a/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md
+++ b/docs/pe/org.apache.streampipes.sinks.databases.jvm.iotdb.md
@@ -1,7 +1,7 @@
---
id: org.apache.streampipes.sinks.databases.jvm.iotdb
-title: IoTDB
-sidebar_label: IoTDB
+title: Apache IoTDB
+sidebar_label: Apache IoTDB
---
<!--
@@ -34,6 +34,10 @@
Stores events in a IoTDB database.
+Events will be stored in timeseries `root.${Database Name}.${Device (Entity) Name}.${Event Key}`.
+
+Please reference to [https://iotdb.apache.org/](https://iotdb.apache.org/) for more information.
+
***
## Required input
@@ -52,11 +56,6 @@
The port of the IoTDB instance (default 6667).
-### Storage Group Name
-
-The name of the storage group where events will be stored (will be created if it does not exist).
-For each element of the stream a new time series will be created.
-
### Username
The username for the IoTDB Server.
@@ -65,6 +64,28 @@
The password for the IoTDB Server.
+### **Database Name**
+
+The name of the database where events will be stored (will be created if it does not exist).
+
+A database is a group of devices (entities). Users can create any prefix path as a database.
+
+### **Device (Entity) Name**
+
+The name of the device (entity) where events will be stored.
+
+A device (also called entity) is an equipped with measurements in real scenarios. In IoTDB, all measurements should have
+their corresponding devices.
+
+### **Measurements**
+
+All keys of fields in an event will be automatically converted to suffixes of timeseries.
+
+A measurement is information measured by detection equipment in an actual scene and can transform the sensed information
+into an electrical signal or other desired form of information output and send it to IoTDB.
+
+In IoTDB, all data and paths stored are organized in units of measurements.
+
## Output
(not applicable for data sinks)
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.jvm.mysql.md b/docs/pe/org.apache.streampipes.sinks.databases.jvm.mysql.md
deleted file mode 100644
index 9cff5c3..0000000
--- a/docs/pe/org.apache.streampipes.sinks.databases.jvm.mysql.md
+++ /dev/null
@@ -1,74 +0,0 @@
----
-id: org.apache.streampipes.sinks.databases.jvm.mysql
-title: MySQL Database
-sidebar_label: MySQL Database
----
-
-<!--
- ~ 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="/img/pipeline-elements/org.apache.streampipes.sinks.databases.jvm.mysql/icon.png" width="150px;" class="pe-image-documentation"/>
-</p>
-
-***
-
-## Description
-
-Stores events to a MySQL Database.
-
-***
-
-## Required input
-
-This sink does not have any requirements and works with any incoming event type.
-
-***
-
-## Configuration
-
-### Hostname
-
-The hostname of the MySQL Server.
-
-### Port
-
-The port of the MySQL Server (default: 3306).
-
-### Database
-
-The database of the MySQL Server the data is written to.
-
-### Table
-
-The table name of the MySQL Server the data is written to.
-
-### Username
-
-The username for the MySQL Server.
-
-### Password
-
-The password for the MySQL Server.
-
-## Output
-
-(not applicable for data sinks)
-
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md b/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md
index 5c7d7cd..bf7f1de 100644
--- a/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md
+++ b/docs/pe/org.apache.streampipes.sinks.databases.jvm.opcua.md
@@ -69,4 +69,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.databases.jvm.redis.md b/docs/pe/org.apache.streampipes.sinks.databases.jvm.redis.md
new file mode 100644
index 0000000..cee9844
--- /dev/null
+++ b/docs/pe/org.apache.streampipes.sinks.databases.jvm.redis.md
@@ -0,0 +1,87 @@
+---
+id: org.apache.streampipes.sinks.databases.jvm.redis
+title: Redis
+sidebar_label: Redis
+---
+
+<!--
+ ~ 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="/img/pipeline-elements/org.apache.streampipes.sinks.databases.jvm.redis/icon.png" width="150px;" class="pe-image-documentation"/>
+</p>
+
+***
+
+## Description
+
+Stores events in a Redis key-value store.
+
+***
+
+## Required input
+
+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 Redis instance
+
+### Port
+The port of the Redis instance (default 6379)
+
+### Key Field
+Runtime field to be used as the key when storing the event. If auto-increment is enabled, this setting will be ignored.
+
+### Auto Increment
+Enabling this will generate a sequential numeric key for every record inserted. (note: enabling this will ignore Key Field)
+
+### Expiration Time (Optional)
+The expiration time for a persisted event.
+
+### Password (Optional)
+The password for the Redis instance.
+
+### Connection Name (Optional)
+A connection name to assign for the current connection.
+
+### DB Index (Optional)
+Zero-based numeric index for Redis database.
+
+### Max Active (Redis Pool) (Optional)
+The maximum number of connections that can be allocated from the pool.
+
+### Max Idle (Redis Pool) (Optional)
+The maximum number of connections that can remain idle in the pool.
+
+### Max Wait (Redis Pool) (Optional)
+The maximum number of milliseconds that the caller needs to wait when no connection is available.
+
+### Max Timeout (Redis Pool) (Optional)
+The maximum time for connection timeout and read/write timeout.
+
+## Output
+
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md b/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md
index ab067e4..527c991 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md
+++ b/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake.md
@@ -32,7 +32,8 @@
## Description
-Stores events in an InfluxDB.
+Stores events in the internal data lake so that data can be visualized in the live dashboard or in the data explorer.
+Simply create a pipeline with a data lake sink, switch to one of the data exploration tool and start exploring your data!
***
@@ -45,41 +46,7 @@
## Configuration
-### Hostname
+### Index
-The hostname/URL of the InfluxDB instance. (Include http(s)://).
+The name of the storage group of this event.
-### Port
-
-The port of the InfluxDB instance.
-
-### Database Name
-
-The name of the database where events will be stored.
-
-### Measurement Name
-
-The name of the Measurement where events will be stored (will be created if it does not exist).
-
-### Username
-
-The username for the InfluxDB Server.
-
-### Password
-
-The password for the InfluxDB Server.
-
-### Timestamp Field
-
-The field which contains the required timestamp.
-
-### Buffer Size
-
-Indicates how many events are written into a buffer, before they are written to the database.
-
-### Maximum Flush
-
-The maximum waiting time for the buffer to fill the Buffer size before it will be written to the database in ms.
-## Output
-
-(not applicable for data sinks)
diff --git a/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md b/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md
index be2af8f..0dd3b0e 100644
--- a/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md
+++ b/docs/pe/org.apache.streampipes.sinks.internal.jvm.notification.md
@@ -54,4 +54,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md
index d102d55..ff786cb 100644
--- a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md
+++ b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.email.md
@@ -64,4 +64,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md
index 6a6be19..0c4d642 100644
--- a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md
+++ b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.onesignal.md
@@ -60,4 +60,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md
index a08cf3d..ffd6b0c 100644
--- a/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md
+++ b/docs/pe/org.apache.streampipes.sinks.notifications.jvm.slack.md
@@ -64,4 +64,4 @@
## Output
-(not applicable for data sinks)
+(not applicable for data sinks)
\ No newline at end of file
diff --git a/website-v2/sidebars.json b/website-v2/sidebars.json
index 31b768d..55e46f5 100644
--- a/website-v2/sidebars.json
+++ b/website-v2/sidebars.json
@@ -1,14 +1,14 @@
{
"documentation": {
- "\uD83D\uDE80 Try StreamPipes": [
+ "🚀 Try StreamPipes": [
"user-guide-introduction",
"try-installation"
],
- "\uD83D\uDCA1 Concepts": [
+ "💡 Concepts": [
"introduction",
"concepts-overview"
],
- "\uD83C\uDF93 Use StreamPipes": [
+ "🎓 Use StreamPipes": [
"use-connect",
"use-pipeline-editor",
"use-managing-pipelines",
@@ -18,148 +18,124 @@
"use-install-pipeline-elements",
"use-configurations"
],
- "\uD83D\uDCDA Pipeline Elements": [
+ "📚 Pipeline Elements": [
{
"type": "category",
"label": "Adapters",
"items": [
- "pe/org.apache.streampipes.connect.protocol.stream.kafka",
- "pe/org.apache.streampipes.connect.protocol.stream.pulsar",
- "pe/org.apache.streampipes.connect.adapters.coindesk",
- "pe/org.apache.streampipes.connect.protocol.stream.file",
- "pe/org.apache.streampipes.protocol.set.file",
- "pe/org.apache.streampipes.connect.adapters.flic.mqtt",
- "pe/org.apache.streampipes.connect.adapters.gdelt",
- "pe/org.apache.streampipes.connect.protocol.stream.httpserver",
- "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.connect.adapters.image.set",
- "pe/org.apache.streampipes.connect.adapters.image.stream",
- "pe/org.apache.streampipes.connect.adapters.influxdb.set",
- "pe/org.apache.streampipes.connect.adapters.influxdb.stream",
- "pe/org.apache.streampipes.connect.protocol.stream.mqtt",
- "pe/org.apache.streampipes.connect.adapters.simulator.machine",
- "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.connect.adapters.opcua",
- "pe/org.apache.streampipes.connect.adapters.plc4x.modbus",
- "pe/org.apache.streampipes.connect.adapters.plc4x.s7",
- "pe/org.apache.streampipes.connect.adapters.ros",
- "pe/org.apache.streampipes.connect.adapters.simulator.randomdataset",
- "pe/org.apache.streampipes.connect.adapters.simulator.randomdatastream",
- "pe/org.apache.streampipes.connect.adapters.slack",
- "pe/org.apache.streampipes.connect.adapters.ti",
- "pe/org.apache.streampipes.connect.adapters.wikipedia.edit",
- "pe/org.apache.streampipes.connect.adapters.wikipedia.new"
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.kafka",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.pulsar",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.tubemq",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.file",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.httpserver",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.http",
+ "pe/org.apache.streampipes.connect.iiot.adapters.influxdb.stream",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.mqtt",
+ "pe/org.apache.streampipes.connect.iiot.adapters.simulator.machine",
+ "pe/org.apache.streampipes.connect.iiot.protocol.stream.nats",
+ "pe/org.apache.streampipes.connect.iiot.adapters.opcua",
+ "pe/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus",
+ "pe/org.apache.streampipes.connect.iiot.adapters.plc4x.s7",
+ "pe/org.apache.streampipes.connect.iiot.adapters.ros",
+ "pe/org.apache.streampipes.connect.iiot.adapters.iolink"
]
},
{
"type": "category",
"label": "Data Processors",
"items": [
- "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.processors.transformation.flink.processor.boilerplate",
"pe/org.apache.streampipes.processors.transformation.jvm.booloperator.counter",
+ "pe/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter",
"pe/org.apache.streampipes.processors.transformation.jvm.booloperator.inverter",
+ "pe/org.apache.streampipes.processors.transformation.jvm.booloperator.logical",
"pe/org.apache.streampipes.processors.transformation.jvm.booloperator.timer",
"pe/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state",
"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.processors.filters.jvm.compose",
- "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.processors.changedetection.jvm.cusum",
- "pe/org.apache.streampipes.processors.geo.jvm.processor.distancecalculator",
- "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG",
- "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.processors.siddhi.frequency",
- "pe/org.apache.streampipes.processors.siddhi.frequencychange",
+ "pe/org.apache.streampipes.processors.siddhi.count",
+ "pe/org.apache.streampipes.processors.transformation.jvm.fieldhasher",
+ "pe/org.apache.streampipes.processors.transformation.jvm.field-mapper",
+ "pe/org.apache.streampipes.processors.transformation.jvm.fieldrename",
"pe/org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification",
- "pe/org.apache.streampipes.processor.geo.jvm.geocoding",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic",
+ "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory",
+ "pe/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator",
"pe/org.apache.streampipes.processor.imageclassification.jvm.image-cropper",
"pe/org.apache.streampipes.processor.imageclassification.jvm.image-enricher",
- "pe/org.apache.streampipes.processors.textmining.flink.languagedetection",
+ "pe/org.apache.streampipes.processors.enricher.jvm.jseval",
"pe/org.apache.streampipes.processors.textmining.jvm.languagedetection",
- "pe/org.apache.streampipes.processors.enricher.flink.processor.math.mathop",
+ "pe/org.apache.streampipes.processors.siddhi.listcollector",
+ "pe/org.apache.streampipes.processors.siddhi.listfilter",
+ "pe/org.apache.streampipes.processors.enricher.jvm.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.transformation.jvm.measurementunitconverter",
"pe/org.apache.streampipes.processors.filters.jvm.enrich",
+ "pe/org.apache.streampipes.processors.filters.jvm.schema",
+ "pe/org.apache.streampipes.processors.filters.jvm.movingaverage",
"pe/org.apache.streampipes.processors.textmining.jvm.namefinder",
"pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number",
+ "pe/org.apache.streampipes.processors.transformation.jvm.round",
"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.processors.textmining.jvm.partofspeech",
- "pe/org.apache.streampipes.processors.pattern-detection.flink.peak-detection",
"pe/org.apache.streampipes.processors.filters.jvm.project",
"pe/org.apache.streampipes.processor.imageclassification.qrcode",
"pe/org.apache.streampipes.processors.filters.jvm.limit",
- "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.transformation.jvm.processor.booloperator.edge",
- "pe/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory",
"pe/org.apache.streampipes.processors.enricher.jvm.sizemeasure",
- "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.transformation.jvm.processor.state.buffer",
- "pe/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer",
- "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.enricher.jvm.processor.math.staticmathop",
"pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter",
"pe/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer",
"pe/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state",
+ "pe/org.apache.streampipes.processors.filters.jvm.sdt",
"pe/org.apache.streampipes.processors.filters.jvm.merge",
"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.filters.jvm.throughputmon",
"pe/org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor",
"pe/org.apache.streampipes.processors.textmining.jvm.tokenizer",
+ "pe/org.apache.streampipes.processors.siddhi.topk",
"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.enricher.jvm.processor.trigonometry",
+ "pe/org.apache.streampipes.processors.enricher.jvm.valuechange",
"pe/org.apache.streampipes.processors.transformation.jvm.changed-value",
- "pe/org.apache.streampipes.processors.textmining.flink.wordcount"
+ "pe/org.apache.streampipes.processors.changedetection.jvm.welford"
]
},
{
"type": "category",
"label": "Data Sinks",
"items": [
+ "pe/org.apache.streampipes.sinks.databases.jvm.iotdb",
"pe/org.apache.streampipes.sinks.brokers.jvm.bufferrest",
"pe/org.apache.streampipes.sinks.databases.jvm.couchdb",
- "pe/org.apache.streampipes.sinks.internal.jvm.dashboard",
"pe/org.apache.streampipes.sinks.internal.jvm.datalake",
"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.sinks.databases.jvm.influxdb",
- "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.sinks.databases.jvm.mysql",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.mqtt",
"pe/org.apache.streampipes.sinks.brokers.jvm.nats",
"pe/org.apache.streampipes.sinks.internal.jvm.notification",
"pe/org.apache.streampipes.sinks.databases.jvm.opcua",
@@ -168,8 +144,12 @@
"pe/org.apache.streampipes.sinks.brokers.jvm.pulsar",
"pe/org.apache.streampipes.sinks.brokers.jvm.rest",
"pe/org.apache.streampipes.sinks.brokers.jvm.rabbitmq",
+ "pe/org.apache.streampipes.sinks.databases.jvm.redis",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.rocketmq",
"pe/org.apache.streampipes.sinks.notifications.jvm.slack",
- "pe/org.apache.streampipes.sinks.notifications.jvm.telegram"
+ "pe/org.apache.streampipes.sinks.notifications.jvm.telegram",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.tubemq",
+ "pe/org.apache.streampipes.sinks.brokers.jvm.websocket"
]
}
],
@@ -179,7 +159,7 @@
"deploy-use-ssl",
"deploy-security"
],
- "\uD83D\uDCBB Customize StreamPipes": [
+ "💻 Customize StreamPipes": [
"extend-setup",
"extend-cli",
"extend-archetypes",
@@ -195,14 +175,14 @@
"extend-sdk-output-strategies",
"extend-sdk-migration-service-discovery"
],
- "\uD83D\uDD27 Technicals": [
+ "🔧 Technicals": [
"technicals-architecture",
"technicals-user-guidance",
"technicals-runtime-wrappers",
"technicals-messaging",
"technicals-configuration"
],
- "\uD83D\uDC6A Community": [
+ "👪 Community": [
"community-get-help",
"community-contribute"
]
@@ -212,4 +192,4 @@
"faq-common-problems"
]
}
-}
+}
\ No newline at end of file
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/icon.png
new file mode 100644
index 0000000..1f9bb88
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.iolink/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.iolink/icon.png
new file mode 100644
index 0000000..39c33a2
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.iolink/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.opcua/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.opcua/icon.png
new file mode 100644
index 0000000..ab68d43
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.opcua/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/icon.png
new file mode 100644
index 0000000..cfb6339
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/icon.png
new file mode 100644
index 0000000..cfb6339
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.ros/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.ros/icon.png
new file mode 100644
index 0000000..ae0e943
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.ros/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.simulator.machine/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.simulator.machine/icon.png
new file mode 100644
index 0000000..33c09c4
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.adapters.simulator.machine/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.file/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.file/icon.png
new file mode 100644
index 0000000..2b3a037
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.file/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.http/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.http/icon.png
new file mode 100644
index 0000000..b44424d
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.http/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.httpserver/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.httpserver/icon.png
new file mode 100644
index 0000000..b44424d
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.httpserver/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.kafka/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.kafka/icon.png
new file mode 100644
index 0000000..8b72662
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.kafka/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png
new file mode 100644
index 0000000..88f2035
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png
new file mode 100644
index 0000000..a016ca8
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/icon.png
new file mode 100644
index 0000000..d1b1228
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png
new file mode 100644
index 0000000..d686bac
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png
new file mode 100644
index 0000000..7c0fde0
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.changedetection.jvm.welford/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.changedetection.jvm.welford/icon.png
new file mode 100644
index 0000000..444fa4e
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.changedetection.jvm.welford/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop/icon.png
new file mode 100644
index 0000000..4da2789
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.mathop/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop/icon.png
new file mode 100644
index 0000000..6146d8d
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry/icon.png
new file mode 100644
index 0000000..77fc667
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.processor.trigonometry/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.valuechange/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.valuechange/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.enricher.jvm.valuechange/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.merge/merge_description.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.merge/merge_description.png
new file mode 100644
index 0000000..a08c6b1
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.merge/merge_description.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.movingaverage/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.movingaverage/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.movingaverage/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter/icon.png
new file mode 100644
index 0000000..2823bc4
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.processor.booleanfilter/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.schema/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.schema/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.schema/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.sdt/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.sdt/icon.png
new file mode 100644
index 0000000..046158d
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.sdt/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.throughputmon/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.throughputmon/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.filters.jvm.throughputmon/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/icon.png
new file mode 100644
index 0000000..11c8028
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/icon.png
new file mode 100644
index 0000000..1742f6d
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/output.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/output.png
new file mode 100644
index 0000000..ce4b5ec
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/output.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg/icon.png
new file mode 100644
index 0000000..d2a81e7
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.epsg/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint/icon.png
new file mode 100644
index 0000000..7b8c315
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/icon.png
new file mode 100644
index 0000000..5521a54
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png
index 7389006..1f3bebb 100644
--- a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/icon.png
new file mode 100644
index 0000000..5467806
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/icon.png
new file mode 100644
index 0000000..be71973
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine/icon.png
new file mode 100644
index 0000000..f4a7f75
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic/icon.png
new file mode 100644
index 0000000..f245b71
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps/icon.png
new file mode 100644
index 0000000..ee65703
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic/icon.png
new file mode 100644
index 0000000..fae9028
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname/icon.png
new file mode 100644
index 0000000..505f90f
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator/icon.png
new file mode 100644
index 0000000..914d29e
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.count/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.count/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.count/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listcollector/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listcollector/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listcollector/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listfilter/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listfilter/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.listfilter/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.topk/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.topk/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.siddhi.topk/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.logical/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.logical/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.logical/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/time_measure_example.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/time_measure_example.png
new file mode 100644
index 0000000..9c8ea7e
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping/time_measure_example.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.field-mapper/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.field-mapper/icon.png
new file mode 100644
index 0000000..2eafc5f
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.field-mapper/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldhasher/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldhasher/icon.png
new file mode 100644
index 0000000..f9fa3a2
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldhasher/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldrename/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldrename/icon.png
new file mode 100644
index 0000000..dcd55fc
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.fieldrename/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter/icon.png
new file mode 100644
index 0000000..ebe9f3a
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.measurementunitconverter/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.round/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.round/icon.png
new file mode 100644
index 0000000..c423b29
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.processors.transformation.jvm.round/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png
new file mode 100644
index 0000000..d686bac
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png
new file mode 100644
index 0000000..7c0fde0
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png
Binary files differ
diff --git a/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.websocket/icon.png b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.websocket/icon.png
new file mode 100644
index 0000000..c7efb91
--- /dev/null
+++ b/website-v2/static/img/pipeline-elements/org.apache.streampipes.sinks.brokers.jvm.websocket/icon.png
Binary files differ
