Package org.apache.flink.cep.nfa
Class NFAStateSerializer
- java.lang.Object
-
- org.apache.flink.api.common.typeutils.TypeSerializer<T>
-
- org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<NFAState>
-
- org.apache.flink.cep.nfa.NFAStateSerializer
-
- All Implemented Interfaces:
Serializable
public class NFAStateSerializer extends TypeSerializerSingleton<NFAState>
ATypeSerializer
forNFAState
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description NFAStateSerializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description NFAState
copy(NFAState from)
Creates a deep copy of the given element in a new element.NFAState
copy(NFAState from, NFAState reuse)
Creates a copy from the given element.void
copy(DataInputView source, DataOutputView target)
Copies exactly one record from the source input view to the target output view.NFAState
createInstance()
Creates a new instance of the data type.NFAState
deserialize(NFAState reuse, DataInputView source)
De-serializes a record from the given source input view into the given reuse record instance if mutable.NFAState
deserialize(DataInputView source)
De-serializes a record from the given source input view.int
getLength()
Gets the length of the data type, if it is a fix length data type.boolean
isImmutableType()
Gets whether the type is an immutable type.boolean
isSupportsPreviousTimestamp()
void
serialize(NFAState record, DataOutputView target)
Serializes the given record to the given target output view.TypeSerializerSnapshot<NFAState>
snapshotConfiguration()
Snapshots the configuration of this TypeSerializer.-
Methods inherited from class org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton
duplicate, equals, hashCode
-
-
-
-
Method Detail
-
isSupportsPreviousTimestamp
public boolean isSupportsPreviousTimestamp()
-
isImmutableType
public boolean isImmutableType()
Description copied from class:TypeSerializer
Gets whether the type is an immutable type.- Specified by:
isImmutableType
in classTypeSerializer<NFAState>
- Returns:
- True, if the type is immutable.
-
createInstance
public NFAState createInstance()
Description copied from class:TypeSerializer
Creates a new instance of the data type.- Specified by:
createInstance
in classTypeSerializer<NFAState>
- Returns:
- A new instance of the data type.
-
copy
public NFAState copy(NFAState from)
Description copied from class:TypeSerializer
Creates a deep copy of the given element in a new element.- Specified by:
copy
in classTypeSerializer<NFAState>
- Parameters:
from
- The element reuse be copied.- Returns:
- A deep copy of the element.
-
copy
public NFAState copy(NFAState from, NFAState reuse)
Description copied from class:TypeSerializer
Creates a copy from the given element. The method makes an attempt to store the copy in the given reuse element, if the type is mutable. This is, however, not guaranteed.- Specified by:
copy
in classTypeSerializer<NFAState>
- Parameters:
from
- The element to be copied.reuse
- The element to be reused. May or may not be used.- Returns:
- A deep copy of the element.
-
getLength
public int getLength()
Description copied from class:TypeSerializer
Gets the length of the data type, if it is a fix length data type.- Specified by:
getLength
in classTypeSerializer<NFAState>
- Returns:
- The length of the data type, or
-1
for variable length data types.
-
serialize
public void serialize(NFAState record, DataOutputView target) throws IOException
Description copied from class:TypeSerializer
Serializes the given record to the given target output view.- Specified by:
serialize
in classTypeSerializer<NFAState>
- Parameters:
record
- The record to serialize.target
- The output view to write the serialized data to.- Throws:
IOException
- Thrown, if the serialization encountered an I/O related error. Typically raised by the output view, which may have an underlying I/O channel to which it delegates.
-
deserialize
public NFAState deserialize(DataInputView source) throws IOException
Description copied from class:TypeSerializer
De-serializes a record from the given source input view.- Specified by:
deserialize
in classTypeSerializer<NFAState>
- Parameters:
source
- The input view from which to read the data.- Returns:
- The deserialized element.
- Throws:
IOException
- Thrown, if the de-serialization encountered an I/O related error. Typically raised by the input view, which may have an underlying I/O channel from which it reads.
-
deserialize
public NFAState deserialize(NFAState reuse, DataInputView source) throws IOException
Description copied from class:TypeSerializer
De-serializes a record from the given source input view into the given reuse record instance if mutable.- Specified by:
deserialize
in classTypeSerializer<NFAState>
- Parameters:
reuse
- The record instance into which to de-serialize the data.source
- The input view from which to read the data.- Returns:
- The deserialized element.
- Throws:
IOException
- Thrown, if the de-serialization encountered an I/O related error. Typically raised by the input view, which may have an underlying I/O channel from which it reads.
-
copy
public void copy(DataInputView source, DataOutputView target) throws IOException
Description copied from class:TypeSerializer
Copies exactly one record from the source input view to the target output view. Whether this operation works on binary data or partially de-serializes the record to determine its length (such as for records of variable length) is up to the implementer. Binary copies are typically faster. A copy of a record containing two integer numbers (8 bytes total) is most efficiently implemented astarget.write(source, 8);
.- Specified by:
copy
in classTypeSerializer<NFAState>
- Parameters:
source
- The input view from which to read the record.target
- The target output view to which to write the record.- Throws:
IOException
- Thrown if any of the two views raises an exception.
-
snapshotConfiguration
public TypeSerializerSnapshot<NFAState> snapshotConfiguration()
Description copied from class:TypeSerializer
Snapshots the configuration of this TypeSerializer. This method is only relevant if the serializer is used to state stored in checkpoints/savepoints.The snapshot of the TypeSerializer is supposed to contain all information that affects the serialization format of the serializer. The snapshot serves two purposes: First, to reproduce the serializer when the checkpoint/savepoint is restored, and second, to check whether the serialization format is compatible with the serializer used in the restored program.
IMPORTANT: TypeSerializerSnapshots changed after Flink 1.6. Serializers implemented against Flink versions up to 1.6 should still work, but adjust to new model to enable state evolution and be future-proof. See the class-level comments, section "Upgrading TypeSerializers to the new TypeSerializerSnapshot model" for details.
- Specified by:
snapshotConfiguration
in classTypeSerializer<NFAState>
- Returns:
- snapshot of the serializer's current configuration (cannot be
null
). - See Also:
TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot)
-
-