Stream processing with Kafka,Flink,Calcite

Java example to read from Kafka, mapping stream in to calcite table, query and write to a new topic with Flink.

Usage

Do a mvn clean install -Dmaven.test.skip=true to build the jar.

--read-topic --write-topic --bootstrap.servers --group.id

bin/flink run stream-analytics-0.0.1-SNAPSHOT.jar

jar uf target/stream-analytics-0.0.1-SNAPSHOT.jar application.properties query.sql hazelcast-client.xml consumer.properties producer.properties

Name		Name	Last commit message	Last commit date
Latest commit History 4 Commits
.settings		.settings
src/main		src/main
.classpath		.classpath
.gitignore		.gitignore
.project		.project
README.md		README.md
application.properties		application.properties
consumer.properties		consumer.properties
dependency-reduced-pom.xml		dependency-reduced-pom.xml
hazelcast-client.xml		hazelcast-client.xml
hazelcast.xml		hazelcast.xml
hs_err_pid7582.log		hs_err_pid7582.log
jartmp6115585030654785962.tmp		jartmp6115585030654785962.tmp
pom.xml		pom.xml
producer.properties		producer.properties
query.sql		query.sql
schema.json		schema.json