@Experimental public class CommittableMessageTypeInfo<CommT> extends TypeInformation<CommittableMessage<CommT>>
CommittableMessage
to make it consumable from a DataStream
.Modifier and Type | Method and Description |
---|---|
boolean |
canEqual(Object obj)
Returns true if the given object can be equaled with this object.
|
TypeSerializer<CommittableMessage<CommT>> |
createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
boolean |
equals(Object o) |
int |
getArity()
Gets the arity of this type - the number of fields without nesting.
|
int |
getTotalFields()
Gets the number of logical fields in this type.
|
Class<CommittableMessage<CommT>> |
getTypeClass()
Gets the class of the type represented by this type information.
|
int |
hashCode() |
boolean |
isBasicType()
Checks if this type information represents a basic type.
|
boolean |
isKeyType()
Checks whether this type can be used as a key.
|
boolean |
isTupleType()
Checks if this type information represents a Tuple type.
|
static TypeInformation<CommittableMessage<Void>> |
noOutput()
Returns the type information for a
CommittableMessage with no committable. |
static <CommT> TypeInformation<CommittableMessage<CommT>> |
of(SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializerFactory)
Returns the type information based on the serializer for a
CommittableMessage . |
String |
toString() |
getGenericParameters, isSortKeyType, of, of
public static <CommT> TypeInformation<CommittableMessage<CommT>> of(SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializerFactory)
CommittableMessage
.CommT
- type of the committablecommittableSerializerFactory
- factory to create the serializer for a CommittableMessage
public static TypeInformation<CommittableMessage<Void>> noOutput()
CommittableMessage
with no committable.TypeInformation
with CommittableMessage
public boolean isBasicType()
TypeInformation
BasicTypeInfo
and are primitives, their boxing types, Strings, Date, Void, ...isBasicType
in class TypeInformation<CommittableMessage<CommT>>
public boolean isTupleType()
TypeInformation
isTupleType
in class TypeInformation<CommittableMessage<CommT>>
public int getArity()
TypeInformation
getArity
in class TypeInformation<CommittableMessage<CommT>>
public int getTotalFields()
TypeInformation
The total number of fields must be at least 1.
getTotalFields
in class TypeInformation<CommittableMessage<CommT>>
public Class<CommittableMessage<CommT>> getTypeClass()
TypeInformation
getTypeClass
in class TypeInformation<CommittableMessage<CommT>>
public boolean isKeyType()
TypeInformation
isKeyType
in class TypeInformation<CommittableMessage<CommT>>
public TypeSerializer<CommittableMessage<CommT>> createSerializer(ExecutionConfig config)
TypeInformation
createSerializer
in class TypeInformation<CommittableMessage<CommT>>
config
- The config used to parameterize the serializer.public String toString()
toString
in class TypeInformation<CommittableMessage<CommT>>
public boolean equals(Object o)
equals
in class TypeInformation<CommittableMessage<CommT>>
public int hashCode()
hashCode
in class TypeInformation<CommittableMessage<CommT>>
public boolean canEqual(Object obj)
TypeInformation
canEqual
in class TypeInformation<CommittableMessage<CommT>>
obj
- Object which wants to take part in the equality relationCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.