OSS Streaming data pipeline on GCP

Open source version of raycom. Replaced the Pub/Sub with Kafka, and Dataflow with Flink

Maven

Use maven to generate a skeleton flink project

mvn archetype:generate \
    -DarchetypeGroupId=org.apache.flink \
    -DarchetypeArtifactId=flink-quickstart-java \
    -DarchetypeVersion=1.20.0

Name		Name	Last commit message	Last commit date
Latest commit History 16 Commits
bin		bin
conf		conf
lib		lib
notebooks		notebooks
sql		sql
src/flink/dingostream		src/flink/dingostream
.gitignore		.gitignore
readme.md		readme.md