THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- IOChannelFactory Redesign [doc]
- Configurable BeamFileSystem [doc]
- New API for writing files in Beam [doc]
- Dynamic file-based sinks [doc]
- Event Time and Watermarks in KafkaIO [doc]
- Exactly-once Kafka sink [doc]
- Beam GCP Debuggability Metrics [doc]
Metrics
- Defining and Adding SDK Metrics via FN API [doc]
- Histogram Style Metrics - [doc]
- Get Metrics API: Metric Extraction via proto RPC API. [doc]
- Metrics API [doc]
- I/O Metrics [doc]
- Metrics extraction independent from runners / execution engines [doc]
- Watermark Metrics [doc]
- Support Dropwizard Metrics in Beam [doc]
- Beam GCP Debuggability Metrics [doc]
Runners
- Runner Authoring Guide [doc] (obsoletes [doc] and [doc])
- Composite PInputs, POutputs, and the Runner API [doc]
- Side Input Architecture for Apache Beam [doc]
- Runner supported features plugin [doc]
- Structured streaming Spark Runner [doc]
...