Package org.apache.flink.api.java.typeutils

Class TupleTypeInfo<T extends Tuple>

    • Field Detail

      • fieldNames

        protected final String[] fieldNames

    • Constructor Detail

      • TupleTypeInfo

        @PublicEvolving
public TupleTypeInfo​(TypeInformation<?>... types)

      • TupleTypeInfo

        @PublicEvolving
public TupleTypeInfo​(Class<T> tupleType,
                     TypeInformation<?>... types)

    • Method Detail

      • getFieldNames

        @PublicEvolving
public String[] getFieldNames()
        Description copied from class: CompositeType
        Returns the names of the composite fields of this type. The order of the returned array must be consistent with the internal field index ordering.
        Specified by:
        getFieldNames in class CompositeType<T extends Tuple>

      • getFieldIndex

        @PublicEvolving
public int getFieldIndex​(String fieldName)
        Description copied from class: CompositeType
        Returns the field index of the composite field of the given name.
        Specified by:
        getFieldIndex in class CompositeType<T extends Tuple>
        Returns:
        The field index or -1 if this type does not have a field of the given name.

      • createSerializer

        @PublicEvolving
public TupleSerializer<T> createSerializer​(SerializerConfig serializerConfig)
        Description copied from class: TypeInformation
        Creates a serializer for the type. The serializer may use the ExecutionConfig for parameterization.
        Overrides:
        createSerializer in class TypeInformation<T extends Tuple>
        Parameters:
        serializerConfig - The config used to parameterize the serializer.
        Returns:
        A serializer for this type.

      • getGenericParameters

        public Map<String,​TypeInformation<?>> getGenericParameters()
        Description copied from class: TypeInformation
        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. This information is necessary in cases where type information should be deduced from an input type.

        For instance, a method for a Tuple2 would look like this: Map m = new HashMap(); m.put("T0", this.getTypeAt(0)); m.put("T1", this.getTypeAt(1)); return m;

        Overrides:
        getGenericParameters in class TypeInformation<T extends Tuple>
        Returns:
        map of inferred subtypes; it does not have to contain all generic parameters as key; values may be null if type could not be inferred

      • canEqual

        public boolean canEqual​(Object obj)
        Description copied from class: TypeInformation
        Returns true if the given object can be equaled with this object. If not, it returns false.
        Overrides:
        canEqual in class TupleTypeInfoBase<T extends Tuple>
        Parameters:
        obj - Object which wants to take part in the equality relation
        Returns:
        true if obj can be equaled with this, otherwise false

      • getBasicTupleTypeInfo

        @PublicEvolving
public static <X extends Tuple> TupleTypeInfo<X> getBasicTupleTypeInfo​(Class<?>... basicTypes)

      • getBasicAndBasicValueTupleTypeInfo

        @PublicEvolving
public static <X extends Tuple> TupleTypeInfo<X> getBasicAndBasicValueTupleTypeInfo​(Class<?>... basicTypes)