Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.api.java.operators | |
org.apache.flink.optimizer.dag |
Modifier and Type | Field and Description |
---|---|
protected List<GenericDataSinkBase<?>> |
Plan.sinks
A collection of all sinks in the plan.
|
Modifier and Type | Method and Description |
---|---|
Collection<? extends GenericDataSinkBase<?>> |
Plan.getDataSinks()
Gets all the data sinks of this job.
|
Modifier and Type | Method and Description |
---|---|
void |
Plan.addDataSink(GenericDataSinkBase<?> sink)
Adds a data sink to the set of sinks in this program.
|
Constructor and Description |
---|
Plan(GenericDataSinkBase<?> sink)
Creates a new program plan with single data sink.
|
Plan(GenericDataSinkBase<?> sink,
int defaultParallelism)
Creates a new program plan with single data sink and the given default parallelism.
|
Plan(GenericDataSinkBase<?> sink,
String jobName)
Creates a new program plan with the given name, containing initially a single data sink.
|
Plan(GenericDataSinkBase<?> sink,
String jobName,
int defaultParallelism)
Creates a new program plan with the given name and default parallelism, containing initially a single data
sink.
|
Constructor and Description |
---|
Plan(Collection<? extends GenericDataSinkBase<?>> sinks)
Creates a new program plan, describing the data flow that ends at the
given data sinks.
|
Plan(Collection<? extends GenericDataSinkBase<?>> sinks,
int defaultParallelism)
Creates a new program plan with the given default parallelism, describing the data flow that ends at the
given data sinks.
|
Plan(Collection<? extends GenericDataSinkBase<?>> sinks,
String jobName)
Creates a new dataflow plan with the given name, describing the data flow that ends at the
given data sinks.
|
Plan(Collection<? extends GenericDataSinkBase<?>> sinks,
String jobName,
int defaultParallelism)
Creates a new program plan with the given name and default parallelism, describing the data flow that ends
at the given data sinks.
|
Modifier and Type | Method and Description |
---|---|
protected GenericDataSinkBase<T> |
DataSink.translateToDataFlow(Operator<T> input) |
Modifier and Type | Method and Description |
---|---|
GenericDataSinkBase<?> |
DataSinkNode.getOperator()
Gets the operator for which this optimizer sink node was created.
|
Constructor and Description |
---|
DataSinkNode(GenericDataSinkBase<?> sink)
Creates a new DataSinkNode for the given sink operator.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.