BEAM Playground

Install Tool-Chain

Minikube

See here...

Ksonnet

See here...

cqlsh (cmd)

• See here...
• Make sure you disable cassandra from running on startup. (i.e. in linux: sudo update-rc.d cassandra disable)

flink (cmd)

• See here...
• You don't need to have the server running. Stop it.
• Make sure your PATH points to the Flink bin directory. (i.e. in linux: echo 'export PATH=$PATH:/opt/flink/bin' >> ~/.bashrc)

Java 8

See here...

Gradle

See here...

GNU Parallel

See here...

kafkacat

See here...

Prepare the environment

Start minikube

minikube start

Deploy stuff

make deploy

Create the schema

make create-schema

Cleanup

When done you can use these to cleanup

minikube delete

Run the test

Write to Cassandra

gradle write-cassandra

Read from Cassandra

gradle read-cassandra