Builds a union coder with the given list of element coders. This list corresponds to a mapping of union tag to Coder. Union tags start at 0.

Returns a ConsoleIO.Write PTransform with the given step name.

Get the underlying byte array.

Creates a new unbounded source from a Flink source. @param flinkSource The Flink source function @param <T> The type that the source function produces

Creates and returns a new test pipeline for batch execution. <p> Use {@link com.google.cloud.dataflow.sdk.testing.DataflowAssert} to add tests, then

Returns a ConsoleIO.Write PTransform with a default step name.

Creates and returns a new test pipeline for streaming or batch execution. <p> Use {@link com.google.cloud.dataflow.sdk.testing.DataflowAssert} to add

Creates and returns a new test pipeline for streaming execution. <p> Use {@link com.google.cloud.dataflow.sdk.testing.DataflowAssert} to add tests, t

List of local files to make available to workers. <p> Jars are placed on the worker's classpath. <p> The default value is the list of jars from the ma

Creates an DataStream where elements are grouped in windows based on the specified windowing strategy. This method assumes that <b>elements are alread

The url of the Flink JobManager on which to execute pipelines. This can either be the the address of a cluster JobManager, in the form "host:port" or