Uses of Class
org.apache.flink.api.common.typeinfo.TypeInformation

Packages that use TypeInformation

Package	Description
org.apache.flink.api.common.distributions
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators
org.apache.flink.api.common.serialization
org.apache.flink.api.common.state
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.connector.source.lib
org.apache.flink.api.dag
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.streaming.api.operators
org.apache.flink.util

Uses of TypeInformation in org.apache.flink.api.common.distributions

Methods in org.apache.flink.api.common.distributions that return TypeInformation

Modifier and Type	Method	Description
TypeInformation[]	DataDistribution.getKeyTypes()	Gets the type of the key by which the dataSet is partitioned.

Uses of TypeInformation in org.apache.flink.api.common.functions

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

Modifier and Type	Method	Description
<T> TypeSerializer<T>	RuntimeContext.createSerializer(TypeInformation<T> typeInformation)	Create a serializer for a given type.
<T> TypeSerializer<T>	SerializerFactory.createSerializer(TypeInformation<T> typeInformation)	Creates a serializer for the specified type of data.

Uses of TypeInformation in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util with parameters of type TypeInformation

Modifier and Type	Method	Description
<T> TypeSerializer<T>	AbstractRuntimeUDFContext.createSerializer(TypeInformation<T> typeInformation)

Uses of TypeInformation in org.apache.flink.api.common.operators

Fields in org.apache.flink.api.common.operators declared as TypeInformation

Modifier and Type	Field	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

Methods in org.apache.flink.api.common.operators that return TypeInformation

Modifier and Type	Method	Description
TypeInformation<IN1>	BinaryOperatorInformation.getFirstInputType()
TypeInformation<T>	Keys.SelectorFunctionKeys.getInputType()
TypeInformation<IN>	UnaryOperatorInformation.getInputType()
TypeInformation<?>[]	Keys.ExpressionKeys.getKeyFieldTypes()
abstract TypeInformation<?>[]	Keys.getKeyFieldTypes()
TypeInformation<?>[]	Keys.SelectorFunctionKeys.getKeyFieldTypes()
TypeInformation<K>	Keys.SelectorFunctionKeys.getKeyType()
TypeInformation<?>[]	Keys.ExpressionKeys.getOriginalKeyFieldTypes()
abstract TypeInformation<?>[]	Keys.getOriginalKeyFieldTypes()
TypeInformation<?>[]	Keys.SelectorFunctionKeys.getOriginalKeyFieldTypes()
TypeInformation<OUT>	OperatorInformation.getOutputType()	Gets the return type of the user code function.
TypeInformation<IN2>	BinaryOperatorInformation.getSecondInputType()

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

Modifier and Type	Method	Description
static boolean	Keys.ExpressionKeys.isSortKey(int fieldPos, TypeInformation<?> type)
static boolean	Keys.ExpressionKeys.isSortKey(String fieldExpr, TypeInformation<?> type)
<E> void	Keys.ExpressionKeys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)
<E> void	Keys.SelectorFunctionKeys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)
abstract <E> void	Keys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)

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

Constructor	Description
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)
OperatorInformation(TypeInformation<OUT> outputType)
SelectorFunctionKeys(KeySelector<T,K> keyExtractor, TypeInformation<T> inputType, TypeInformation<K> keyType)
UnaryOperatorInformation(TypeInformation<IN> inputType, TypeInformation<OUT> outputType)

Uses of TypeInformation in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization that return TypeInformation

Modifier and Type	Method	Description
TypeInformation<T>	AbstractDeserializationSchema.getProducedType()	Gets the type produced by this deserializer.
TypeInformation<String>	SimpleStringSchema.getProducedType()
TypeInformation<T>	TypeInformationSerializationSchema.getProducedType()

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

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

Uses of TypeInformation in org.apache.flink.api.common.state

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

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

Uses of TypeInformation in org.apache.flink.api.common.typeinfo

Subclasses of TypeInformation in org.apache.flink.api.common.typeinfo

Modifier and Type	Class	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.

Fields in org.apache.flink.api.common.typeinfo declared as TypeInformation

Modifier and Type	Field	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.

Methods in org.apache.flink.api.common.typeinfo that return TypeInformation

Modifier and Type	Method	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>> TypeInformation<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(TypeInformation<?>... types)	Returns type information for Row with fields of the given types.
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 <T extends Tuple> TypeInformation<T>	Types.TUPLE(Class<T> tupleSubclass)	Returns type information for typed subclasses of Flink's Tuple.
static <T extends Tuple> TypeInformation<T>	Types.TUPLE(TypeInformation<?>... types)	Returns type information for subclasses of Flink's Tuple (namely Tuple0 till Tuple25) with fields of the given types.
static <V extends Value> TypeInformation<V>	Types.VALUE(Class<V> valueType)	Returns type information for Flink value types (classes that implement Value).

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

Modifier and Type	Method	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.

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

Modifier and Type	Method	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 <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 TypeInformation<?>	Types.PRIMITIVE_ARRAY(TypeInformation<?> elementType)	Returns type information for Java arrays of primitive type (such as byte[]).
static TypeInformation<Row>	Types.ROW(TypeInformation<?>... types)	Returns type information for Row with fields of the given types.
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 <T extends Tuple> TypeInformation<T>	Types.TUPLE(TypeInformation<?>... types)	Returns type information for subclasses of Flink's Tuple (namely Tuple0 till Tuple25) with fields of the given types.

Method parameters in org.apache.flink.api.common.typeinfo with type arguments of type TypeInformation

Modifier and Type	Method	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.

Uses of TypeInformation in org.apache.flink.api.common.typeutils

Subclasses of TypeInformation in org.apache.flink.api.common.typeutils

Modifier and Type	Class	Description
class	CompositeType<T>	Base type information class for Tuple and Pojo types

Methods in org.apache.flink.api.common.typeutils that return TypeInformation

Modifier and Type	Method	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.

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

Constructor	Description
FlatFieldDescriptor(int keyPosition, TypeInformation<?> type)

Uses of TypeInformation in org.apache.flink.api.connector.source.lib

Methods in org.apache.flink.api.connector.source.lib that return TypeInformation

Modifier and Type	Method	Description
TypeInformation<Long>	NumberSequenceSource.getProducedType()

Uses of TypeInformation in org.apache.flink.api.dag

Fields in org.apache.flink.api.dag declared as TypeInformation

Modifier and Type	Field	Description
protected TypeInformation<T>	Transformation.outputType

Methods in org.apache.flink.api.dag that return TypeInformation

Modifier and Type	Method	Description
TypeInformation<T>	Transformation.getOutputType()	Returns the output type of this Transformation as a TypeInformation.

Methods in org.apache.flink.api.dag with parameters of type TypeInformation

Modifier and Type	Method	Description
void	Transformation.setOutputType(TypeInformation<T> outputType)	Tries to fill in the type information.

Constructors in org.apache.flink.api.dag with parameters of type TypeInformation

Constructor	Description
Transformation(String name, TypeInformation<T> outputType, int parallelism)	Creates a new Transformation with the given name, output type and parallelism.
Transformation(String name, TypeInformation<T> outputType, int parallelism, boolean parallelismConfigured)	Creates a new Transformation with the given name, output type and parallelism.

Uses of TypeInformation in org.apache.flink.api.java.typeutils

Subclasses of TypeInformation in org.apache.flink.api.java.typeutils

Modifier and Type	Class	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.

Fields in org.apache.flink.api.java.typeutils declared as TypeInformation

Modifier and Type	Field	Description
protected TypeInformation<?>[]	TupleTypeInfoBase.types

Methods in org.apache.flink.api.java.typeutils that return TypeInformation

Modifier and Type	Method	Description
protected <OUT,IN1,IN2> TypeInformation<OUT>	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)
TypeInformation<Either<L,R>>	EitherTypeInfoFactory.createTypeInfo(Type t, Map<String,TypeInformation<?>> genericParameters)
static <IN1,IN2,OUT> TypeInformation<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)
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> TypeInformation<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> TypeInformation<OUT>	TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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> TypeInformation<OUT>	TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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> TypeInformation<OUT>	TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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> TypeInformation<OUT>	TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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>	PojoTypeInfo.getTypeAt(int pos)
<X> TypeInformation<X>	PojoTypeInfo.getTypeAt(String fieldExpression)
<X> TypeInformation<X>	RowTypeInfo.getTypeAt(String fieldExpression)
<X> TypeInformation<X>	TupleTypeInfoBase.getTypeAt(int pos)
<X> TypeInformation<X>	TupleTypeInfoBase.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

Methods in org.apache.flink.api.java.typeutils that return types with arguments of type TypeInformation

Modifier and Type	Method	Description
Map<String,TypeInformation<?>>	EitherTypeInfo.getGenericParameters()
Map<String,TypeInformation<?>>	TupleTypeInfo.getGenericParameters()

Methods in org.apache.flink.api.java.typeutils with parameters of type TypeInformation

Modifier and Type	Method	Description
protected <OUT,IN1,IN2> TypeInformation<OUT>	TypeExtractor.analyzePojo(Type type, List<Type> typeHierarchy, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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> TypeInformation<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> TypeInformation<OUT>	TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getCoGroupReturnTypes(CoGroupFunction<IN1,IN2,OUT> coGroupInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type, String functionName, boolean allowMissing)
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type, String functionName, boolean allowMissing)
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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 <C> MultisetTypeInfo<C>	MultisetTypeInfo.getInfoFor(TypeInformation<C> componentInfo)
static <T,C> ObjectArrayTypeInfo<T,C>	ObjectArrayTypeInfo.getInfoFor(Class<T> arrayClass, 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> TypeInformation<OUT>	TypeExtractor.getJoinReturnTypes(JoinFunction<IN1,IN2,OUT> joinInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<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.

Method parameters in org.apache.flink.api.java.typeutils with type arguments of type TypeInformation

Modifier and Type	Method	Description
TypeInformation<Either<L,R>>	EitherTypeInfoFactory.createTypeInfo(Type t, Map<String,TypeInformation<?>> genericParameters)

Constructors in org.apache.flink.api.java.typeutils with parameters of type TypeInformation

Constructor	Description
EitherTypeInfo(TypeInformation<L> leftType, TypeInformation<R> rightType)
ListTypeInfo(TypeInformation<T> elementTypeInfo)
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)

Uses of TypeInformation in org.apache.flink.api.java.typeutils.runtime.kryo

Methods in org.apache.flink.api.java.typeutils.runtime.kryo with parameters of type TypeInformation

Modifier and Type	Method	Description
static void	Serializers.recursivelyRegisterType(TypeInformation<?> typeInfo, SerializerConfig config, Set<Class<?>> alreadySeen)

Uses of TypeInformation in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type TypeInformation

Modifier and Type	Method	Description
void	OutputTypeConfigurable.setOutputType(TypeInformation<OUT> outTypeInfo, ExecutionConfig executionConfig)	Is called by the org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String) method when the org.apache.flink.streaming.api.graph.StreamGraph is generated.

Uses of TypeInformation in org.apache.flink.util

Methods in org.apache.flink.util that return TypeInformation

Modifier and Type	Method	Description
TypeInformation<T>	OutputTag.getTypeInfo()

Constructors in org.apache.flink.util with parameters of type TypeInformation

Constructor	Description
OutputTag(String id, TypeInformation<T> typeInfo)	Creates a new named OutputTag with the given id and output TypeInformation.