org.apache.flink.examples.java.misc

Class CollectionExecutionExample

java.lang.Object

org.apache.flink.examples.java.misc.CollectionExecutionExample

public class CollectionExecutionExample
extends Object

This example shows how to use the collection based execution of Flink. The collection based execution is a local mode that is not using the full Flink runtime. DataSet transformations are executed on Java collections. See the "Local Execution" section in the documentation for more details: http://flink.apache.org/docs/latest/apis/local_execution.html

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CollectionExecutionExample.EMail POJO for an EMail.
static class	CollectionExecutionExample.User POJO class representing a user

Constructor Summary

Constructors

Constructor and Description
CollectionExecutionExample()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectionExecutionExample

public CollectionExecutionExample()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception