Package org.apache.beam.runners.flink.adapter

Adaptors for using Beam transforms in Apache Flink pipelines.

See: Description

Class Summary

Class	Description
BeamFlinkDataSetAdapter	An adapter class that allows one to apply Apache Beam PTransforms directly to Flink DataSets.
BeamFlinkDataStreamAdapter	An adapter class that allows one to apply Apache Beam PTransforms directly to Flink DataStreams.
FlinkKey

Package org.apache.beam.runners.flink.adapter Description

Adaptors for using Beam transforms in Apache Flink pipelines.