org.apache.flink.api.common.operators

Class CollectionExecutor

java.lang.Object

org.apache.flink.api.common.operators.CollectionExecutor

@Internal
public class CollectionExecutor
extends Object

Execution utility for serial, local, collection-based executions of Flink programs.

Constructor Summary

Constructors

Constructor and Description
CollectionExecutor(ExecutionConfig executionConfig)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	execute(Plan program)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectionExecutor

public CollectionExecutor(ExecutionConfig executionConfig)

Method Detail

execute

public JobExecutionResult execute(Plan program)
                           throws Exception

Throws:

Exception