CollectionExecutor (Flink : Core 1.20.2-cp1 API)

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 Description
  
  CollectionExecutor(ExecutionConfig executionConfig)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method 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