20 docs tagged with "Java"

Using Flink CEP to generate alerts when a sensor remains hot for too long

Introduction

Batch and Streaming with the Table and DataStream APIs

Capturing late data to send to a separate sink with Apache Flink

Creating a new pipeline from scratch can be difficult, especially if there are no data sources and sinks set up yet.

Continuously reading CSV files with Apache Flink

Creating dead letter queues when using Apache Kafka with Apache Flink

Deserializing JSON from Apache Kafka with Apache Flink

Exactly once processing with Apache Kafka and Apache Flink

Joining and deduplicating events from Kafka in Apache Flink

Using a custom metric to measure latency

Using Flink's State Processor API to migrate state away from Kyro

Extracting metadata from Apache Kafka record headers

Reading changes from databases using Change Data Capture (CDC) with Apache Flink

Reading Google Protocol Buffers with Apache Flink®

Splitting or routing a stream of events

Unit testing managed state with Apache Flink's test harnesses

Upgrading Flink jobs that use the Table API

Computing analytics on events grouped into session windows

Writing Apache Parquet files with Apache Flink