Explore Enterprise Apache Flink with Cloudera Streaming Analytics - CSA 1.2
Explore Enterprise Apache Flink with Cloudera Streaming Analytics - CSA 1.2
What's New in Cloudera Streaming Analytics
Try out the tutorials now: https://github.com/cloudera/flink-tutorials
So let's get our Apache Flink on, as part of my FLaNK Stack series I'll show you some fun things we can do with Apache Flink + Apache Kafka + Apache NiFi.
We will look at some of updates in Apache Flink 1.10 including the SQL Client and API.
We are working with Apache Flink 1.10, Apache NiFi 1.11.4 and Apache Kafka 2.4.1.
The SQL features are strong and we will take a look at what we can do.
Table connectors
- Kafka
- Kudu
- Hive (through catalog)
Data formats (Kafka)
- JSON
- Avro
- CSV
Using Hive Catalog with Flink SQL: https://docs.cloudera.com/csa/1.2.0/flink-sql-table-api/topics/csa-hive-catalog.html
Use Kudu Catalog with Flink SQL: https://docs.cloudera.com/csa/1.2.0/flink-sql-table-api/topics/csa-kudu-catalog.html
Building a DataStream Application in Flink
Build A Flink Project
mvn archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
-DarchetypeVersion=1.10.0References:
