Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.common.operators.base |
Modifier and Type | Class and Description |
---|---|
class |
BinaryOperatorInformation<IN1,IN2,OUT>
A class for holding information about a single input operator, such as input/output TypeInformation.
|
class |
UnaryOperatorInformation<IN,OUT>
A class for holding information about a single input operator, such as input/output TypeInformation.
|
Modifier and Type | Field and Description |
---|---|
protected OperatorInformation<OUT> |
Operator.operatorInfo
The return type of the user function.
|
Modifier and Type | Method and Description |
---|---|
OperatorInformation<OUT> |
Operator.getOperatorInfo()
Gets the information about the operators input/output types.
|
Constructor and Description |
---|
AbstractUdfOperator(UserCodeWrapper<FT> function,
OperatorInformation<OUT> operatorInfo,
String name)
Creates a new abstract operator with the given name wrapping the given user function.
|
GenericDataSourceBase(Class<? extends T> format,
OperatorInformation<OUT> operatorInfo)
Creates a new instance for the given file using the given input format, using the default name.
|
GenericDataSourceBase(Class<? extends T> format,
OperatorInformation<OUT> operatorInfo,
String name)
Creates a new instance for the given file using the given input format.
|
GenericDataSourceBase(T format,
OperatorInformation<OUT> operatorInfo)
Creates a new instance for the given file using the given input format, using the default name.
|
GenericDataSourceBase(T format,
OperatorInformation<OUT> operatorInfo,
String name)
Creates a new instance for the given file using the given input format.
|
Operator(OperatorInformation<OUT> operatorInfo,
String name)
Creates a new contract with the given name.
|
Constructor and Description |
---|
PartialSolutionPlaceHolder(BulkIterationBase<OT> container,
OperatorInformation<OT> operatorInfo) |
SolutionSetPlaceHolder(DeltaIterationBase<ST,?> container,
OperatorInformation<ST> operatorInfo) |
WorksetPlaceHolder(DeltaIterationBase<?,WT> container,
OperatorInformation<WT> operatorInfo) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.