Code Samples

Getting Started
Connect External Kafka Instances With Sdp image
SDP Kafka

Connect External Kafka Instances With Sdp

Apache Community

This is a general guide for connecting external Kafka instances with Dell EMC Streaming Data Platform.

Configure Off Cluster Pravega Clients image
SDP Pravega

Configure Off Cluster Pravega Clients

Apache Community

This is a general guide for configuring Pravega applications/clients to connect to SDP when the client is running off-cluster.

Pravega Stream Ingest On Streaming Data Platform image
SDP Pravega

Pravega Stream Ingest On Streaming Data Platform

Apache Community

This is a general guide for writing and ingesting into a Pravega stream on Dell EMC Streaming Data Platform.

Create Flink Project On Streaming Data Platform image
SDP Flink

Create Flink Project On Streaming Data Platform

Apache Community

This is a general guide for creating and setting up Flink job on Dell EMC Streaming Data Platform.

Pravega Client Examples image
Pravega

Pravega Client Examples

Apache Community

These examples show how to initialize and use the Pravega Client to write and read data to/from a Pravega Stream in Java.

Processing Data
Word Count Example Using Pravega Flink Connectors image
Pravega Flink

Word Count Example Using Pravega Flink Connectors

Apache Community

This example demonstrates how to use the Pravega Flink Connectors to write data collected from an external network stream into a Pravega Stream and read the data from the Pravega Stream.

Streamcuts Flink Example image
SDP Flink

Streamcuts Flink Example

Apache Community

This sample application demonstrates the use of a Pravega abstraction, the StreamCut, in a Flink application to make it easier for developers to write analytics applications.

Pravega Watermark Flink Example image
Pravega Flink

Pravega Watermark Flink Example

Apache Community

This sample demonstrates the use of Pravega Watermarks in Flink applications.

Exactly Once Example image
SDP Flink

Exactly Once Example

Apache Community

This example demonstrates how Pravega EXACTLY_ONCE mode works in conjection with Flink checkpointing and exactly-once mode.