public class CollectionExecutionExample extends Object
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
Modifier and Type | Class and Description |
---|---|
static class |
CollectionExecutionExample.EMail
POJO for an EMail.
|
static class |
CollectionExecutionExample.User
POJO class representing a user.
|
Constructor and Description |
---|
CollectionExecutionExample() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.