Package org.apache.flink.api.java.utils

Class PlanGenerator

java.lang.Object

org.apache.flink.api.java.utils.PlanGenerator

@Internal
public class PlanGenerator
extends Object

A generator that generates a Plan from a graph of Operators.

Constructor Summary

Constructors

Constructor	Description
PlanGenerator(List<DataSink<?>> sinks, org.apache.flink.api.common.ExecutionConfig config, int defaultParallelism, List<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry>> cacheFile, String jobName)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.Plan	generate()

Methods inherited from class java.lang.Object

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

Constructor Detail

PlanGenerator

public PlanGenerator(List<DataSink<?>> sinks,
                     org.apache.flink.api.common.ExecutionConfig config,
                     int defaultParallelism,
                     List<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry>> cacheFile,
                     String jobName)

Method Detail

generate

public org.apache.flink.api.common.Plan generate()