Depending on the type of job (Streaming or Batch) and the user-specified options, this method creates the adequate ExecutionEnvironment.

Depending on the type of job (Streaming or Batch), this method creates the adequate job graph translator. In the case of batch, it will work with {@li

The job name is used to identify jobs running on a Flink cluster.

Join two collections, using country code as the key.

Sets the AppliedPTransform which carries input/output. @param currentTransform

If the submitted job is a batch processing job, this method creates the adequate Flink {@link org.apache.flink.api.java.ExecutionEnvironment} dependin

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

Constructs a runner with default properties for testing. @return The newly created runner.

Create the adequate {@link com.google.cloud.dataflow.sdk.util.GroupAlsoByWindowsDoFn}, <b> if not already created</b>. If a {@link com.google.cloud.da

If the submitted job is a stream processing job, this method creates the adequate Flink {@link org.apache.flink.streaming.api.environment.StreamExecut

We remove the first character which encodes the type of the stateTag ('s' for system and 'u' for user). For more details check out the source of {@lin

Attempts to detect all the resources the class loader has access to. This does not recurse to class loader parents stopping it from pulling in resourc

Launches the program execution.