Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.sharedbuffer |
Modifier and Type | Method and Description |
---|---|
DeweyNumber |
DeweyNumber.addStage()
Creates a new dewey number from this such that a 0 is appended as new last digit.
|
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from,
DeweyNumber reuse) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.createInstance() |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DataInputView source) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse,
DataInputView source) |
static DeweyNumber |
DeweyNumber.fromString(String deweyNumberString)
Creates a dewey number from a string representation.
|
DeweyNumber |
ComputationState.getVersion() |
DeweyNumber |
DeweyNumber.increase()
Creates a new dewey number from this such that its last digit is increased by
one.
|
DeweyNumber |
DeweyNumber.increase(int times)
Creates a new dewey number from this such that its last digit is increased by the supplied
number.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<DeweyNumber> |
SharedBuffer.SharedBufferSerializer.getVersionSerializer() |
TypeSerializerSnapshot<DeweyNumber> |
DeweyNumber.DeweyNumberSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from,
DeweyNumber reuse) |
static ComputationState |
ComputationState.createStartState(String state,
DeweyNumber version) |
static ComputationState |
ComputationState.createState(String currentState,
NodeId previousEntry,
DeweyNumber version,
long startTimestamp,
EventId startEventID) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse,
DataInputView source) |
boolean |
DeweyNumber.isCompatibleWith(DeweyNumber other)
Checks whether this dewey number is compatible to the other dewey number.
|
void |
DeweyNumber.DeweyNumberSerializer.serialize(DeweyNumber record,
DataOutputView target) |
Constructor and Description |
---|
DeweyNumber(DeweyNumber number) |
Constructor and Description |
---|
SharedBufferSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<DeweyNumber> versionSerializer) |
SharedBufferSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<DeweyNumber> versionSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<Map<String,List<EventId>>> |
SharedBufferAccessor.extractPatterns(NodeId nodeId,
DeweyNumber version)
Returns all elements from the previous relation starting at the given entry.
|
NodeId |
SharedBufferAccessor.put(String stateName,
EventId eventId,
NodeId previousNodeId,
DeweyNumber version)
Stores given value (value + timestamp) under the given state.
|
Constructor and Description |
---|
SharedBufferEdge(NodeId target,
DeweyNumber deweyNumber)
Creates versioned (with
DeweyNumber ) edge that points to the target entry. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.