Samples Catalog
Sensor Collector
Pravega Sensor Collector collects data from sensors and ingests the data into Pravega streams.
Blog: Data Flow from Sensors to the Edge and the Cloud using Pravega
Use Case: Predictive Maintenance for IoT
Docs: README
Source: pravega-sensor-collector
Spark Examples
Demonstrates the capabilities of Pravega as a data stream storage system for Apache Spark.
Get Started: Using Spark
Code Hub: Pravega Spark Connectors
Docs: README
Sample Code: spark-connector-examples
Source: spark-connectors
Ingest Gateway
A simple HTTP server that can be used to write JSON events to a Pravega stream.
Use Case: Real-time Billing
Docs: README
Source: pravega-ingest-gateway
Schema Registry
Demonstrates how to work with Pravega Schema Registry using different serialization formats such as Avro, Protobuf, and JSON. Schema evolution and compression are also demonstrated.
Get Started: Using Schema Registry
Docs: README
Sample Code: schema-registry-examples
Source: schema-registry
MQTT to Pravega Bridge
A sample application reads events from MQTT and writes them to a Pravega stream.
Docs: README
Source: mqtt-pravega-bridge
Flink Examples
Demonstrates the capabilities of Pravega as a data stream storage system for Apache Flink. Samples are word count, exactly once processing, stream cuts, and watermarks.
Get Started: Using Flink
Docs: README
Sample Code: flink-connector-examples
Source: flink-connectors