Package org.apache.flink.api.common.operators

Interface Summary

Interface	Description
GenericDataSourceBase.SplitDataProperties<T>
IterationOperator
MailboxExecutor	Executor like interface for a build around a mailbox-based execution model.
MailboxExecutor.MailOptions	Extra options to configure enqueued mails.
ProcessingTimeService	A service that allows to get the current processing time and register timers that will execute the given ProcessingTimeService.ProcessingTimeCallback when firing.
ProcessingTimeService.ProcessingTimeCallback	A callback that can be registered via ProcessingTimeService.registerTimer(long, ProcessingTimeCallback).
SemanticProperties	Container for the semantic properties associated to an operator.

Class Summary

Class	Description
AbstractUdfOperator<OUT,FT extends org.apache.flink.api.common.functions.Function>	Abstract superclass for all contracts that represent actual operators.
BinaryOperatorInformation<IN1,IN2,OUT>	A class for holding information about a single input operator, such as input/output TypeInformation.
CollectionExecutor	Execution utility for serial, local, collection-based executions of Flink programs.
CompilerHints	A class encapsulating compiler hints describing the behavior of the user function.
DualInputOperator<IN1,IN2,OUT,FT extends org.apache.flink.api.common.functions.Function>	Abstract operator superclass for all operators that have two inputs, like "Join", "CoGroup", or "Cross".
DualInputSemanticProperties	Container for the semantic properties associated to a dual input operator.
GenericDataSinkBase<IN>	Operator for nodes that act as data sinks, storing the data they receive.
GenericDataSourceBase<OUT,T extends InputFormat<OUT,?>>	Abstract superclass for data sources in a Pact plan.
Keys<T>
Keys.ExpressionKeys<T>	Represents (nested) field access through string and integer-based keys
Keys.SelectorFunctionKeys<T,K>
MailOptionsImpl	Options to configure behaviour of executing mailbox mails.
Operator<OUT>	Abstract base class for all operators.
OperatorInformation<OUT>	A class for holding information about an operator, such as input/output TypeInformation.
Ordering	This class represents an ordering on a set of fields.
ResourceSpec	Describe the different resource factors of the operator with UDF.
ResourceSpec.Builder	Builder for the ResourceSpec.
SemanticProperties.EmptySemanticProperties
SingleInputOperator<IN,OUT,FT extends org.apache.flink.api.common.functions.Function>	Abstract superclass for all operators that have one input like "map" or "reduce".
SingleInputSemanticProperties	Container for the semantic properties associated to a single input operator.
SingleInputSemanticProperties.AllFieldsForwardedProperties
SlotSharingGroup	Describe the name and the different resource components of a slot sharing group.
SlotSharingGroup.Builder	Builder for the SlotSharingGroup.
UnaryOperatorInformation<IN,OUT>	A class for holding information about a single input operator, such as input/output TypeInformation.
Union<T>	This operator represents a Union between two inputs.

Enum Summary

Enum	Description
Order	Enumeration representing order.

Exception Summary

Exception	Description
Keys.IncompatibleKeysException
SemanticProperties.InvalidSemanticAnnotationException