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

package org.apache.beam.runners.flink.adapter

Adaptors for using Beam transforms in Apache Flink pipelines.

Related Packages

Package	Description
org.apache.beam.runners.flink	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.metrics	Internal metrics implementation of the Beam runner for Apache Flink.

Classes

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