Uses of Class
org.apache.flink.api.common.operators.GenericDataSinkBase

Packages that use GenericDataSinkBase

Package	Description
org.apache.flink.api.common

Uses of GenericDataSinkBase in org.apache.flink.api.common

Fields in org.apache.flink.api.common with type parameters of type GenericDataSinkBase

Modifier and Type	Field	Description
protected List<GenericDataSinkBase<?>>	Plan.sinks	A collection of all sinks in the plan.

Methods in org.apache.flink.api.common that return types with arguments of type GenericDataSinkBase

Modifier and Type	Method	Description
Collection<? extends GenericDataSinkBase<?>>	Plan.getDataSinks()	Gets all the data sinks of this job.

Methods in org.apache.flink.api.common with parameters of type GenericDataSinkBase

Modifier and Type	Method	Description
void	Plan.addDataSink(GenericDataSinkBase<?> sink)	Adds a data sink to the set of sinks in this program.

Constructors in org.apache.flink.api.common with parameters of type GenericDataSinkBase

Constructor	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 parameters in org.apache.flink.api.common with type arguments of type GenericDataSinkBase

Constructor	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.