loader

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