Modifier and Type | Method and Description |
---|---|
TypeInformation[] |
DataDistribution.getKeyTypes()
Gets the type of the key by which the dataSet is partitioned.
|
Modifier and Type | Field and Description |
---|---|
protected TypeInformation<IN> |
UnaryOperatorInformation.inputType
Input Type of the operator
|
protected TypeInformation<IN1> |
BinaryOperatorInformation.inputType1
Input type of the first input
|
protected TypeInformation<IN2> |
BinaryOperatorInformation.inputType2
Input type of the second input
|
protected TypeInformation<OUT> |
OperatorInformation.outputType
Output type of the operator
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<IN1> |
BinaryOperatorInformation.getFirstInputType() |
TypeInformation<IN> |
UnaryOperatorInformation.getInputType() |
TypeInformation<T> |
Keys.SelectorFunctionKeys.getInputType() |
abstract TypeInformation<?>[] |
Keys.getKeyFieldTypes() |
TypeInformation<?>[] |
Keys.SelectorFunctionKeys.getKeyFieldTypes() |
TypeInformation<?>[] |
Keys.ExpressionKeys.getKeyFieldTypes() |
TypeInformation<K> |
Keys.SelectorFunctionKeys.getKeyType() |
abstract TypeInformation<?>[] |
Keys.getOriginalKeyFieldTypes() |
TypeInformation<?>[] |
Keys.SelectorFunctionKeys.getOriginalKeyFieldTypes() |
TypeInformation<?>[] |
Keys.ExpressionKeys.getOriginalKeyFieldTypes() |
TypeInformation<OUT> |
OperatorInformation.getOutputType()
Gets the return type of the user code function.
|
TypeInformation<IN2> |
BinaryOperatorInformation.getSecondInputType() |
Modifier and Type | Method and Description |
---|---|
static boolean |
Keys.ExpressionKeys.isSortKey(int fieldPos,
TypeInformation<?> type) |
static boolean |
Keys.ExpressionKeys.isSortKey(String fieldExpr,
TypeInformation<?> type) |
abstract <E> void |
Keys.validateCustomPartitioner(Partitioner<E> partitioner,
TypeInformation<E> typeInfo) |
<E> void |
Keys.SelectorFunctionKeys.validateCustomPartitioner(Partitioner<E> partitioner,
TypeInformation<E> typeInfo) |
<E> void |
Keys.ExpressionKeys.validateCustomPartitioner(Partitioner<E> partitioner,
TypeInformation<E> typeInfo) |
Constructor and Description |
---|
BinaryOperatorInformation(TypeInformation<IN1> inputType1,
TypeInformation<IN2> inputType2,
TypeInformation<OUT> outputType) |
BinaryOperatorInformation(TypeInformation<IN1> inputType1,
TypeInformation<IN2> inputType2,
TypeInformation<OUT> outputType) |
BinaryOperatorInformation(TypeInformation<IN1> inputType1,
TypeInformation<IN2> inputType2,
TypeInformation<OUT> outputType) |
ExpressionKeys(int[] keyPositions,
TypeInformation<T> type)
Create int-based (non-nested) field position keys on a tuple type.
|
ExpressionKeys(int[] keyPositions,
TypeInformation<T> type,
boolean allowEmpty)
Create int-based (non-nested) field position keys on a tuple type.
|
ExpressionKeys(int keyPosition,
TypeInformation<T> type)
Create int-based (non-nested) field position keys on a tuple type.
|
ExpressionKeys(String[] keyExpressions,
TypeInformation<T> type)
Create String-based (nested) field expression keys on a composite type.
|
ExpressionKeys(String keyExpression,
TypeInformation<T> type)
Create String-based (nested) field expression keys on a composite type.
|
ExpressionKeys(TypeInformation<T> type)
ExpressionKeys that is defined by the full data type.
|
IncompatibleKeysException(TypeInformation<?> typeInformation,
TypeInformation<?> typeInformation2) |
IncompatibleKeysException(TypeInformation<?> typeInformation,
TypeInformation<?> typeInformation2) |
OperatorInformation(TypeInformation<OUT> outputType) |
SelectorFunctionKeys(KeySelector<T,K> keyExtractor,
TypeInformation<T> inputType,
TypeInformation<K> keyType) |
SelectorFunctionKeys(KeySelector<T,K> keyExtractor,
TypeInformation<T> inputType,
TypeInformation<K> keyType) |
UnaryOperatorInformation(TypeInformation<IN> inputType,
TypeInformation<OUT> outputType) |
UnaryOperatorInformation(TypeInformation<IN> inputType,
TypeInformation<OUT> outputType) |
Modifier and Type | Method and Description |
---|---|
static Object |
PythonBridgeUtils.getPickledBytesFromJavaObject(Object obj,
TypeInformation<?> dataType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<String> |
SimpleStringSchema.getProducedType() |
TypeInformation<T> |
AbstractDeserializationSchema.getProducedType()
Gets the type produced by this deserializer.
|
TypeInformation<T> |
TypeInformationSerializationSchema.getProducedType() |
Constructor and Description |
---|
AbstractDeserializationSchema(TypeInformation<T> typeInfo)
Creates an AbstractDeserializationSchema that returns the given TypeInformation for the
produced type.
|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
ExecutionConfig ec)
Creates a new de-/serialization schema for the given type.
|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Creates a new de-/serialization schema for the given type.
|
Constructor and Description |
---|
AggregatingStateDescriptor(String name,
AggregateFunction<IN,ACC,OUT> aggFunction,
TypeInformation<ACC> stateType)
Creates a new
ReducingStateDescriptor with the given name and default value. |
ListStateDescriptor(String name,
TypeInformation<T> elementTypeInfo)
Creates a new
ListStateDescriptor with the given name and list element type. |
MapStateDescriptor(String name,
TypeInformation<UK> keyTypeInfo,
TypeInformation<UV> valueTypeInfo)
Create a new
MapStateDescriptor with the given name and the given type information. |
MapStateDescriptor(String name,
TypeInformation<UK> keyTypeInfo,
TypeInformation<UV> valueTypeInfo)
Create a new
MapStateDescriptor with the given name and the given type information. |
ReducingStateDescriptor(String name,
ReduceFunction<T> reduceFunction,
TypeInformation<T> typeInfo)
Creates a new
ReducingStateDescriptor with the given name and default value. |
StateDescriptor(String name,
TypeInformation<T> typeInfo,
T defaultValue)
Create a new
StateDescriptor with the given name and the given type information. |
ValueStateDescriptor(String name,
TypeInformation<T> typeInfo)
Creates a new
ValueStateDescriptor with the given name and type. |
ValueStateDescriptor(String name,
TypeInformation<T> typeInfo,
T defaultValue)
Deprecated.
Use
ValueStateDescriptor(String, TypeInformation) instead and manually
manage the default value by checking whether the contents of the state is null . |
Modifier and Type | Class and Description |
---|---|
class |
BasicArrayTypeInfo<T,C>
Type information for arrays boxed primitive types.
|
class |
BasicTypeInfo<T>
Type information for primitive types (int, long, double, byte, ...), String, Date, Void,
BigInteger, and BigDecimal.
|
class |
FractionalTypeInfo<T>
Type information for numeric fractional primitive types (double, float).
|
class |
IntegerTypeInfo<T>
Type information for numeric integer primitive types: int, long, byte, short, character.
|
class |
LocalTimeTypeInfo<T extends java.time.temporal.Temporal>
Type information for Java LocalDate/LocalTime/LocalDateTime.
|
class |
NothingTypeInfo
Placeholder type information for the
Nothing type. |
class |
NumericTypeInfo<T>
Type information for numeric primitive types: int, long, double, byte, short, float, char.
|
class |
PrimitiveArrayTypeInfo<T>
A
TypeInformation for arrays of primitive types (int, long, double, ...). |
class |
SqlTimeTypeInfo<T>
Type information for Java SQL Date/Time/Timestamp.
|
Modifier and Type | Field and Description |
---|---|
static TypeInformation<BigDecimal> |
Types.BIG_DEC
Returns type information for
BigDecimal . |
static TypeInformation<BigInteger> |
Types.BIG_INT
Returns type information for
BigInteger . |
static TypeInformation<Boolean> |
Types.BOOLEAN
Returns type information for both a primitive
boolean and Boolean . |
static TypeInformation<Byte> |
Types.BYTE
Returns type information for both a primitive
byte and Byte . |
static TypeInformation<Character> |
Types.CHAR
Returns type information for both a primitive
char and Character . |
static TypeInformation<Double> |
Types.DOUBLE
Returns type information for both a primitive
double and Double . |
static TypeInformation<Float> |
Types.FLOAT
Returns type information for both a primitive
float and Float . |
static TypeInformation<java.time.Instant> |
Types.INSTANT
Returns type information for
Instant . |
static TypeInformation<Integer> |
Types.INT
Returns type information for both a primitive
int and Integer . |
static TypeInformation<java.time.LocalDate> |
Types.LOCAL_DATE
Returns type information for
LocalDate . |
static TypeInformation<java.time.LocalDateTime> |
Types.LOCAL_DATE_TIME
Returns type information for
LocalDateTime . |
static TypeInformation<java.time.LocalTime> |
Types.LOCAL_TIME
Returns type information for
LocalTime . |
static TypeInformation<Long> |
Types.LONG
Returns type information for both a primitive
long and Long . |
static TypeInformation<Short> |
Types.SHORT
Returns type information for both a primitive
short and Short . |
static TypeInformation<Date> |
Types.SQL_DATE
Returns type information for
Date . |
static TypeInformation<Time> |
Types.SQL_TIME
Returns type information for
Time . |
static TypeInformation<Timestamp> |
Types.SQL_TIMESTAMP
Returns type information for
Timestamp . |
static TypeInformation<String> |
Types.STRING
Returns type information for
String . |
static TypeInformation<Void> |
Types.VOID
Returns type information for
Void . |
Modifier and Type | Method and Description |
---|---|
abstract TypeInformation<T> |
TypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Creates type information for the type the factory is targeted for.
|
static <L,R> TypeInformation<Either<L,R>> |
Types.EITHER(TypeInformation<L> leftType,
TypeInformation<R> rightType)
Returns type information for Flink's
Either type. |
static <E extends Enum<E>> |
Types.ENUM(Class<E> enumType)
Returns type information for Java enumerations.
|
static <T> TypeInformation<T> |
Types.GENERIC(Class<T> genericClass)
Returns generic type information for any Java object.
|
TypeInformation<C> |
BasicArrayTypeInfo.getComponentInfo() |
TypeInformation<?> |
PrimitiveArrayTypeInfo.getComponentType()
Gets the type information of the component type.
|
TypeInformation<T> |
TypeHint.getTypeInfo()
Gets the type information described by this TypeHint.
|
static <E> TypeInformation<List<E>> |
Types.LIST(TypeInformation<E> elementType)
Returns type information for a Java
List . |
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Returns type information for a Java
Map . |
static <E> TypeInformation<E[]> |
Types.OBJECT_ARRAY(TypeInformation<E> elementType)
Returns type information for Java arrays of object types (such as
String[] ,
Integer[] ). |
static <T> TypeInformation<T> |
TypeInformation.of(Class<T> typeClass)
Creates a TypeInformation for the type described by the given class.
|
static <T> TypeInformation<T> |
TypeInformation.of(TypeHint<T> typeHint)
Creates a TypeInformation for a generic type via a utility "type hint".
|
static <T> TypeInformation<T> |
Types.POJO(Class<T> pojoClass)
Returns type information for a POJO (Plain Old Java Object).
|
static <T> TypeInformation<T> |
Types.POJO(Class<T> pojoClass,
Map<String,TypeInformation<?>> fields)
Returns type information for a POJO (Plain Old Java Object) and allows to specify all fields
manually.
|
static TypeInformation<?> |
Types.PRIMITIVE_ARRAY(TypeInformation<?> elementType)
Returns type information for Java arrays of primitive type (such as
byte[] ). |
static TypeInformation<Row> |
Types.ROW_NAMED(String[] fieldNames,
TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types. |
static <T extends Tuple> |
Types.TUPLE(Class<T> tupleSubclass)
Returns type information for typed subclasses of Flink's
Tuple . |
static <T extends Tuple> |
Types.TUPLE(TypeInformation<?>... types)
|
static <V extends Value> |
Types.VALUE(Class<V> valueType)
Returns type information for Flink value types (classes that implement
Value ). |
Modifier and Type | Method and Description |
---|---|
Map<String,TypeInformation<?>> |
TypeInformation.getGenericParameters()
Optional method for giving Flink's type extraction system information about the mapping of a
generic type parameter to the type information of a subtype.
|
Modifier and Type | Method and Description |
---|---|
static <L,R> TypeInformation<Either<L,R>> |
Types.EITHER(TypeInformation<L> leftType,
TypeInformation<R> rightType)
Returns type information for Flink's
Either type. |
static <L,R> TypeInformation<Either<L,R>> |
Types.EITHER(TypeInformation<L> leftType,
TypeInformation<R> rightType)
Returns type information for Flink's
Either type. |
static <E> TypeInformation<List<E>> |
Types.LIST(TypeInformation<E> elementType)
Returns type information for a Java
List . |
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Returns type information for a Java
Map . |
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Returns type information for a Java
Map . |
static <E> TypeInformation<E[]> |
Types.OBJECT_ARRAY(TypeInformation<E> elementType)
Returns type information for Java arrays of object types (such as
String[] ,
Integer[] ). |
static TypeInformation<?> |
Types.PRIMITIVE_ARRAY(TypeInformation<?> elementType)
Returns type information for Java arrays of primitive type (such as
byte[] ). |
static TypeInformation<Row> |
Types.ROW_NAMED(String[] fieldNames,
TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types. |
static <T extends Tuple> |
Types.TUPLE(TypeInformation<?>... types)
|
Modifier and Type | Method and Description |
---|---|
abstract TypeInformation<T> |
TypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Creates type information for the type the factory is targeted for.
|
static <T> TypeInformation<T> |
Types.POJO(Class<T> pojoClass,
Map<String,TypeInformation<?>> fields)
Returns type information for a POJO (Plain Old Java Object) and allows to specify all fields
manually.
|
Modifier and Type | Class and Description |
---|---|
class |
CompositeType<T>
Base type information class for Tuple and Pojo types
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
CompositeType.FlatFieldDescriptor.getType() |
abstract <X> TypeInformation<X> |
CompositeType.getTypeAt(int pos)
Returns the type of the (unnested) field at the given field position.
|
abstract <X> TypeInformation<X> |
CompositeType.getTypeAt(String fieldExpression)
Returns the type of the (nested) field at the given field expression position.
|
Constructor and Description |
---|
FlatFieldDescriptor(int keyPosition,
TypeInformation<?> type) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Long> |
NumberSequenceSource.getProducedType() |
Modifier and Type | Field and Description |
---|---|
protected TypeInformation<T> |
Transformation.outputType |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
Transformation.getOutputType()
Returns the output type of this
Transformation as a TypeInformation . |
Modifier and Type | Method and Description |
---|---|
void |
Transformation.setOutputType(TypeInformation<T> outputType)
Tries to fill in the type information.
|
Constructor and Description |
---|
Transformation(String name,
TypeInformation<T> outputType,
int parallelism)
Creates a new
Transformation with the given name, output type and parallelism. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
DataSet.getType()
Returns the
TypeInformation for the type of this DataSet. |
Modifier and Type | Method and Description |
---|---|
<X> DataSource<X> |
ExecutionEnvironment.createInput(InputFormat<X,?> inputFormat,
TypeInformation<X> producedType)
Generic method to create an input DataSet with in
InputFormat . |
protected void |
DataSet.fillInType(TypeInformation<T> typeInfo)
Tries to fill in the type information.
|
<X> DataSource<X> |
ExecutionEnvironment.fromCollection(Collection<X> data,
TypeInformation<X> type)
Creates a DataSet from the given non-empty collection.
|
<X> DataSource<X> |
ExecutionEnvironment.fromCollection(Iterator<X> data,
TypeInformation<X> type)
Creates a DataSet from the given iterator.
|
<X> DataSource<X> |
ExecutionEnvironment.fromParallelCollection(SplittableIterator<X> iterator,
TypeInformation<X> type)
Creates a new data set that contains elements in the iterator.
|
static <T> String |
Utils.getSerializerTree(TypeInformation<T> ti)
Debugging utility to understand the hierarchy of serializers created by the Java API.
|
Constructor and Description |
---|
DataSet(ExecutionEnvironment context,
TypeInformation<T> typeInfo) |
Modifier and Type | Method and Description |
---|---|
static DualInputSemanticProperties |
SemanticPropUtil.createProjectionPropertiesDual(int[] fields,
boolean[] isFromFirst,
TypeInformation<?> inType1,
TypeInformation<?> inType2) |
static DualInputSemanticProperties |
SemanticPropUtil.createProjectionPropertiesDual(int[] fields,
boolean[] isFromFirst,
TypeInformation<?> inType1,
TypeInformation<?> inType2) |
static DualInputSemanticProperties |
SemanticPropUtil.getSemanticPropsDual(Set<Annotation> set,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static DualInputSemanticProperties |
SemanticPropUtil.getSemanticPropsDual(Set<Annotation> set,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static DualInputSemanticProperties |
SemanticPropUtil.getSemanticPropsDual(Set<Annotation> set,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
static void |
SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result,
String[] forwardedFirst,
String[] forwardedSecond,
String[] nonForwardedFirst,
String[] nonForwardedSecond,
String[] readFieldsFirst,
String[] readFieldsSecond,
TypeInformation<?> inType1,
TypeInformation<?> inType2,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
static SingleInputSemanticProperties |
SemanticPropUtil.getSemanticPropsSingle(Set<Annotation> set,
TypeInformation<?> inType,
TypeInformation<?> outType) |
static SingleInputSemanticProperties |
SemanticPropUtil.getSemanticPropsSingle(Set<Annotation> set,
TypeInformation<?> inType,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple2<K,V>> |
HadoopInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple2<K,V>> |
HadoopInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
TypeSerializerInputFormat.getProducedType() |
TypeInformation<Row> |
RowCsvInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
void |
CsvOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
The purpose of this method is solely to check whether the data type to be processed is in
fact a tuple type.
|
void |
LocalCollectionOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
void |
TypeSerializerOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
boolean emptyColumnAsNull) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
int[] selectedFields) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
String lineDelimiter,
String fieldDelimiter) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
String lineDelimiter,
String fieldDelimiter,
int[] selectedFields) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypeInfos,
String lineDelimiter,
String fieldDelimiter,
int[] selectedFields,
boolean emptyColumnAsNull) |
SplitDataProperties(TypeInformation<T> type)
Creates SplitDataProperties for the given data types.
|
TypeSerializerInputFormat(TypeInformation<T> resultType) |
Modifier and Type | Method and Description |
---|---|
static <T,K> TypeInformation<Tuple2<K,T>> |
KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K> key) |
static <T,K1,K2> TypeInformation<Tuple3<K1,K2,T>> |
KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K1> key1,
Keys.SelectorFunctionKeys<T,K2> key2) |
TypeInformation<IN1> |
TwoInputOperator.getInput1Type()
Gets the type information of the data type of the first input data set.
|
TypeInformation<IN2> |
TwoInputOperator.getInput2Type()
Gets the type information of the data type of the second input data set.
|
TypeInformation<IN> |
SingleInputOperator.getInputType()
Gets the type information of the data type of the input data set.
|
TypeInformation<OUT> |
Operator.getResultType()
Returns the type of the result of this operator.
|
TypeInformation<T> |
DataSink.getType() |
TypeInformation<WT> |
DeltaIterationResultSet.getWorksetType() |
Modifier and Type | Method and Description |
---|---|
O |
SingleInputUdfOperator.returns(TypeInformation<OUT> typeInfo)
Adds a type information hint about the return type of this operator.
|
O |
TwoInputUdfOperator.returns(TypeInformation<OUT> typeInfo)
Adds a type information hint about the return type of this operator.
|
Constructor and Description |
---|
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderFirst,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderSecond,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupRawOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
String defaultName) |
CrossOperator(DataSet<I1> input1,
DataSet<I2> input2,
CrossFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
CrossOperatorBase.CrossHint hint,
String defaultName) |
DataSink(DataSet<T> data,
OutputFormat<T> format,
TypeInformation<T> type) |
DataSource(ExecutionEnvironment context,
InputFormat<OUT,?> inputFormat,
TypeInformation<OUT> type,
String dataSourceLocationName)
Creates a new data source.
|
DeltaIteration(ExecutionEnvironment context,
TypeInformation<ST> type,
DataSet<ST> solutionSet,
DataSet<WT> workset,
Keys<ST> keys,
int maxIterations) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
FlatMapOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
FlatMapFunction<IN,OUT> function,
String defaultName) |
GroupCombineOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
GroupCombineFunction<IN,OUT> function,
String defaultName)
Constructor for a non-grouped reduce (all reduce).
|
GroupCombineOperator(Grouping<IN> input,
TypeInformation<OUT> resultType,
GroupCombineFunction<IN,OUT> function,
String defaultName)
Constructor for a grouped reduce.
|
GroupReduceOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
GroupReduceFunction<IN,OUT> function,
String defaultName)
Constructor for a non-grouped reduce (all reduce).
|
GroupReduceOperator(Grouping<IN> input,
TypeInformation<OUT> resultType,
GroupReduceFunction<IN,OUT> function,
String defaultName)
Constructor for a grouped reduce.
|
IterativeDataSet(ExecutionEnvironment context,
TypeInformation<T> type,
DataSet<T> input,
int maxIterations) |
JoinOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
JoinType type) |
MapOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
MapFunction<IN,OUT> function,
String defaultName) |
MapPartitionOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
MapPartitionFunction<IN,OUT> function,
String defaultName) |
NoOpOperator(DataSet<IN> input,
TypeInformation<IN> resultType) |
Operator(ExecutionEnvironment context,
TypeInformation<OUT> resultType) |
PartitionOperator(DataSet<T> input,
Keys<T> pKeys,
Partitioner<P> customPartitioner,
TypeInformation<P> partitionerTypeInfo,
String partitionLocationName) |
SingleInputOperator(DataSet<IN> input,
TypeInformation<OUT> resultType) |
SingleInputUdfOperator(DataSet<IN> input,
TypeInformation<OUT> resultType)
Creates a new operators with the given data set as input.
|
TwoInputOperator(DataSet<IN1> input1,
DataSet<IN2> input2,
TypeInformation<OUT> resultType) |
TwoInputUdfOperator(DataSet<IN1> input1,
DataSet<IN2> input2,
TypeInformation<OUT> resultType)
Creates a new operators with the two given data sets as inputs.
|
Modifier and Type | Class and Description |
---|---|
class |
EitherTypeInfo<L,R>
A
TypeInformation for the Either type of the Java API. |
class |
EnumTypeInfo<T extends Enum<T>>
A
TypeInformation for java enumeration types. |
class |
GenericTypeInfo<T> |
class |
ListTypeInfo<T>
A
TypeInformation for the list types of the Java API. |
class |
MapTypeInfo<K,V>
Special
TypeInformation used by MapStateDescriptor . |
class |
MissingTypeInfo
A special type information signifying that the type extraction failed.
|
class |
MultisetTypeInfo<T>
A
TypeInformation for the Multiset types of the Java API. |
class |
ObjectArrayTypeInfo<T,C> |
class |
PojoTypeInfo<T>
TypeInformation for "Java Beans"-style types.
|
class |
RowTypeInfo
TypeInformation for Row . |
class |
TupleTypeInfo<T extends Tuple>
A
TypeInformation for the tuple types of the Java API. |
class |
TupleTypeInfoBase<T> |
class |
ValueTypeInfo<T extends Value>
Type information for data types that extend the
Value interface. |
class |
WritableTypeInfo<T extends org.apache.hadoop.io.Writable>
Type information for data types that extend Hadoop's
Writable interface. |
Modifier and Type | Field and Description |
---|---|
protected TypeInformation<?>[] |
TupleTypeInfoBase.types |
Modifier and Type | Method and Description |
---|---|
protected <OUT,IN1,IN2> |
TypeExtractor.analyzePojo(Type type,
List<Type> typeHierarchy,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
abstract <T> TypeInformation<T> |
AvroUtils.createAvroTypeInfo(Class<T> type)
Creates an
AvroTypeInfo if flink-avro is present, otherwise throws an exception. |
static <T> TypeInformation<T> |
TypeExtractor.createHadoopWritableTypeInfo(Class<T> clazz) |
static <IN1,IN2,OUT> |
TypeExtractor.createTypeInfo(Class<?> baseClass,
Class<?> clazz,
int returnParamPos,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <T> TypeInformation<T> |
TypeExtractor.createTypeInfo(Class<T> type) |
static <OUT> TypeInformation<OUT> |
TypeExtractor.createTypeInfo(Object instance,
Class<?> baseClass,
Class<?> clazz,
int returnParamPos)
Creates a
TypeInformation from the given parameters. |
static TypeInformation<?> |
TypeExtractor.createTypeInfo(Type t) |
TypeInformation<Either<L,R>> |
EitherTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
static <IN,ACC> TypeInformation<ACC> |
TypeExtractor.getAggregateFunctionAccumulatorType(AggregateFunction<IN,ACC,?> function,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getAggregateFunctionReturnType(AggregateFunction<IN,?,OUT> function,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getBinaryOperatorReturnType(Function function,
Class<?> baseClass,
int input1TypeArgumentIndex,
int input2TypeArgumentIndex,
int outputTypeArgumentIndex,
int[] lambdaOutputTypeArgumentIndices,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing)
Returns the binary operator's return type.
|
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
TypeInformation<C> |
ObjectArrayTypeInfo.getComponentInfo() |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
TypeInformation<T> |
ListTypeInfo.getElementTypeInfo()
Gets the type information for the elements contained in the list
|
TypeInformation<T> |
MultisetTypeInfo.getElementTypeInfo()
Gets the type information for the elements contained in the Multiset
|
TypeInformation<?>[] |
TupleTypeInfoBase.getFieldTypes()
Returns the field types.
|
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <X> TypeInformation<X> |
TypeExtractor.getForClass(Class<X> clazz)
Creates type information from a given Class such as Integer, String[] or POJOs.
|
static <X> TypeInformation<X> |
TypeExtractor.getForObject(X value) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN> TypeInformation<IN> |
TypeExtractor.getInputFormatTypes(InputFormat<IN,?> inputFormatInterface) |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getKeySelectorTypes(KeySelector<IN,OUT> selectorInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getKeySelectorTypes(KeySelector<IN,OUT> selectorInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
TypeInformation<K> |
MapTypeInfo.getKeyTypeInfo()
Gets the type information for the keys in the map
|
TypeInformation<L> |
EitherTypeInfo.getLeftType() |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <T> TypeInformation<T> |
TypeExtractor.getPartitionerTypes(Partitioner<T> partitioner) |
static <T> TypeInformation<T> |
TypeExtractor.getPartitionerTypes(Partitioner<T> partitioner,
String functionName,
boolean allowMissing) |
TypeInformation<T> |
ResultTypeQueryable.getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
TypeInformation<R> |
EitherTypeInfo.getRightType() |
<X> TypeInformation<X> |
TupleTypeInfoBase.getTypeAt(int pos) |
<X> TypeInformation<X> |
PojoTypeInfo.getTypeAt(int pos) |
<X> TypeInformation<X> |
TupleTypeInfoBase.getTypeAt(String fieldExpression) |
<X> TypeInformation<X> |
PojoTypeInfo.getTypeAt(String fieldExpression) |
<X> TypeInformation<X> |
RowTypeInfo.getTypeAt(String fieldExpression) |
TypeInformation<?> |
PojoField.getTypeInformation() |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getUnaryOperatorReturnType(Function function,
Class<?> baseClass,
int inputTypeArgumentIndex,
int outputTypeArgumentIndex,
int[] lambdaOutputTypeArgumentIndices,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing)
Returns the unary operator's return type.
|
TypeInformation<V> |
MapTypeInfo.getValueTypeInfo()
Gets the type information for the values in the map
|
Modifier and Type | Method and Description |
---|---|
Map<String,TypeInformation<?>> |
EitherTypeInfo.getGenericParameters() |
Map<String,TypeInformation<?>> |
TupleTypeInfo.getGenericParameters() |
Modifier and Type | Method and Description |
---|---|
protected <OUT,IN1,IN2> |
TypeExtractor.analyzePojo(Type type,
List<Type> typeHierarchy,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
protected <OUT,IN1,IN2> |
TypeExtractor.analyzePojo(Type type,
List<Type> typeHierarchy,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.createTypeInfo(Class<?> baseClass,
Class<?> clazz,
int returnParamPos,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.createTypeInfo(Class<?> baseClass,
Class<?> clazz,
int returnParamPos,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN,ACC> TypeInformation<ACC> |
TypeExtractor.getAggregateFunctionAccumulatorType(AggregateFunction<IN,ACC,?> function,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getAggregateFunctionReturnType(AggregateFunction<IN,?,OUT> function,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getBinaryOperatorReturnType(Function function,
Class<?> baseClass,
int input1TypeArgumentIndex,
int input2TypeArgumentIndex,
int outputTypeArgumentIndex,
int[] lambdaOutputTypeArgumentIndices,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing)
Returns the binary operator's return type.
|
static <IN1,IN2,OUT> |
TypeExtractor.getBinaryOperatorReturnType(Function function,
Class<?> baseClass,
int input1TypeArgumentIndex,
int input2TypeArgumentIndex,
int outputTypeArgumentIndex,
int[] lambdaOutputTypeArgumentIndices,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing)
Returns the binary operator's return type.
|
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFlatMapReturnTypes(FlatMapFunction<IN,OUT> flatMapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <T,C> ObjectArrayTypeInfo<T,C> |
ObjectArrayTypeInfo.getInfoFor(Class<T> arrayClass,
TypeInformation<C> componentInfo) |
static <C> MultisetTypeInfo<C> |
MultisetTypeInfo.getInfoFor(TypeInformation<C> componentInfo) |
static <T,C> ObjectArrayTypeInfo<T,C> |
ObjectArrayTypeInfo.getInfoFor(TypeInformation<C> componentInfo)
Creates a new
ObjectArrayTypeInfo from a TypeInformation for the component type. |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN1,IN2,OUT> |
TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getKeySelectorTypes(KeySelector<IN,OUT> selectorInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getKeySelectorTypes(KeySelector<IN,OUT> selectorInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapPartitionReturnTypes(MapPartitionFunction<IN,OUT> mapPartitionInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getUnaryOperatorReturnType(Function function,
Class<?> baseClass,
int inputTypeArgumentIndex,
int outputTypeArgumentIndex,
int[] lambdaOutputTypeArgumentIndices,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing)
Returns the unary operator's return type.
|
void |
InputTypeConfigurable.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Method that is called on an
OutputFormat when it is
passed to the DataSet's output method. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Either<L,R>> |
EitherTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
Constructor and Description |
---|
EitherTypeInfo(TypeInformation<L> leftType,
TypeInformation<R> rightType) |
EitherTypeInfo(TypeInformation<L> leftType,
TypeInformation<R> rightType) |
ListTypeInfo(TypeInformation<T> elementTypeInfo) |
MapTypeInfo(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo) |
MapTypeInfo(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo) |
MultisetTypeInfo(TypeInformation<T> elementTypeInfo) |
NamedFlatFieldDescriptor(String name,
int keyPosition,
TypeInformation<?> type) |
PojoField(Field field,
TypeInformation<?> type) |
RowTypeInfo(TypeInformation<?>... types) |
RowTypeInfo(TypeInformation<?>[] types,
String[] fieldNames) |
TupleTypeInfo(Class<T> tupleType,
TypeInformation<?>... types) |
TupleTypeInfo(TypeInformation<?>... types) |
TupleTypeInfoBase(Class<T> tupleType,
TypeInformation<?>... types) |
Modifier and Type | Method and Description |
---|---|
static void |
Serializers.recursivelyRegisterType(TypeInformation<?> typeInfo,
ExecutionConfig config,
Set<Class<?>> alreadySeen) |
Modifier and Type | Method and Description |
---|---|
void |
ScalaCsvOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
The purpose of this method is solely to check whether the data type to be processed is in
fact a tuple type.
|
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(OutputTag<L> timedOutPartialMatchesTag,
PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
Applies a flat select function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(PatternFlatSelectFunction<T,R> patternFlatSelectFunction,
TypeInformation<R> outTypeInfo)
Applies a flat select function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.process(PatternProcessFunction<T,R> patternProcessFunction,
TypeInformation<R> outTypeInfo)
Applies a process function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.select(OutputTag<L> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction,
TypeInformation<R> outTypeInfo)
Applies a select function to the detected pattern sequence.
|
Modifier and Type | Class and Description |
---|---|
class |
CompactorRequestTypeInfo
Type information of
CompactorRequest . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
AbstractFileSource.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
StreamFormatAdapter.getProducedType() |
TypeInformation<T> |
FileRecordFormatAdapter.getProducedType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
FileRecordFormat.getProducedType()
Deprecated.
Gets the type produced by this format.
|
abstract TypeInformation<T> |
SimpleStreamFormat.getProducedType()
Gets the type produced by this format.
|
TypeInformation<T> |
StreamFormat.getProducedType()
Gets the type produced by this format.
|
TypeInformation<T> |
BulkFormat.getProducedType()
Gets the type produced by this format.
|
TypeInformation<String> |
TextLineInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
DeserializationSchemaAdapter.getProducedType() |
TypeInformation<T> |
LimitableBulkFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
Optional<TypeInformation<?>> |
HBaseTableSchema.getRowKeyTypeInfo()
Returns the optional type information of row key.
|
Modifier and Type | Method and Description |
---|---|
static int |
HBaseTypeUtils.getTypeIndex(TypeInformation typeInfo)
Gets the type index (type representation in HBase connector) from the
TypeInformation . |
Modifier and Type | Method and Description |
---|---|
void |
GenericJdbcSinkFunction.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
void |
JdbcOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
JdbcRowDataInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
JdbcOutputFormatBuilder |
JdbcOutputFormatBuilder.setRowDataTypeInfo(TypeInformation<RowData> rowDataTypeInfo) |
JdbcRowDataInputFormat.Builder |
JdbcRowDataInputFormat.Builder.setRowDataTypeInfo(TypeInformation<RowData> rowDataTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static int |
JdbcTypeUtil.typeInformationToSqlType(TypeInformation<?> type)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
JdbcXaSinkFunction.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<OUT> |
KafkaSource.getProducedType() |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSchemaTypeInformation<T>
Wrap the pulsar
Schema into a flink TypeInformation . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
PulsarSchemaFactory.createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info)
Create the flink type information by the given schema info.
|
static <T> TypeInformation<T> |
PulsarSchemaUtils.createTypeInformation(org.apache.pulsar.common.schema.SchemaInfo info)
Convert the
SchemaInfo into a flink manageable TypeInformation . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
PrimitiveSchemaFactory.createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info) |
TypeInformation<org.apache.pulsar.common.schema.KeyValue<K,V>> |
KeyValueSchemaFactory.createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info) |
TypeInformation<T> |
BaseStructSchemaFactory.createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info) |
TypeInformation<String> |
StringSchemaFactory.createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info) |
Constructor and Description |
---|
PrimitiveSchemaFactory(org.apache.pulsar.client.api.Schema<T> schema,
TypeInformation<T> typeInformation) |
PrimitiveSchemaFactory(org.apache.pulsar.common.schema.SchemaType type,
org.apache.pulsar.client.api.Schema<T> schema,
TypeInformation<T> typeInformation) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<OUT> |
PulsarSource.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
PulsarTypeInformationWrapper.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <T> PulsarDeserializationSchema<T> |
PulsarDeserializationSchema.flinkTypeInfo(TypeInformation<T> information,
ExecutionConfig config)
Create a PulsarDeserializationSchema by using the given
TypeInformation . |
Constructor and Description |
---|
PulsarTypeInformationWrapper(TypeInformation<T> information,
ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
FileSystemLookupFunction.getResultType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
HiveInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<E> |
AvroInputFormat.getProducedType() |
TypeInformation<T> |
AvroDeserializationSchema.getProducedType() |
TypeInformation<RowData> |
AvroRowDataDeserializationSchema.getProducedType() |
TypeInformation<Row> |
AvroRowDeserializationSchema.getProducedType()
Deprecated.
|
Constructor and Description |
---|
AvroRowDataDeserializationSchema(DeserializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema,
AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter,
TypeInformation<RowData> typeInfo)
Creates a Avro deserialization schema for the given logical type.
|
AvroRowDataDeserializationSchema(RowType rowType,
TypeInformation<RowData> typeInfo)
Creates a Avro deserialization schema for the given logical type.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
DebeziumAvroDeserializationSchema.getProducedType() |
Constructor and Description |
---|
DebeziumAvroDeserializationSchema(RowType rowType,
TypeInformation<RowData> producedTypeInfo,
String schemaRegistryUrl,
Map<String,?> registryConfigs) |
Modifier and Type | Class and Description |
---|---|
class |
AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>
Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing
SpecificRecordBase, the typed Avro POJOs)
|
class |
GenericRecordAvroTypeInfo
TypeInformation for
GenericRecord . |
Modifier and Type | Method and Description |
---|---|
static <T extends org.apache.avro.specific.SpecificRecord> |
AvroSchemaConverter.convertToTypeInfo(Class<T> avroClass)
Converts an Avro class into a nested row structure with deterministic field order and data
types that are compatible with Flink's Table & SQL API.
|
static <T> TypeInformation<T> |
AvroSchemaConverter.convertToTypeInfo(String avroSchemaString)
Converts an Avro schema string into a nested row structure with deterministic field order and
data types that are compatible with Flink's Table & SQL API.
|
Modifier and Type | Method and Description |
---|---|
<T> TypeInformation<T> |
AvroKryoSerializerUtils.createAvroTypeInfo(Class<T> type) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
CsvReaderFormat.getProducedType() |
TypeInformation<Row> |
CsvRowDeserializationSchema.getProducedType()
Deprecated.
|
TypeInformation<RowData> |
CsvRowDataDeserializationSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static RowCsvInputFormat.Builder |
RowCsvInputFormat.builder(TypeInformation<Row> typeInfo,
Path... filePaths)
Create a builder.
|
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper mapper,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
TypeInformation<T> typeInformation)
Builds a new
CsvReaderFormat using a CsvSchema and a pre-created CsvMapper . |
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
TypeInformation<T> typeInformation)
Builds a new
CsvReaderFormat using a CsvSchema . |
Constructor and Description |
---|
Builder(RowType rowType,
TypeInformation<RowData> resultTypeInfo)
Creates a CSV deserialization schema for the given
TypeInformation with optional
parameters. |
Builder(TypeInformation<Row> typeInfo)
Creates a
CsvRowSerializationSchema expecting the given TypeInformation . |
Builder(TypeInformation<Row> typeInfo)
Creates a CSV deserialization schema for the given
TypeInformation with optional
parameters. |
Modifier and Type | Method and Description |
---|---|
static <T> TypeInformation<T> |
JsonRowSchemaConverter.convert(String jsonSchema)
Converts a JSON schema into Flink's type information.
|
TypeInformation<RowData> |
JsonRowDataDeserializationSchema.getProducedType() |
TypeInformation<Row> |
JsonRowDeserializationSchema.getProducedType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonRowSerializationSchema.Builder |
JsonRowSerializationSchema.Builder.withTypeInfo(TypeInformation<Row> typeInfo)
Sets type information for JSON serialization schema.
|
Constructor and Description |
---|
Builder(TypeInformation<Row> typeInfo)
Deprecated.
Use
JsonRowSerializationSchema.builder() instead. |
Builder(TypeInformation<Row> typeInfo)
Creates a JSON deserialization schema for the given type information.
|
JsonRowDataDeserializationSchema(RowType rowType,
TypeInformation<RowData> resultTypeInfo,
boolean failOnMissingField,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
JsonRowDeserializationSchema(TypeInformation<Row> typeInfo)
Deprecated.
Use the provided
JsonRowDeserializationSchema.Builder instead. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
CanalJsonDeserializationSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.builder(DataType physicalDataType,
List<org.apache.flink.formats.json.canal.CanalJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo)
Creates A builder for building a
CanalJsonDeserializationSchema . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
DebeziumJsonDeserializationSchema.getProducedType() |
Constructor and Description |
---|
DebeziumJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.debezium.DebeziumJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean schemaInclude,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
GlueSchemaRegistryJsonDeserializationSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
MaxwellJsonDeserializationSchema.getProducedType() |
Constructor and Description |
---|
MaxwellJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.maxwell.MaxwellJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
OggJsonDeserializationSchema.getProducedType() |
Constructor and Description |
---|
OggJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.ogg.OggJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
ParquetColumnarRowInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <SplitT extends FileSourceSplit> |
ParquetColumnarRowInputFormat.createPartitionedFormat(Configuration hadoopConfig,
RowType producedRowType,
TypeInformation<RowData> producedTypeInfo,
List<String> partitionKeys,
PartitionFieldExtractor<SplitT> extractor,
int batchSize,
boolean isUtcTimestamp,
boolean isCaseSensitive)
Create a partitioned
ParquetColumnarRowInputFormat , the partition columns can be
generated by Path . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
RawFormatDeserializationSchema.getProducedType() |
Constructor and Description |
---|
RawFormatDeserializationSchema(LogicalType deserializedType,
TypeInformation<RowData> producedTypeInfo,
String charsetName,
boolean isBigEndian) |
Modifier and Type | Method and Description |
---|---|
<T> DataSet<T> |
Graph.groupReduceOnEdges(EdgesFunction<K,EV,T> edgesFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.
|
<T> DataSet<T> |
Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue<K,VV,EV,T> edgesFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.
|
<T> DataSet<T> |
Graph.groupReduceOnNeighbors(NeighborsFunction<K,VV,EV,T> neighborsFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.
|
<T> DataSet<T> |
Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue<K,VV,EV,T> neighborsFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.
|
<NV> Graph<K,VV,NV> |
Graph.mapEdges(MapFunction<Edge<K,EV>,NV> mapper,
TypeInformation<Edge<K,NV>> returnType)
Apply a function to the attribute of each edge in the graph.
|
<NV> Graph<K,NV,EV> |
Graph.mapVertices(MapFunction<Vertex<K,VV>,NV> mapper,
TypeInformation<Vertex<K,NV>> returnType)
Apply a function to the attribute of each vertex in the graph.
|
Modifier and Type | Class and Description |
---|---|
static class |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo
A
TypeInformation for the LongValueWithProperHashCode type. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
Modifier and Type | Method and Description |
---|---|
Map<String,TypeInformation<?>> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo.getGenericParameters() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<VV> |
LabelPropagation.SendNewLabelToNeighbors.getProducedType() |
TypeInformation<VV> |
ConnectedComponents.CCMessenger.getProducedType() |
Constructor and Description |
---|
CCMessenger(TypeInformation<VV> typeInformation) |
SendNewLabelToNeighbors(TypeInformation<VV> typeInformation) |
Modifier and Type | Class and Description |
---|---|
class |
ValueArrayTypeInfo<T>
A
TypeInformation for the ValueArray type. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<ValueArray<T>> |
ValueArrayTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
Modifier and Type | Method and Description |
---|---|
Map<String,TypeInformation<?>> |
ValueArrayTypeInfo.getGenericParameters() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<ValueArray<T>> |
ValueArrayTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
Constructor and Description |
---|
ValueArrayTypeInfo(TypeInformation<T> valueType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<O> |
GraphUtils.MapTo.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple2<KEYOUT,VALUEOUT>> |
HadoopReduceFunction.getProducedType() |
TypeInformation<Tuple2<KEYOUT,VALUEOUT>> |
HadoopMapFunction.getProducedType() |
TypeInformation<Tuple2<KEYOUT,VALUEOUT>> |
HadoopReduceCombineFunction.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
HCatInputFormatBase.getProducedType() |
Constructor and Description |
---|
NoOpBinaryUdfOp(TypeInformation<OUT> type) |
Modifier and Type | Method and Description |
---|---|
abstract TypeInformation<T> |
AbstractOrcFileInputFormat.getProducedType()
Gets the type produced by this format.
|
TypeInformation<RowData> |
OrcColumnarRowInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <SplitT extends FileSourceSplit> |
OrcColumnarRowInputFormat.createPartitionedFormat(OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> shim,
Configuration hadoopConfig,
RowType tableType,
List<String> partitionKeys,
PartitionFieldExtractor<SplitT> extractor,
int[] selectedFields,
List<OrcFilters.Predicate> conjunctPredicates,
int batchSize,
java.util.function.Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory)
Create a partitioned
OrcColumnarRowInputFormat , the partition columns can be
generated by split. |
Constructor and Description |
---|
OrcColumnarRowFileInputFormat(OrcShim shim,
Configuration hadoopConfig,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List conjunctPredicates,
int batchSize,
ColumnBatchFactory batchFactory,
TypeInformation producedTypeInfo)
Deprecated.
|
OrcColumnarRowInputFormat(OrcShim<BatchT> shim,
Configuration hadoopConfig,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<OrcFilters.Predicate> conjunctPredicates,
int batchSize,
ColumnBatchFactory<BatchT,SplitT> batchFactory,
TypeInformation<RowData> producedTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static <SplitT extends FileSourceSplit> |
OrcNoHiveColumnarRowInputFormat.createPartitionedFormat(Configuration hadoopConfig,
RowType tableType,
List<String> partitionKeys,
PartitionFieldExtractor<SplitT> extractor,
int[] selectedFields,
List<OrcFilters.Predicate> conjunctPredicates,
int batchSize,
java.util.function.Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory)
Create a partitioned
OrcColumnarRowInputFormat , the partition columns can be
generated by split. |
Modifier and Type | Class and Description |
---|---|
class |
VoidNamespaceTypeInfo
|
Modifier and Type | Method and Description |
---|---|
<K,S extends State,V> |
QueryableStateClient.getKvState(JobID jobId,
String queryableStateName,
K key,
TypeInformation<K> keyTypeInfo,
StateDescriptor<S,V> stateDescriptor)
Returns a future holding the request result.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
StreamSQLTestProgram.Generator.getProducedType() |
TypeInformation |
StreamSQLTestProgram.KillMapper.getProducedType() |
TypeInformation<Row> |
StreamSQLTestProgram.GeneratorTableSource.getReturnType() |
Modifier and Type | Method and Description |
---|---|
<ACC,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType)
Applies the given aggregation function to each window.
|
<ACC,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType)
Applies the given aggregation function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<K,T,ACC,R> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<R> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
WindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<ACC> accType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<K,T,ACC,R,OUT> |
EvictingWindowSavepointReader.aggregate(String uid,
AggregateFunction<T,ACC,R> aggregateFunction,
WindowReaderFunction<R,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> inputType,
TypeInformation<OUT> outputType)
Reads window state generated using an
AggregateFunction . |
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<K> KeyedOperatorTransformation<K,T> |
OneInputOperatorTransformation.keyBy(KeySelector<T,K> keySelector,
TypeInformation<K> keyType)
Deprecated.
It creates a new
KeyedOperatorTransformation that uses the provided key with explicit
type information for partitioning its operator states. |
<K> KeyedStateTransformation<K,T> |
OneInputStateTransformation.keyBy(KeySelector<T,K> keySelector,
TypeInformation<K> keyType)
It creates a new
KeyedOperatorTransformation that uses the provided key with explicit
type information for partitioning its operator states. |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataSource<OUT> |
WindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataSource<OUT> |
WindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,T,OUT> DataSource<OUT> |
WindowReader.process(String uid,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> stateType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated without any preaggregation such as
WindowedStream#apply
and WindowedStream#process . |
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo)
Deprecated.
Read operator
BroadcastState from a Savepoint . |
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo)
Deprecated.
Read operator
BroadcastState from a Savepoint . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo)
Read operator
BroadcastState from a Savepoint . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo)
Read operator
BroadcastState from a Savepoint . |
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,OUT> DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Deprecated.
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Deprecated.
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataStream<OUT> |
SavepointReader.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataStream<OUT> |
SavepointReader.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Read keyed state from an operator in a
Savepoint . |
<T> DataSource<T> |
ExistingSavepoint.readListState(String uid,
String name,
TypeInformation<T> typeInfo)
Deprecated.
Read operator
ListState from a Savepoint . |
<T> DataStream<T> |
SavepointReader.readListState(String uid,
String name,
TypeInformation<T> typeInfo)
Read operator
ListState from a Savepoint . |
<T> DataSource<T> |
ExistingSavepoint.readListState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Deprecated.
Read operator
ListState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataStream<T> |
SavepointReader.readListState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
ListState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataSource<T> |
ExistingSavepoint.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo)
Deprecated.
Read operator
UnionState from a Savepoint . |
<T> DataStream<T> |
SavepointReader.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo)
Read operator
UnionState from a Savepoint . |
<T> DataSource<T> |
ExistingSavepoint.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Deprecated.
Read operator
UnionState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataStream<T> |
SavepointReader.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
UnionState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T,K> DataSet<T> |
EvictingWindowReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<T,K> DataSet<T> |
EvictingWindowReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<T,K> DataStream<T> |
WindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Reads window state generated using a
ReduceFunction . |
<T,K> DataStream<T> |
WindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Reads window state generated using a
ReduceFunction . |
<T,K> DataStream<T> |
EvictingWindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Reads window state generated using a
ReduceFunction . |
<T,K> DataStream<T> |
EvictingWindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Reads window state generated using a
ReduceFunction . |
<T,K> DataSource<T> |
WindowReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<T,K> DataSource<T> |
WindowReader.reduce(String uid,
ReduceFunction<T> function,
TypeInformation<K> keyType,
TypeInformation<T> reduceType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSet<OUT> |
EvictingWindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
WindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataStream<OUT> |
EvictingWindowSavepointReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSource<OUT> |
WindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSource<OUT> |
WindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
<K,T,OUT> DataSource<OUT> |
WindowReader.reduce(String uid,
ReduceFunction<T> function,
WindowReaderFunction<T,OUT,K,W> readerFunction,
TypeInformation<K> keyType,
TypeInformation<T> reduceType,
TypeInformation<OUT> outputType)
Deprecated.
Reads window state generated using a
ReduceFunction . |
Modifier and Type | Method and Description |
---|---|
static <OUT> DataStreamSource<OUT> |
SourceBuilder.fromFormat(StreamExecutionEnvironment env,
InputFormat<OUT,?> inputFormat,
TypeInformation<OUT> typeInfo)
Creates a new source that is bounded.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<KEY> |
StateReaderOperator.getKeyType() |
Modifier and Type | Method and Description |
---|---|
static <KEY,T,ACC,R,OUT,W extends Window> |
WindowReaderOperator.aggregate(AggregateFunction<T,ACC,R> function,
WindowReaderFunction<R,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<ACC> accumulatorType) |
static <KEY,T,ACC,R,OUT,W extends Window> |
WindowReaderOperator.aggregate(AggregateFunction<T,ACC,R> function,
WindowReaderFunction<R,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<ACC> accumulatorType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.evictingWindow(WindowReaderFunction<StreamRecord<T>,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType,
ExecutionConfig config) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.evictingWindow(WindowReaderFunction<StreamRecord<T>,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType,
ExecutionConfig config) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.process(WindowReaderFunction<T,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.process(WindowReaderFunction<T,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.reduce(ReduceFunction<T> function,
WindowReaderFunction<T,OUT,KEY,W> reader,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> inputType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.reduce(ReduceFunction<T> function,
WindowReaderFunction<T,OUT,KEY,W> reader,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> inputType) |
Constructor and Description |
---|
KeyedStateReaderOperator(KeyedStateReaderFunction<KEY,OUT> function,
TypeInformation<KEY> keyType) |
StateReaderOperator(F function,
TypeInformation<KEY> keyType,
TypeSerializer<N> namespaceSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
CommittableMessageTypeInfo<CommT>
The type information for the
CommittableMessage to make it consumable from a DataStream . |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<CommittableMessage<Void>> |
CommittableMessageTypeInfo.noOutput()
Returns the type information for a
CommittableMessage with no committable. |
static <CommT> TypeInformation<CommittableMessage<CommT>> |
CommittableMessageTypeInfo.of(SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializerFactory)
Returns the type information based on the serializer for a
CommittableMessage . |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?>[] |
StreamProjection.extractFieldTypes(int[] fields,
TypeInformation<?> inType) |
TypeInformation<T> |
AllWindowedStream.getInputType() |
TypeInformation<T> |
WindowedStream.getInputType() |
TypeInformation<KEY> |
KeyedStream.getKeyType()
Gets the type of the key by which the stream is partitioned.
|
TypeInformation<T> |
BroadcastStream.getType() |
TypeInformation<T> |
DataStream.getType()
Gets the type of the stream.
|
TypeInformation<IN1> |
BroadcastConnectedStream.getType1()
Gets the type of the first input.
|
TypeInformation<IN1> |
ConnectedStreams.getType1()
Gets the type of the first input.
|
TypeInformation<IN2> |
BroadcastConnectedStream.getType2()
Gets the type of the second input.
|
TypeInformation<IN2> |
ConnectedStreams.getType2()
Gets the type of the second input.
|
Modifier and Type | Method and Description |
---|---|
<ACC,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given
AggregateFunction to each window. |
<ACC,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given
AggregateFunction to each window. |
<ACC,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given aggregation function to each window.
|
<ACC,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given aggregation function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
AllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
AllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessAllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessAllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessAllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,V,R> SingleOutputStreamOperator<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<T> DataStream<T> |
CoGroupedStreams.WithWindow.apply(CoGroupFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Completes the co-group operation with the user function that is executed for windowed
groups.
|
<T> DataStream<T> |
JoinedStreams.WithWindow.apply(FlatJoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Completes the join operation with the user function that is executed for each combination
of elements with the same key in a window.
|
<T> DataStream<T> |
JoinedStreams.WithWindow.apply(JoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Completes the join operation with the user function that is executed for each combination
of elements with the same key in a window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> reduceFunction,
AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Deprecated.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Deprecated.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
protected <R> SingleOutputStreamOperator<R> |
KeyedStream.doTransform(String operatorName,
TypeInformation<R> outTypeInfo,
StreamOperatorFactory<R> operatorFactory) |
protected <R> SingleOutputStreamOperator<R> |
DataStream.doTransform(String operatorName,
TypeInformation<R> outTypeInfo,
StreamOperatorFactory<R> operatorFactory) |
CoGroupedStreams.Where.EqualTo |
CoGroupedStreams.Where.equalTo(KeySelector<T2,KEY> keySelector,
TypeInformation<KEY> keyType)
Specifies a
KeySelector for elements from the second input with explicit type
information for the key type. |
JoinedStreams.Where.EqualTo |
JoinedStreams.Where.equalTo(KeySelector<T2,KEY> keySelector,
TypeInformation<KEY> keyType)
Specifies a
KeySelector for elements from the second input with explicit type
information for the key type. |
static TypeInformation<?>[] |
StreamProjection.extractFieldTypes(int[] fields,
TypeInformation<?> inType) |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.flatMap(CoFlatMapFunction<IN1,IN2,R> coFlatMapper,
TypeInformation<R> outputType)
Applies a CoFlatMap transformation on a
ConnectedStreams and maps the output to a
common type. |
<R> SingleOutputStreamOperator<R> |
DataStream.flatMap(FlatMapFunction<T,R> flatMapper,
TypeInformation<R> outputType)
Applies a FlatMap transformation on a
DataStream . |
<KEY> ConnectedStreams<I,F> |
IterativeStream.ConnectedIterativeStreams.keyBy(KeySelector<I,KEY> keySelector1,
KeySelector<F,KEY> keySelector2,
TypeInformation<KEY> keyType) |
<KEY> ConnectedStreams<IN1,IN2> |
ConnectedStreams.keyBy(KeySelector<IN1,KEY> keySelector1,
KeySelector<IN2,KEY> keySelector2,
TypeInformation<KEY> keyType)
KeyBy operation for connected data stream.
|
<K> KeyedStream<T,K> |
DataStream.keyBy(KeySelector<T,K> key,
TypeInformation<K> keyType)
It creates a new
KeyedStream that uses the provided key with explicit type
information for partitioning its operator states. |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.map(CoMapFunction<IN1,IN2,R> coMapper,
TypeInformation<R> outputType)
Applies a CoMap transformation on a
ConnectedStreams and maps the output to a common
type. |
<R> SingleOutputStreamOperator<R> |
DataStream.map(MapFunction<T,R> mapper,
TypeInformation<R> outputType)
Applies a Map transformation on a
DataStream . |
<OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(BroadcastProcessFunction<IN1,IN2,OUT> function,
TypeInformation<OUT> outTypeInfo)
Assumes as inputs a
BroadcastStream and a non-keyed DataStream and applies
the given BroadcastProcessFunction on them, thereby creating a transformed output
stream. |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.process(CoProcessFunction<IN1,IN2,R> coProcessFunction,
TypeInformation<R> outputType)
Applies the given
CoProcessFunction on the connected input streams, thereby creating
a transformed output stream. |
<KEY,OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> function,
TypeInformation<OUT> outTypeInfo)
Assumes as inputs a
BroadcastStream and a KeyedStream and applies the given
KeyedBroadcastProcessFunction on them, thereby creating a transformed output stream. |
<K,R> SingleOutputStreamOperator<R> |
ConnectedStreams.process(KeyedCoProcessFunction<K,IN1,IN2,R> keyedCoProcessFunction,
TypeInformation<R> outputType)
Applies the given
KeyedCoProcessFunction on the connected input streams, thereby
creating a transformed output stream. |
<R> SingleOutputStreamOperator<R> |
KeyedStream.process(KeyedProcessFunction<KEY,T,R> keyedProcessFunction,
TypeInformation<R> outputType)
Applies the given
KeyedProcessFunction on the input stream, thereby creating a
transformed output stream. |
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.process(ProcessAllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
KeyedStream.process(ProcessFunction<T,R> processFunction,
TypeInformation<R> outputType)
Deprecated.
|
<R> SingleOutputStreamOperator<R> |
DataStream.process(ProcessFunction<T,R> processFunction,
TypeInformation<R> outputType)
Applies the given
ProcessFunction on the input stream, thereby creating a transformed
output stream. |
<OUT> SingleOutputStreamOperator<OUT> |
KeyedStream.IntervalJoined.process(ProcessJoinFunction<IN1,IN2,OUT> processJoinFunction,
TypeInformation<OUT> outputType)
Completes the join operation with the given user function that is executed for each
joined pair of elements.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.process(ProcessWindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.reduce(ReduceFunction<T> reduceFunction,
AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.reduce(ReduceFunction<T> reduceFunction,
ProcessAllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.reduce(ReduceFunction<T> reduceFunction,
ProcessWindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.reduce(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
static <T,K> KeyedStream<T,K> |
DataStreamUtils.reinterpretAsKeyedStream(DataStream<T> stream,
KeySelector<T,K> keySelector,
TypeInformation<K> typeInfo)
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(TypeInformation<T> typeInfo)
Adds a type information hint about the return type of this operator.
|
<R> SingleOutputStreamOperator<R> |
DataStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T,R> operator)
Method for passing user defined operators along with the type information that will transform
the DataStream.
|
<R> SingleOutputStreamOperator<R> |
DataStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperatorFactory<T,R> operatorFactory)
Method for passing user defined operators created by the given factory along with the type
information that will transform the DataStream.
|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.transform(String functionName,
TypeInformation<R> outTypeInfo,
TwoInputStreamOperator<IN1,IN2,R> operator) |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.transform(String functionName,
TypeInformation<R> outTypeInfo,
TwoInputStreamOperatorFactory<IN1,IN2,R> operatorFactory) |
<KEY> CoGroupedStreams.Where<KEY> |
CoGroupedStreams.where(KeySelector<T1,KEY> keySelector,
TypeInformation<KEY> keyType)
Specifies a
KeySelector for elements from the first input with explicit type
information. |
<KEY> JoinedStreams.Where<KEY> |
JoinedStreams.where(KeySelector<T1,KEY> keySelector,
TypeInformation<KEY> keyType)
Specifies a
KeySelector for elements from the first input with explicit type
information for the key type. |
<T> SingleOutputStreamOperator<T> |
CoGroupedStreams.WithWindow.with(CoGroupFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Deprecated.
This method will be removed once the
CoGroupedStreams.WithWindow.apply(CoGroupFunction,
TypeInformation) method is fixed in the next major version of Flink (2.0). |
<T> SingleOutputStreamOperator<T> |
JoinedStreams.WithWindow.with(FlatJoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Deprecated.
This method will be replaced by
JoinedStreams.WithWindow.apply(FlatJoinFunction,
TypeInformation) in Flink 2.0. So use the JoinedStreams.WithWindow.apply(FlatJoinFunction,
TypeInformation) in the future. |
<T> SingleOutputStreamOperator<T> |
JoinedStreams.WithWindow.with(JoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Deprecated.
This method will be removed once the
JoinedStreams.WithWindow.apply(JoinFunction,
TypeInformation) method is fixed in the next major version of Flink (2.0). |
<F> IterativeStream.ConnectedIterativeStreams<T,F> |
IterativeStream.withFeedbackType(TypeInformation<F> feedbackType)
Changes the feedback type of the iteration and allows the user to apply co-transformations on
the input and feedback stream, as in a
ConnectedStreams . |
Constructor and Description |
---|
ConnectedIterativeStreams(DataStream<I> input,
TypeInformation<F> feedbackType,
long waitTime) |
DataStreamSource(StreamExecutionEnvironment environment,
Source<T,?,?> source,
WatermarkStrategy<T> watermarkStrategy,
TypeInformation<T> outTypeInfo,
String sourceName)
Constructor for new Sources (FLIP-27).
|
DataStreamSource(StreamExecutionEnvironment environment,
TypeInformation<T> outTypeInfo,
StreamSource<T,?> operator,
boolean isParallel,
String sourceName) |
DataStreamSource(StreamExecutionEnvironment environment,
TypeInformation<T> outTypeInfo,
StreamSource<T,?> operator,
boolean isParallel,
String sourceName,
Boundedness boundedness)
The constructor used to create legacy sources.
|
KeyedStream(DataStream<T> dataStream,
KeySelector<T,KEY> keySelector,
TypeInformation<KEY> keyType)
Creates a new
KeyedStream using the given KeySelector to partition operator
state by key. |
WithWindow(DataStream<T1> input1,
DataStream<T2> input2,
KeySelector<T1,KEY> keySelector1,
KeySelector<T2,KEY> keySelector2,
TypeInformation<KEY> keyType,
WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner,
Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger,
Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor,
Time allowedLateness) |
WithWindow(DataStream<T1> input1,
DataStream<T2> input2,
KeySelector<T1,KEY> keySelector1,
KeySelector<T2,KEY> keySelector2,
TypeInformation<KEY> keyType,
WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner,
Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger,
Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor,
Time allowedLateness) |
Modifier and Type | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function,
String sourceName,
TypeInformation<OUT> typeInfo)
Ads a data source with a custom type information thus opening a
DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function,
TypeInformation<OUT> typeInfo)
Ads a data source with a custom type information thus opening a
DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.createInput(InputFormat<OUT,?> inputFormat,
TypeInformation<OUT> typeInfo)
Generic method to create an input data stream with
InputFormat . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromCollection(Collection<OUT> data,
TypeInformation<OUT> typeInfo)
Creates a data stream from the given non-empty collection.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromCollection(Iterator<OUT> data,
TypeInformation<OUT> typeInfo)
Creates a data stream from the given iterator.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<OUT> iterator,
TypeInformation<OUT> typeInfo)
Creates a new data stream that contains elements in the iterator.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source,
WatermarkStrategy<OUT> timestampsAndWatermarks,
String sourceName,
TypeInformation<OUT> typeInfo)
Adds a data
Source to the environment to get a DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
TypeInformation<OUT> typeInformation)
Reads the contents of the user-specified
filePath based on the given FileInputFormat . |
Constructor and Description |
---|
ComparableAggregator(int positionToAggregate,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
boolean first,
ExecutionConfig config) |
ComparableAggregator(int positionToAggregate,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
ExecutionConfig config) |
ComparableAggregator(String field,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
boolean first,
ExecutionConfig config) |
SumAggregator(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
SumAggregator(String field,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
OutputFormatSinkFunction.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.setOutputType(TypeInformation<OUT> outTypeInfo,
ExecutionConfig executionConfig) |
void |
ContinuousFileReaderOperatorFactory.setOutputType(TypeInformation<OUT> type,
ExecutionConfig executionConfig) |
void |
FromElementsFunction.setOutputType(TypeInformation<T> outTypeInfo,
ExecutionConfig executionConfig)
Set element type and re-serialize element if required.
|
Constructor and Description |
---|
ContinuousFileReaderOperatorFactory(InputFormat<OUT,? super T> inputFormat,
TypeInformation<OUT> type,
ExecutionConfig executionConfig) |
InputFormatSourceFunction(InputFormat<OUT,?> format,
TypeInformation<OUT> typeInfo) |
MessageAcknowledgingSourceBase(TypeInformation<UId> idTypeInfo)
Creates a new MessageAcknowledgingSourceBase for IDs of the given type.
|
MultipleIdsMessageAcknowledgingSourceBase(TypeInformation<UId> idTypeInfo)
Creates a new MessageAcknowledgingSourceBase for IDs of the given type.
|
Modifier and Type | Method and Description |
---|---|
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> taskOperatorFactory,
TypeInformation<IN1> in1TypeInfo,
TypeInformation<IN2> in2TypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> taskOperatorFactory,
TypeInformation<IN1> in1TypeInfo,
TypeInformation<IN2> in2TypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> taskOperatorFactory,
TypeInformation<IN1> in1TypeInfo,
TypeInformation<IN2> in2TypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addLegacySource(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addLegacySource(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<OUT> void |
StreamGraph.addMultipleInputOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
List<TypeInformation<?>> inTypeInfos,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSink(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSink(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSource(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
SourceOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSource(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
SourceOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
Modifier and Type | Method and Description |
---|---|
<OUT> void |
StreamGraph.addMultipleInputOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
List<TypeInformation<?>> inTypeInfos,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<IN> |
AbstractOneInputPythonFunctionOperator.getInputTypeInfo() |
protected TypeInformation<IN1> |
AbstractTwoInputPythonFunctionOperator.getLeftInputType() |
TypeInformation<OUT> |
AbstractDataStreamPythonFunctionOperator.getProducedType() |
protected TypeInformation<IN2> |
AbstractTwoInputPythonFunctionOperator.getRightInputType() |
Modifier and Type | Method and Description |
---|---|
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
abstract <T> AbstractDataStreamPythonFunctionOperator<T> |
AbstractDataStreamPythonFunctionOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
RunnerOutputCollector.getRunnerOutputTypeInfo(TypeInformation<?> elementDataTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
RunnerOutputCollector.getRunnerOutputTypeInfo(TypeInformation<?> elementDataTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
TimerUtils.createTimerDataTypeInfo(TypeInformation<Row> keyType) |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
TimerUtils.createTimerDataCoderInfoDescriptorProto(TypeInformation<Row> timerDataType) |
static TypeInformation<Row> |
TimerUtils.createTimerDataTypeInfo(TypeInformation<Row> keyType) |
Modifier and Type | Field and Description |
---|---|
protected TypeInformation<?> |
KeyedMultipleInputTransformation.stateKeyType |
Modifier and Type | Method and Description |
---|---|
TypeInformation<IN> |
OneInputTransformation.getInputType()
Returns the
TypeInformation for the elements of the input. |
TypeInformation<IN> |
ReduceTransformation.getInputType()
Returns the
TypeInformation for the elements of the input. |
TypeInformation<IN> |
TimestampsAndWatermarksTransformation.getInputType()
Returns the
TypeInformation for the elements of the input. |
TypeInformation<IN1> |
TwoInputTransformation.getInputType1()
Returns the
TypeInformation for the elements from the first input. |
TypeInformation<IN2> |
TwoInputTransformation.getInputType2()
Returns the
TypeInformation for the elements from the second input. |
TypeInformation<K> |
ReduceTransformation.getKeyTypeInfo() |
TypeInformation<?> |
KeyedMultipleInputTransformation.getStateKeyType() |
TypeInformation<?> |
LegacySinkTransformation.getStateKeyType() |
TypeInformation<?> |
OneInputTransformation.getStateKeyType() |
TypeInformation<KEY> |
KeyedBroadcastStateTransformation.getStateKeyType() |
TypeInformation<?> |
TwoInputTransformation.getStateKeyType() |
Modifier and Type | Method and Description |
---|---|
List<TypeInformation<?>> |
AbstractMultipleInputTransformation.getInputTypes()
Returns the
TypeInformation for the elements from the inputs. |
Modifier and Type | Method and Description |
---|---|
void |
LegacySinkTransformation.setStateKeyType(TypeInformation<?> stateKeyType) |
void |
OneInputTransformation.setStateKeyType(TypeInformation<?> stateKeyType) |
void |
TwoInputTransformation.setStateKeyType(TypeInformation<?> stateKeyType) |
Constructor and Description |
---|
AbstractBroadcastStateTransformation(String name,
Transformation<IN1> regularInput,
Transformation<IN2> broadcastInput,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
AbstractMultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
BroadcastStateTransformation(String name,
Transformation<IN1> inputStream,
Transformation<IN2> broadcastStream,
BroadcastProcessFunction<IN1,IN2,OUT> userFunction,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
CoFeedbackTransformation(int parallelism,
TypeInformation<F> feedbackType,
Long waitTime)
Creates a new
CoFeedbackTransformation from the given input. |
KeyedBroadcastStateTransformation(String name,
Transformation<IN1> inputStream,
Transformation<IN2> broadcastStream,
KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> userFunction,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<KEY> keyType,
KeySelector<IN1,KEY> keySelector,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
KeyedBroadcastStateTransformation(String name,
Transformation<IN1> inputStream,
Transformation<IN2> broadcastStream,
KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> userFunction,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<KEY> keyType,
KeySelector<IN1,KEY> keySelector,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
KeyedMultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism,
TypeInformation<?> stateKeyType) |
KeyedMultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism,
TypeInformation<?> stateKeyType) |
LegacySourceTransformation(String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
Boundedness boundedness) |
LegacySourceTransformation(String name,
StreamSource<T,?> operator,
TypeInformation<T> outputType,
int parallelism,
Boundedness boundedness)
Creates a new
LegacySourceTransformation from the given operator. |
MultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
OneInputTransformation(Transformation<IN> input,
String name,
OneInputStreamOperator<IN,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
OneInputTransformation from the given input and operator. |
OneInputTransformation(Transformation<IN> input,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
ReduceTransformation(String name,
int parallelism,
Transformation<IN> input,
ReduceFunction<IN> reducer,
KeySelector<IN,K> keySelector,
TypeInformation<K> keyTypeInfo) |
SinkTransformation(DataStream<InputT> inputStream,
Sink<InputT> sink,
TypeInformation<OutputT> outputType,
String name,
int parallelism,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
SourceTransformation(String name,
Source<OUT,SplitT,EnumChkT> source,
WatermarkStrategy<OUT> watermarkStrategy,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
Transformation with the given name, output type and parallelism. |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
TwoInputStreamOperator<IN1,IN2,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
Modifier and Type | Class and Description |
---|---|
class |
PickledByteArrayTypeInfo
A PickledByteArrayTypeInfo indicates that the data of this type is a generated primitive byte
array by pickle.
|
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
ProtoUtils.createRawTypeCoderInfoDescriptorProto(TypeInformation<?> typeInformation,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage) |
static List<FlinkFnApi.UserDefinedDataStreamFunction> |
ProtoUtils.createUserDefinedDataStreamStatefulFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation<?> keyTypeInfo,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static FlinkFnApi.TypeInfo |
PythonTypeUtils.TypeInfoToProtoConverter.toTypeInfoProto(TypeInformation<?> typeInformation) |
static <T> TypeSerializer<T> |
PythonTypeUtils.TypeInfoToSerializerConverter.typeInfoSerializerConverter(TypeInformation<T> typeInformation) |
Modifier and Type | Method and Description |
---|---|
<S extends Serializable> |
Trigger.TriggerContext.getKeyValueState(String name,
TypeInformation<S> stateType,
S defaultState)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected TypeInformation<IN> |
CassandraSink.CassandraSinkBuilder.typeInfo |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?>[] |
CassandraAppendTableSink.getFieldTypes() |
TypeInformation<Row> |
CassandraAppendTableSink.getOutputType() |
Modifier and Type | Method and Description |
---|---|
CassandraAppendTableSink |
CassandraAppendTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
Constructor and Description |
---|
CassandraPojoSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraRowSinkBuilder(DataStream<Row> input,
TypeInformation<Row> typeInfo,
TypeSerializer<Row> serializer) |
CassandraScalaProductSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraTupleSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<OUT> |
PubSubSource.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
FlinkKafkaConsumerBase.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
KafkaDeserializationSchemaWrapper.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <T,K> KeyedStream<T,K> |
FlinkKafkaShuffle.readKeyBy(String topic,
StreamExecutionEnvironment env,
TypeInformation<T> typeInformation,
Properties kafkaProperties,
KeySelector<T,K> keySelector)
|
Modifier and Type | Method and Description |
---|---|
protected KafkaSource<RowData> |
KafkaDynamicSource.createKafkaSource(DeserializationSchema<RowData> keyDeserialization,
DeserializationSchema<RowData> valueDeserialization,
TypeInformation<RowData> producedTypeInfo) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
FlinkKinesisConsumer.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
KinesisDeserializationSchemaWrapper.getProducedType() |
TypeInformation<com.amazonaws.services.dynamodbv2.model.Record> |
DynamoDBStreamsSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
RowDataKinesisDeserializationSchema.getProducedType() |
Constructor and Description |
---|
RowDataKinesisDeserializationSchema(DeserializationSchema<RowData> physicalDeserializer,
TypeInformation<RowData> producedTypeInfo,
List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<OUT> |
RMQSource.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Event> |
EventDeSerializationSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<KafkaEvent> |
KafkaEventSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
<ACC,V,R> WindowOperator<K,T,?,R,W> |
WindowOperatorBuilder.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType) |
<ACC,V,R> WindowOperator<K,T,?,R,W> |
WindowOperatorBuilder.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType) |
<S extends Serializable> |
WindowOperator.Context.getKeyValueState(String name,
TypeInformation<S> stateType,
S defaultState) |
Constructor and Description |
---|
WindowOperatorBuilder(WindowAssigner<? super T,W> windowAssigner,
Trigger<? super T,? super W> trigger,
ExecutionConfig config,
TypeInformation<T> inputType,
KeySelector<T,K> keySelector,
TypeInformation<K> keyType) |
WindowOperatorBuilder(WindowAssigner<? super T,W> windowAssigner,
Trigger<? super T,? super W> trigger,
ExecutionConfig config,
TypeInformation<T> inputType,
KeySelector<T,K> keySelector,
TypeInformation<K> keyType) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Integer> |
AbstractTwoInputTransformationTranslator.translateInternal(Transformation<OUT> transformation,
Transformation<IN1> firstInputTransformation,
Transformation<IN2> secondInputTransformation,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<?> keyTypeInfo,
KeySelector<IN1,?> firstKeySelector,
KeySelector<IN2,?> secondKeySelector,
TransformationTranslator.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
SingleThreadAccessCheckingTypeInfo<T>
Custom
TypeInformation to test custom TypeSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple> |
PeriodicStreamingJob.PeriodicSourceGenerator.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <T> void |
StreamingFunctionUtils.setOutputType(Function userFunction,
TypeInformation<T> outTypeInfo,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple> |
KeySelectorUtil.ComparableKeySelector.getProducedType() |
TypeInformation<Tuple> |
KeySelectorUtil.ArrayKeySelector.getProducedType() |
Modifier and Type | Method and Description |
---|---|
static <X> KeySelectorUtil.ArrayKeySelector<X> |
KeySelectorUtil.getSelectorForArray(int[] positions,
TypeInformation<X> typeInfo) |
static <X> KeySelector<X,Tuple> |
KeySelectorUtil.getSelectorForKeys(Keys<X> keys,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
static <X,K> KeySelector<X,K> |
KeySelectorUtil.getSelectorForOneKey(Keys<X> keys,
Partitioner<K> partitioner,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode> |
JSONKeyValueDeserializationSchema.getProducedType() |
TypeInformation<Tuple2<K,V>> |
TypeInformationKeyValueSerializationSchema.getProducedType() |
Constructor and Description |
---|
TypeInformationKeyValueSerializationSchema(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
ExecutionConfig ec)
Creates a new de-/serialization schema for the given types.
|
TypeInformationKeyValueSerializationSchema(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
ExecutionConfig ec)
Creates a new de-/serialization schema for the given types.
|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
ExecutionConfig ec)
Deprecated.
Creates a new de-/serialization schema for the given type.
|
Modifier and Type | Field and Description |
---|---|
protected TypeInformation |
FieldAccessor.fieldType |
Modifier and Type | Method and Description |
---|---|
TypeInformation<F> |
FieldAccessor.getFieldType()
Gets the TypeInformation for the type of the field.
|
Modifier and Type | Method and Description |
---|---|
<T,R,F> FieldAccessor<T,F> |
DefaultScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config) |
<T,R,F> FieldAccessor<T,F> |
ScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config)
Returns a product
FieldAccessor that does support recursion. |
<T,F> FieldAccessor<T,F> |
DefaultScalaProductFieldAccessorFactory.createSimpleProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
<T,F> FieldAccessor<T,F> |
ScalaProductFieldAccessorFactory.createSimpleProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config)
Returns a product
FieldAccessor that does not support recursion. |
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
int pos,
ExecutionConfig config)
Creates a
FieldAccessor for the given field position, which can be used to get and
set the specified field on instances of this type. |
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
String field,
ExecutionConfig config)
Creates a
FieldAccessor for the field that is given by a field expression, which can
be used to get and set the specified field on instances of this type. |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Boolean> |
Types.BOOLEAN()
Deprecated.
Returns type information for a Table API boolean or SQL BOOLEAN type.
|
static TypeInformation<Byte> |
Types.BYTE()
Deprecated.
Returns type information for a Table API byte or SQL TINYINT type.
|
static TypeInformation<BigDecimal> |
Types.DECIMAL()
Deprecated.
Returns type information for a Table API big decimal or SQL DECIMAL type.
|
static TypeInformation<Double> |
Types.DOUBLE()
Deprecated.
Returns type information for a Table API integer or SQL DOUBLE type.
|
static TypeInformation<Float> |
Types.FLOAT()
Deprecated.
Returns type information for a Table API float or SQL FLOAT/REAL type.
|
TypeInformation<?>[] |
TableSchema.getFieldTypes()
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
TableSchema.getFieldDataTypes() instead which uses the new type system
based on DataTypes . Please make sure to use either the old or the new type system
consistently to avoid unintended behavior. See the website documentation for more
information. |
static TypeInformation<Integer> |
Types.INT()
Deprecated.
Returns type information for a Table API integer or SQL INT/INTEGER type.
|
static TypeInformation<Long> |
Types.INTERVAL_MILLIS()
Deprecated.
Returns type information for a Table API interval of milliseconds.
|
static TypeInformation<Integer> |
Types.INTERVAL_MONTHS()
Deprecated.
Returns type information for a Table API interval of months.
|
static TypeInformation<java.time.LocalDateTime> |
Types.LOCAL_DATE_TIME()
Deprecated.
Returns type information for a Table API LocalDateTime type.
|
static TypeInformation<java.time.LocalDate> |
Types.LOCAL_DATE()
Deprecated.
Returns type information for a Table API LocalDate type.
|
static TypeInformation<java.time.LocalTime> |
Types.LOCAL_TIME()
Deprecated.
Returns type information for a Table API LocalTime type.
|
static TypeInformation<Long> |
Types.LONG()
Deprecated.
Returns type information for a Table API long or SQL BIGINT type.
|
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Deprecated.
Generates type information for a Java HashMap.
|
static <E> TypeInformation<Map<E,Integer>> |
Types.MULTISET(TypeInformation<E> elementType)
Deprecated.
Generates type information for a Multiset.
|
static <E> TypeInformation<E[]> |
Types.OBJECT_ARRAY(TypeInformation<E> elementType)
Deprecated.
Generates type information for an array consisting of Java object elements.
|
static TypeInformation<?> |
Types.PRIMITIVE_ARRAY(TypeInformation<?> elementType)
Deprecated.
Generates type information for an array consisting of Java primitive elements.
|
static TypeInformation<Row> |
Types.ROW(String[] fieldNames,
TypeInformation<?>[] types)
Deprecated.
Returns type information for
Row with fields of the given types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Deprecated.
Returns type information for
Row with fields of the given types. |
static TypeInformation<Short> |
Types.SHORT()
Deprecated.
Returns type information for a Table API short or SQL SMALLINT type.
|
static TypeInformation<Date> |
Types.SQL_DATE()
Deprecated.
Returns type information for a Table API SQL date or SQL DATE type.
|
static TypeInformation<Time> |
Types.SQL_TIME()
Deprecated.
Returns type information for a Table API SQL time or SQL TIME type.
|
static TypeInformation<Timestamp> |
Types.SQL_TIMESTAMP()
Deprecated.
Returns type information for a Table API SQL timestamp or SQL TIMESTAMP type.
|
static TypeInformation<String> |
Types.STRING()
Deprecated.
Returns type information for a Table API string or SQL VARCHAR type.
|
TypeInformation<Row> |
TableSchema.toRowType()
Deprecated.
Use
TableSchema.toRowDataType() instead. |
Modifier and Type | Method and Description |
---|---|
Optional<TypeInformation<?>> |
TableSchema.getFieldType(int fieldIndex)
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
TableSchema.getFieldDataType(int) instead which uses the new type
system based on DataTypes . Please make sure to use either the old or the new type
system consistently to avoid unintended behavior. See the website documentation for more
information. |
Optional<TypeInformation<?>> |
TableSchema.getFieldType(String fieldName)
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
TableSchema.getFieldDataType(String) instead which uses the new type
system based on DataTypes . Please make sure to use either the old or the new type
system consistently to avoid unintended behavior. See the website documentation for more
information. |
Modifier and Type | Method and Description |
---|---|
TableSchema.Builder |
TableSchema.Builder.field(String name,
TypeInformation<?> typeInfo)
Deprecated.
This method will be removed in future versions as it uses the old type
system. It is recommended to use
TableSchema.Builder.field(String, DataType) instead which uses
the new type system based on DataTypes . Please make sure to use either the
old or the new type system consistently to avoid unintended behavior. See the website
documentation for more information. |
static TableSchema |
TableSchema.fromTypeInfo(TypeInformation<?> typeInfo)
Deprecated.
This method will be removed soon. Use
DataTypes to declare types. |
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Deprecated.
Generates type information for a Java HashMap.
|
static <K,V> TypeInformation<Map<K,V>> |
Types.MAP(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Deprecated.
Generates type information for a Java HashMap.
|
static <E> TypeInformation<Map<E,Integer>> |
Types.MULTISET(TypeInformation<E> elementType)
Deprecated.
Generates type information for a Multiset.
|
static ApiExpression |
Expressions.nullOf(TypeInformation<?> typeInfo)
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
Expressions.nullOf(DataType) instead which uses the new type system
based on DataTypes . Please make sure to use either the old or the new type system
consistently to avoid unintended behavior. See the website documentation for more
information. |
static <E> TypeInformation<E[]> |
Types.OBJECT_ARRAY(TypeInformation<E> elementType)
Deprecated.
Generates type information for an array consisting of Java object elements.
|
static UnresolvedDataType |
DataTypes.of(TypeInformation<?> typeInfo)
Creates an unresolved type that will be resolved to a
DataType by converting the
given TypeInformation later. |
static TypeInformation<?> |
Types.PRIMITIVE_ARRAY(TypeInformation<?> elementType)
Deprecated.
Generates type information for an array consisting of Java primitive elements.
|
static <T> UnresolvedDataType |
DataTypes.RAW(TypeInformation<T> typeInformation)
Data type of an arbitrary serialized type backed by
TypeInformation . |
static TypeInformation<Row> |
Types.ROW(String[] fieldNames,
TypeInformation<?>[] types)
Deprecated.
Returns type information for
Row with fields of the given types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Deprecated.
Returns type information for
Row with fields of the given types. |
Constructor and Description |
---|
TableSchema(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
Use the
TableSchema.Builder instead. |
Modifier and Type | Method and Description |
---|---|
protected <T> TypeInformation<T> |
AbstractStreamTableEnvironmentImpl.extractTypeInformation(Table table,
Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
protected <T> DataType |
AbstractStreamTableEnvironmentImpl.wrapWithChangeFlag(TypeInformation<T> outputType) |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> typeInfo)
Deprecated.
Use
StreamTableEnvironment.toDataStream(Table, Class) instead. It integrates with the new type
system and supports all kinds of DataTypes that the table runtime can produce.
The semantics might be slightly different for raw and structured types. Use toDataStream(DataTypes.of(TypeInformation.of(Class))) if TypeInformation should
be used as source of truth. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> typeInfo)
Deprecated.
Use
StreamTableEnvironment.toChangelogStream(Table, Schema) instead. It integrates with the new
type system and supports all kinds of DataTypes and every ChangelogMode
that the table runtime can produce. |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
TypeInformation<T> typeInfo) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
TypeInformation<T> typeInfo) |
Modifier and Type | Field and Description |
---|---|
TypeInformation<?> |
ListView.elementType
Deprecated.
|
TypeInformation<?> |
MapView.keyType
Deprecated.
|
TypeInformation<?> |
MapView.valueType
Deprecated.
|
Constructor and Description |
---|
ListView(TypeInformation<?> elementType)
Deprecated.
This method uses the old type system. Please use a
DataTypeHint instead
if the reflective type extraction is not successful. |
MapView(TypeInformation<?> keyType,
TypeInformation<?> valueType)
Deprecated.
This method uses the old type system. Please use a
DataTypeHint instead
if the reflective type extraction is not successful. |
MapView(TypeInformation<?> keyType,
TypeInformation<?> valueType)
Deprecated.
This method uses the old type system. Please use a
DataTypeHint instead
if the reflective type extraction is not successful. |
Modifier and Type | Method and Description |
---|---|
OutType |
BaseExpressions.cast(TypeInformation<?> toType)
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
BaseExpressions.cast(DataType) instead which uses the new type system
based on DataTypes . Please make sure to use either the
old or the new type system consistently to avoid unintended behavior. See the website
documentation for more information. |
Modifier and Type | Method and Description |
---|---|
static SchemaTranslator.ConsumingResult |
SchemaTranslator.createConsumingResult(DataTypeFactory dataTypeFactory,
TypeInformation<?> inputTypeInfo,
Schema declaredSchema)
Converts the given
TypeInformation and an optional declared Schema (possibly
incomplete) into the final SchemaTranslator.ConsumingResult . |
<T> DataType |
DataTypeFactory.createDataType(TypeInformation<T> typeInfo)
Creates a type for the given
TypeInformation . |
<T> DataType |
DataTypeFactory.createRawDataType(TypeInformation<T> typeInfo)
Creates a RAW type for the given
TypeInformation . |
<T,ACC> void |
FunctionCatalog.registerTempSystemAggregateFunction(String name,
ImperativeAggregateFunction<T,ACC> function,
TypeInformation<T> resultType,
TypeInformation<ACC> accType)
Deprecated.
|
<T,ACC> void |
FunctionCatalog.registerTempSystemAggregateFunction(String name,
ImperativeAggregateFunction<T,ACC> function,
TypeInformation<T> resultType,
TypeInformation<ACC> accType)
Deprecated.
|
<T> void |
FunctionCatalog.registerTempSystemTableFunction(String name,
TableFunction<T> function,
TypeInformation<T> resultType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
<T> TypeInformation<T> |
DynamicTableSink.Context.createTypeInformation(DataType consumedDataType)
Creates type information describing the internal data structures of the given
DataType . |
<T> TypeInformation<T> |
DynamicTableSink.Context.createTypeInformation(LogicalType consumedLogicalType)
Creates type information describing the internal data structures of the given
LogicalType . |
Modifier and Type | Method and Description |
---|---|
<T> TypeInformation<T> |
DynamicTableSource.Context.createTypeInformation(DataType producedDataType)
Creates type information describing the internal data structures of the given
DataType . |
<T> TypeInformation<T> |
DynamicTableSource.Context.createTypeInformation(LogicalType producedLogicalType)
Creates type information describing the internal data structures of the given
LogicalType . |
Modifier and Type | Class and Description |
---|---|
class |
ListViewTypeInfo<T>
Deprecated.
|
class |
MapViewTypeInfo<K,V>
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<MapView<K,V>> |
MapViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Deprecated.
|
TypeInformation<ListView<T>> |
ListViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Deprecated.
|
TypeInformation<T> |
ListViewTypeInfo.getElementType()
Deprecated.
|
TypeInformation<K> |
MapViewTypeInfo.getKeyType()
Deprecated.
|
TypeInformation<V> |
MapViewTypeInfo.getValueType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<MapView<K,V>> |
MapViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Deprecated.
|
TypeInformation<ListView<T>> |
ListViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters)
Deprecated.
|
Constructor and Description |
---|
ListViewTypeInfo(TypeInformation<T> elementType)
Deprecated.
|
ListViewTypeInfo(TypeInformation<T> elementType,
boolean nullSerializer)
Deprecated.
|
MapViewTypeInfo(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Deprecated.
|
MapViewTypeInfo(TypeInformation<K> keyType,
TypeInformation<V> valueType)
Deprecated.
|
MapViewTypeInfo(TypeInformation<K> keyType,
TypeInformation<V> valueType,
boolean nullSerializer,
boolean nullAware)
Deprecated.
|
MapViewTypeInfo(TypeInformation<K> keyType,
TypeInformation<V> valueType,
boolean nullSerializer,
boolean nullAware)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
DescriptorProperties.getType(String key)
Deprecated.
Returns the type information under the given existing key.
|
Modifier and Type | Method and Description |
---|---|
Optional<TypeInformation<?>> |
DescriptorProperties.getOptionalType(String key)
Deprecated.
Returns the type information under the given key if it exists.
|
Modifier and Type | Method and Description |
---|---|
Schema |
Schema.field(String fieldName,
TypeInformation<?> fieldType)
Deprecated.
This method will be removed in future versions as it uses the old type system.
Please use
Schema.field(String, DataType) instead. |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
SchemaValidator.deriveFieldMapping(DescriptorProperties properties,
Optional<TypeInformation<?>> inputType)
Deprecated.
Finds a table source field mapping.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
ChangelogCsvDeserializer.getProducedType() |
TypeInformation<RowData> |
SocketSourceFunction.getProducedType() |
Constructor and Description |
---|
ChangelogCsvDeserializer(List<LogicalType> parsingTypes,
DynamicTableSource.DataStructureConverter converter,
TypeInformation<RowData> producedTypeInfo,
String columnDelimiter) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
ResolvedFieldReference.resultType() |
Constructor and Description |
---|
ResolvedFieldReference(String name,
TypeInformation<?> resultType,
int fieldIndex) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<ACC> |
ImperativeAggregateFunction.getAccumulatorType()
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<?> |
AggregateFunctionDefinition.getAccumulatorTypeInfo()
Deprecated.
|
TypeInformation<?> |
TableAggregateFunctionDefinition.getAccumulatorTypeInfo()
Deprecated.
|
static <T,ACC> TypeInformation<ACC> |
UserDefinedFunctionHelper.getAccumulatorTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<ACC> |
UserDefinedFunctionHelper.getAccumulatorTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<ACC> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
TypeInformation<?>[] |
ScalarFunction.getParameterTypes(Class<?>[] signature)
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<?>[] |
TableFunction.getParameterTypes(Class<?>[] signature)
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<T> |
ImperativeAggregateFunction.getResultType()
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<T> |
TableFunction.getResultType()
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<?> |
TableFunctionDefinition.getResultType()
Deprecated.
|
TypeInformation<?> |
ScalarFunction.getResultType(Class<?>[] signature)
Deprecated.
This method uses the old type system and is based on the old reflective
extraction logic. The method will be removed in future versions and is only called when
using the deprecated
TableEnvironment.registerFunction(...) method. The new
reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint ) should be powerful enough to cover most use cases. For advanced users, it
is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory) . |
TypeInformation<?> |
AggregateFunctionDefinition.getResultTypeInfo()
Deprecated.
|
TypeInformation<?> |
TableAggregateFunctionDefinition.getResultTypeInfo()
Deprecated.
|
static <T,ACC> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfTableFunction(TableFunction<T> tableFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfTableFunction(TableFunction<T> tableFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
Modifier and Type | Method and Description |
---|---|
static <T,ACC> TypeInformation<ACC> |
UserDefinedFunctionHelper.getAccumulatorTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<ACC> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfAggregateFunction(ImperativeAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T> TypeInformation<T> |
UserDefinedFunctionHelper.getReturnTypeOfTableFunction(TableFunction<T> tableFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
Constructor and Description |
---|
AggregateFunctionDefinition(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
AggregateFunctionDefinition(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
TableAggregateFunctionDefinition(String name,
TableAggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
TableAggregateFunctionDefinition(String name,
TableAggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo)
Deprecated.
|
TableFunctionDefinition(String name,
TableFunction<?> tableFunction,
TypeInformation<?> resultType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer> |
HiveGenericUDAF.getAccumulatorType() |
TypeInformation |
HiveGenericUDAF.getResultType() |
TypeInformation |
HiveGenericUDTF.getResultType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation |
PythonAggregateFunction.getAccumulatorType() |
TypeInformation |
PythonTableAggregateFunction.getAccumulatorType() |
TypeInformation[] |
PythonScalarFunction.getParameterTypes(Class[] signature) |
TypeInformation[] |
PythonTableFunction.getParameterTypes(Class[] signature) |
TypeInformation |
PythonAggregateFunction.getResultType() |
TypeInformation |
PythonTableAggregateFunction.getResultType() |
TypeInformation<Row> |
PythonTableFunction.getResultType() |
TypeInformation |
PythonScalarFunction.getResultType(Class[] signature) |
Constructor and Description |
---|
PythonScalarFunction(String name,
byte[] serializedScalarFunction,
TypeInformation[] inputTypes,
TypeInformation resultType,
PythonFunctionKind pythonFunctionKind,
boolean deterministic,
boolean takesRowAsInput,
PythonEnv pythonEnv) |
PythonScalarFunction(String name,
byte[] serializedScalarFunction,
TypeInformation[] inputTypes,
TypeInformation resultType,
PythonFunctionKind pythonFunctionKind,
boolean deterministic,
boolean takesRowAsInput,
PythonEnv pythonEnv) |
PythonTableFunction(String name,
byte[] serializedScalarFunction,
TypeInformation[] inputTypes,
RowTypeInfo resultType,
PythonFunctionKind pythonFunctionKind,
boolean deterministic,
boolean takesRowAsInput,
PythonEnv pythonEnv) |
Modifier and Type | Method and Description |
---|---|
protected <IN> Transformation<IN> |
BatchExecLegacyTableSourceScan.createInput(StreamExecutionEnvironment env,
InputFormat<IN,? extends InputSplit> inputFormat,
TypeInformation<IN> typeInfo) |
Modifier and Type | Method and Description |
---|---|
protected abstract <IN> Transformation<IN> |
CommonExecLegacyTableSourceScan.createInput(StreamExecutionEnvironment env,
InputFormat<IN,? extends InputSplit> inputFormat,
TypeInformation<IN> typeInfo) |
protected Transformation<RowData> |
CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment env,
SourceFunction<RowData> function,
boolean isBounded,
String operatorName,
TypeInformation<RowData> outputTypeInfo)
Adopted from
StreamExecutionEnvironment.addSource(SourceFunction, String,
TypeInformation) but with custom Boundedness . |
Modifier and Type | Method and Description |
---|---|
protected <IN> Transformation<IN> |
StreamExecLegacyTableSourceScan.createInput(StreamExecutionEnvironment env,
InputFormat<IN,? extends InputSplit> format,
TypeInformation<IN> typeInfo) |
Modifier and Type | Method and Description |
---|---|
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
String desc,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
String desc,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
ArrowSourceFunction.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
SinkRuntimeProviderContext.createTypeInformation(DataType consumedDataType) |
TypeInformation<?> |
SinkRuntimeProviderContext.createTypeInformation(LogicalType consumedLogicalType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
ScanRuntimeProviderContext.createTypeInformation(DataType producedDataType) |
TypeInformation<?> |
LookupRuntimeProviderContext.createTypeInformation(DataType producedDataType) |
TypeInformation<?> |
ScanRuntimeProviderContext.createTypeInformation(LogicalType producedLogicalType) |
TypeInformation<?> |
LookupRuntimeProviderContext.createTypeInformation(LogicalType producedLogicalType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<RowData> |
FilterAllFlatMapFunction.getProducedType() |
TypeInformation<RowData> |
IntervalJoinFunction.getProducedType() |
TypeInformation<RowData> |
PaddingLeftMapFunction.getProducedType() |
TypeInformation<RowData> |
PaddingRightMapFunction.getProducedType() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?> |
TableOperatorWrapper.getOutputType() |
Modifier and Type | Method and Description |
---|---|
List<TypeInformation<?>> |
TableOperatorWrapper.getAllInputTypes() |
Constructor and Description |
---|
TableOperatorWrapper(StreamOperatorFactory<RowData> factory,
String operatorName,
List<TypeInformation<?>> allInputTypes,
TypeInformation<?> outputType) |
Constructor and Description |
---|
TableOperatorWrapper(StreamOperatorFactory<RowData> factory,
String operatorName,
List<TypeInformation<?>> allInputTypes,
TypeInformation<?> outputType) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?> |
TypeInfoDataTypeConverter.fromDataTypeToTypeInfo(DataType dataType)
Deprecated.
|
static TypeInformation |
TypeInfoLogicalTypeConverter.fromLogicalTypeToTypeInfo(LogicalType type)
Deprecated.
Use
BigDecimalTypeInfo to retain precision and scale of decimal. |
Modifier and Type | Method and Description |
---|---|
static LogicalType |
TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType(TypeInformation typeInfo)
Deprecated.
It will lose some information.
|
Modifier and Type | Class and Description |
---|---|
class |
BigDecimalTypeInfo
|
class |
DecimalDataTypeInfo
TypeInformation for
DecimalData . |
class |
ExternalTypeInfo<T>
Type information that wraps a serializer that originated from a
DataType . |
class |
InternalTypeInfo<T>
Type information that wraps a serializer that originated from a
LogicalType . |
class |
LegacyInstantTypeInfo
TypeInformation for Instant . |
class |
LegacyLocalDateTimeTypeInfo
TypeInformation for LocalDateTime . |
class |
LegacyTimestampTypeInfo
TypeInformation for Timestamp . |
class |
SortedMapTypeInfo<K,V>
The type information for sorted maps.
|
class |
StringDataTypeInfo
TypeInformation for
StringData . |
class |
TimestampDataTypeInfo
TypeInformation for
TimestampData . |
Constructor and Description |
---|
SortedMapTypeInfo(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
Comparator<K> comparator) |
SortedMapTypeInfo(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
Comparator<K> comparator) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<?>[] |
TableSinkBase.getFieldTypes()
Deprecated.
Returns the field types of the table to emit.
|
default TypeInformation<?>[] |
TableSink.getFieldTypes()
Deprecated.
Use the field types of
TableSink.getTableSchema() instead. |
default TypeInformation<Tuple2<Boolean,T>> |
UpsertStreamTableSink.getOutputType()
Deprecated.
|
default TypeInformation<Tuple2<Boolean,T>> |
RetractStreamTableSink.getOutputType()
Deprecated.
|
default TypeInformation<T> |
TableSink.getOutputType()
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
TableSink.getConsumedDataType() instead which uses the new type
system based on DataTypes . Please make sure to use either the old or the new type
system consistently to avoid unintended behavior. See the website documentation for more
information. |
TypeInformation<T> |
UpsertStreamTableSink.getRecordType()
Deprecated.
Returns the requested record type.
|
TypeInformation<T> |
RetractStreamTableSink.getRecordType()
Deprecated.
Returns the requested record type.
|
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
CsvTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
|
TableSink<T> |
TableSinkBase.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
TableSink<T> |
TableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
This method will be dropped in future versions. It is recommended to pass a
static schema when instantiating the sink instead.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
CsvTableSource.CsvLookupFunction.getResultType() |
default TypeInformation<T> |
TableSource.getReturnType()
Deprecated.
This method will be removed in future versions as it uses the old type system. It
is recommended to use
TableSource.getProducedDataType() instead which uses the new type
system based on DataTypes . Please make sure to use either the old or the new type
system consistently to avoid unintended behavior. See the website documentation for more
information. |
TypeInformation<T> |
FieldComputer.getReturnType()
Deprecated.
Returns the result type of the expression.
|
Modifier and Type | Method and Description |
---|---|
CsvTableSource.Builder |
CsvTableSource.Builder.field(String fieldName,
TypeInformation<?> fieldType)
Deprecated.
This method will be removed in future versions as it uses the old type
system. It is recommended to use
CsvTableSource.Builder.field(String, DataType) instead which uses
the new type system based on DataTypes . Please make sure to use either the
old or the new type system consistently to avoid unintended behavior. See the website
documentation for more information. |
void |
FieldComputer.validateArgumentFields(TypeInformation<?>[] argumentFieldTypes)
Deprecated.
Validates that the fields that the expression references have the correct types.
|
Constructor and Description |
---|
CsvTableSource(String path,
String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
A
InputFormatTableSource and LookupableTableSource for simple CSV files with
a (logically) unlimited number of fields. |
CsvTableSource(String path,
String[] fieldNames,
TypeInformation<?>[] fieldTypes,
int[] selectedFields,
String fieldDelim,
String lineDelim,
Character quoteCharacter,
boolean ignoreFirstLine,
String ignoreComments,
boolean lenient)
Deprecated.
A
InputFormatTableSource and LookupableTableSource for simple CSV files with
a (logically) unlimited number of fields. |
CsvTableSource(String path,
String[] fieldNames,
TypeInformation<?>[] fieldTypes,
String fieldDelim,
String lineDelim,
Character quoteCharacter,
boolean ignoreFirstLine,
String ignoreComments,
boolean lenient)
Deprecated.
A
InputFormatTableSource and LookupableTableSource for simple CSV files with
a (logically) unlimited number of fields. |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Long> |
TimestampExtractor.getReturnType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ExistingField.validateArgumentFields(TypeInformation<?>[] argumentFieldTypes) |
void |
StreamRecordTimestamp.validateArgumentFields(TypeInformation<?>[] argumentFieldTypes) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
LegacyTypeInformationType.getTypeInformation() |
TypeInformation<T> |
TypeInformationRawType.getTypeInformation()
Deprecated.
|
Constructor and Description |
---|
LegacyTypeInformationType(LogicalTypeRoot logicalTypeRoot,
TypeInformation<T> typeInfo) |
TypeInformationRawType(boolean isNullable,
TypeInformation<T> typeInfo)
Deprecated.
|
TypeInformationRawType(TypeInformation<T> typeInfo)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?> |
TypeConversions.fromDataTypeToLegacyInfo(DataType dataType)
Deprecated.
Please don't use this method anymore. It will be removed soon and we should not
make the removal more painful. Sources and sinks should use the method available in
context to convert, within the planner you should use either
InternalTypeInfo or
ExternalTypeInfo depending on the use case. |
static TypeInformation<?>[] |
TypeConversions.fromDataTypeToLegacyInfo(DataType[] dataType)
Deprecated.
Please don't use this method anymore. It will be removed soon and we should not
make the removal more painful. Sources and sinks should use the method available in
context to convert, within the planner you should use either
InternalTypeInfo or
ExternalTypeInfo depending on the use case. |
static TypeInformation<?> |
LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(DataType dataType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
TypeConversions.fromLegacyInfoToDataType(TypeInformation<?> typeInfo)
Deprecated.
Please don't use this method anymore. It will be removed soon and we should not
make the removal more painful. Sources and sinks should use the method available in
context to convert, within the planner you should use either
InternalTypeInfo or
ExternalTypeInfo depending on the use case. |
static DataType[] |
TypeConversions.fromLegacyInfoToDataType(TypeInformation<?>[] typeInfo)
Deprecated.
Please don't use this method anymore. It will be removed soon and we should not
make the removal more painful. Sources and sinks should use the method available in
context to convert, within the planner you should use either
InternalTypeInfo or
ExternalTypeInfo depending on the use case. |
static DataType |
TypeInfoDataTypeConverter.toDataType(DataTypeFactory dataTypeFactory,
TypeInformation<?> typeInfo)
Converts the given
TypeInformation into DataType . |
static DataType |
TypeInfoDataTypeConverter.toDataType(DataTypeFactory dataTypeFactory,
TypeInformation<?> typeInfo,
boolean forceNullability)
Converts the given
TypeInformation into DataType but allows to make all
fields nullable independent of the nullability in the serialization stack. |
static DataType |
LegacyTypeInfoDataTypeConverter.toDataType(TypeInformation<?> typeInfo)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
TimeIndicatorTypeInfo
Deprecated.
This class will be removed in future versions as it is used for the old type system.
It is recommended to use
DataTypes instead. Please make sure to use either the old or
the new type system consistently to avoid unintended behavior. See the website documentation
for more information. |
class |
TimeIntervalTypeInfo<T>
Deprecated.
This class will be removed in future versions as it is used for the old type system.
It is recommended to use
DataTypes instead. Please make sure to use either the old or
the new type system consistently to avoid unintended behavior. See the website documentation
for more information. |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?>[] |
FieldInfoUtils.getFieldTypes(TypeInformation<?> inputType)
Returns field types for a given
TypeInformation . |
Modifier and Type | Method and Description |
---|---|
static int[] |
FieldInfoUtils.getFieldIndices(TypeInformation<?> inputType)
Returns field indexes for a given
TypeInformation . |
static <A> String[] |
FieldInfoUtils.getFieldNames(TypeInformation<A> inputType)
Returns field names for a given
TypeInformation . |
static <A> String[] |
FieldInfoUtils.getFieldNames(TypeInformation<A> inputType,
List<String> existingNames)
Returns field names for a given
TypeInformation . |
static <A> FieldInfoUtils.TypeInfoSchema |
FieldInfoUtils.getFieldsInfo(TypeInformation<A> inputType)
Returns a
FieldInfoUtils.TypeInfoSchema for a given TypeInformation . |
static <A> FieldInfoUtils.TypeInfoSchema |
FieldInfoUtils.getFieldsInfo(TypeInformation<A> inputType,
Expression[] expressions)
Returns a
FieldInfoUtils.TypeInfoSchema for a given TypeInformation . |
static TypeInformation<?>[] |
FieldInfoUtils.getFieldTypes(TypeInformation<?> inputType)
Returns field types for a given
TypeInformation . |
static <A> void |
FieldInfoUtils.validateInputTypeInfo(TypeInformation<A> typeInfo)
Validate if class represented by the typeInfo is static and globally accessible.
|
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?> |
TypeStringUtils.readTypeInfo(String typeString)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static String |
TypeStringUtils.writeTypeInfo(TypeInformation<?> typeInfo)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
PythonInputFormatTableSource.getReturnType() |
Modifier and Type | Method and Description |
---|---|
static <T> InputFormat<T,?> |
PythonTableUtils.getCollectionInputFormat(List<T> data,
TypeInformation<T> dataType,
ExecutionConfig config)
Wrap the unpickled python data with an InputFormat.
|
static InputFormat<Row,?> |
PythonTableUtils.getInputFormat(List<Object[]> data,
TypeInformation<Row> dataType,
ExecutionConfig config)
Wrap the unpickled python data with an InputFormat.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<T> |
OutputTag.getTypeInfo() |
Constructor and Description |
---|
OutputTag(String id,
TypeInformation<T> typeInfo)
Creates a new named
OutputTag with the given id and output TypeInformation . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.