Package org.apache.beam.runners.flink.translation.types

Class EncodedValueTypeInformation

java.lang.Object
org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>
org.apache.beam.runners.flink.translation.types.EncodedValueTypeInformation
All Implemented Interfaces:
Serializable, org.apache.flink.api.common.typeinfo.AtomicType<byte[]>
public class EncodedValueTypeInformation extends org.apache.flink.api.common.typeinfo.TypeInformation<byte[]> implements org.apache.flink.api.common.typeinfo.AtomicType<byte[]>
Flink TypeInformation for Beam values that have been encoded to byte data by a Coder.
See Also:

  • Constructor Details

    • EncodedValueTypeInformation

      public EncodedValueTypeInformation()

  • Method Details

    • isBasicType

      public boolean isBasicType()
      Specified by:
      isBasicType in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • isTupleType

      public boolean isTupleType()
      Specified by:
      isTupleType in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • getArity

      public int getArity()
      Specified by:
      getArity in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • getTotalFields

      public int getTotalFields()
      Specified by:
      getTotalFields in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • getTypeClass

      public Class<byte[]> getTypeClass()
      Specified by:
      getTypeClass in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • isKeyType

      public boolean isKeyType()
      Specified by:
      isKeyType in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • createSerializer

      public org.apache.flink.api.common.typeutils.TypeSerializer<byte[]> createSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)
      Specified by:
      createSerializer in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • equals

      public boolean equals(@Nullable Object other)
      Specified by:
      equals in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • canEqual

      public boolean canEqual(Object obj)
      Specified by:
      canEqual in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • toString

      public String toString()
      Specified by:
      toString in class org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>

    • createComparator

      public org.apache.flink.api.common.typeutils.TypeComparator<byte[]> createComparator(boolean sortOrderAscending, org.apache.flink.api.common.ExecutionConfig executionConfig)
      Specified by:
      createComparator in interface org.apache.flink.api.common.typeinfo.AtomicType<byte[]>