THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Checkpoints [doc]
- A New DoFn [doc], [slides]
- Proposed Splittable DoFn API changes [doc]
- Splittable DoFn (Obsoletes Source API) [doc]
- State and Timers for DoFn [doc]
- ContextFn [doc]
- Static Display Data [doc]
- Lateness (and Panes) in Apache Beam [doc]
- Triggers in Apache Beam [doc]
- Triggering is for sinks [doc] (not implemented)
- Pipeline Drain [doc]
- Pipelines Considered Harmful [doc]
- Side-Channel Inputs [doc]
- Dynamic Pipeline Options [doc]
- SDK Support for Reading Dynamic PipelineOptions [doc]
- Fine-grained Resource Configuration in Beam [doc]
- External Join with KV Stores [doc]
- Error Reporting Callback (WIP) [doc]
- Snapshotting and Updating Beam Pipelines [doc]
- Requiring PTransform to set a coder on its resulting collections [mail]
- Support of @RequiresStableInput annotation [doc], [mail]
- [PROPOSAL] @onwindowexpiration [mail]
- AutoValue Coding and Row Support [doc]
- HyperLogLog++ Integration with Apache Beam [doc]
- Retractions [doc]
- @RequiresTimeSortedInput annotation for stateful DoFns [doc]
IO / Filesystem
- 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]
...