Added
- Transforming, aggregating, and join functions for
PCollection. - Functions to work with side inputs and side outputs.
- Basic support for SQL over
PCollectionof rows or Kotlin data classes. - A simple extension for complex event processing (CEP).
- Basic connectors for Kafka and BigQuery.
- Additional methods and classes to test pipelines.