Apache Flink
Running a simple Flink application
Application development
Flink application structure
Source, operator and sink in DataStream API
Flink application example
Testing and validating Flink applications
Flink Project Template
Configuring Flink applications
Setting parallelism and max parallelism
Configuring Flink application resources
Configuring RocksDB state backend
Enabling checkpoints for Flink applications
DataStream connectors
HBase sink with Flink
Creating and configuring the HBaseSinkFunction
Kafka with Flink
Schema Registry with Flink
ClouderaRegistryKafkaSerializationSchema
ClouderaRegistryKafkaDeserializationSchema
Kafka Metrics Reporter
Kudu with Flink
Job lifecycle
Running a Flink job
Using Flink CLI
Enabling savepoints for Flink applications
Monitoring
Flink Dashboard
Streams Messaging Manager integration
Enabling Flink DEBUG logging
Governance
Flink metadata collection using Atlas
Atlas entities in Flink metadata collection
Migrating Flink jobs
Migrating Flink jobs without state
Migrating stateful Flink jobs
Updating Flink job dependencies