Constructor and Description |
---|
PlanGenerator(List<DataSink<?>> sinks,
ExecutionConfig config,
int defaultParallelism,
List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cacheFile,
String jobName) |
public PlanGenerator(List<DataSink<?>> sinks, ExecutionConfig config, int defaultParallelism, List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cacheFile, String jobName)
public Plan generate()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.