Cluster Execution

The command line interface lets you submit packaged programs (JARs) to a cluster (or single machine setup).

Remote Environment

The remote environment lets you execute Flink Java programs on a cluster directly. The remote environment points to the cluster on which you want to execute the program.

Example

The following illustrates the use of the RemoteEnvironment:

public static void main(String[] args) throws Exception {
    ExecutionEnvironment env = ExecutionEnvironment
    data
        .filter(new FilterFunction<String>() {
            public boolean filter(String value) {
        })
        .writeAsText("hdfs://path/to/result");
    env.execute();
}