apache / streampipes-extensions
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams. This repository contains ready-to-use pipeline elements and adapters for StreamPipes Connect
☆26Updated 2 years ago
Alternatives and similar repositories for streampipes-extensions:
Users that are interested in streampipes-extensions are comparing it to the libraries listed below
- Pulsar IO Kafka Connector☆24Updated last year
- Flink dynamic CEP demo☆18Updated 2 years ago
- Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book☆17Updated 2 years ago
- Sematext Monitoring Agent☆23Updated this week
- Ecosystem website for Apache Flink☆12Updated last year
- Flink HTTP Sink Connector☆11Updated 3 years ago
- spark-drools tutorials☆16Updated 9 months ago
- Code and documentation for the demonstration example of the real-time bushfire alerting with the Complex Event Processing (CEP) in Apache…☆26Updated 6 years ago
- Flink image for Kubernetes that fixes Jobmanage connection issue☆26Updated 6 years ago
- Integration of Iceberg table management into Spark SQL☆11Updated 5 years ago
- BlobIt - a Distributed Large Object Storage☆36Updated last year
- Extension that can be used to receive events from a Kafka cluster and to publish events to a Kafka cluster☆18Updated 3 months ago
- Industrial IoT (IIoT) Integration and Data Processing with Apache PLC4X, Kafka Connect, KSQL (OPC-UA, Modbus, Siemens S7)☆33Updated 5 years ago
- A demo combining Kafka Streams and Drools to create a lightweight real-time rules engine.☆37Updated last year
- Spark Connector to read and write with Pulsar☆113Updated 2 months ago
- Apache Phoenix Query Server☆48Updated 2 weeks ago
- Kylo is a data lake management software platform and framework for enabling scalable enterprise-class data lakes on big data technologies…☆21Updated 6 years ago
- A JDBC driver for CrateDB.☆23Updated 3 weeks ago
- Sample Applications for Pravega.☆54Updated last year
- A custom ContentRepository implementation for NiFi to persist data to MinIO Object Storage☆34Updated 2 years ago
- Temporal_Graph_library☆25Updated 5 years ago
- This is a simple CEP Engine leveraging the Kafka Streams platform☆16Updated 7 years ago
- Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream API☆14Updated 4 years ago
- The code repository for the "Pulsar in Action" book by Manning press☆47Updated 2 years ago
- Dremio Flight connector. Access Dremio using Arrow flight☆40Updated 4 years ago
- Serializable ACID transactions on streaming data☆24Updated 2 years ago
- Collection of generic Apache Flink operators☆17Updated 7 years ago
- Common components used across the datamountaineer kafka connect connectors☆21Updated 3 years ago
- Flink Examples☆39Updated 8 years ago
- Distributed Operations and Data Organizer built on Apache BookKeeper☆27Updated last year