Uses of Class
org.apache.flink.cep.nfa.DeweyNumber
-
Packages that use DeweyNumber Package Description org.apache.flink.cep.nfa org.apache.flink.cep.nfa.sharedbuffer -
-
Uses of DeweyNumber in org.apache.flink.cep.nfa
Methods in org.apache.flink.cep.nfa that return DeweyNumber Modifier and Type Method 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(DeweyNumber reuse, DataInputView source)
DeweyNumber
DeweyNumber.DeweyNumberSerializer. deserialize(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.Methods in org.apache.flink.cep.nfa that return types with arguments of type DeweyNumber Modifier and Type Method Description TypeSerializerSnapshot<DeweyNumber>
DeweyNumber.DeweyNumberSerializer. snapshotConfiguration()
Methods in org.apache.flink.cep.nfa with parameters of type DeweyNumber Modifier and Type Method 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, long previousTimestamp, 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)
Constructors in org.apache.flink.cep.nfa with parameters of type DeweyNumber Constructor Description DeweyNumber(DeweyNumber number)
-
Uses of DeweyNumber in org.apache.flink.cep.nfa.sharedbuffer
Methods in org.apache.flink.cep.nfa.sharedbuffer with parameters of type DeweyNumber Modifier and Type Method Description List<Map<String,List<EventId>>>
SharedBufferAccessor. extractPatterns(NodeId nodeId, DeweyNumber version)
Returns all elements from the previous relation starting at the given entry.void
SharedBufferAccessor. lockNode(NodeId node, DeweyNumber version)
Increases the reference counter for the given entry so that it is not accidentally removed.NodeId
SharedBufferAccessor. put(String stateName, EventId eventId, NodeId previousNodeId, DeweyNumber version)
Stores given value (value + timestamp) under the given state.void
SharedBufferAccessor. releaseNode(NodeId node, DeweyNumber version)
Decreases the reference counter for the given entry so that it can be removed once the reference counter reaches 0.Constructors in org.apache.flink.cep.nfa.sharedbuffer with parameters of type DeweyNumber Constructor Description SharedBufferEdge(NodeId target, DeweyNumber deweyNumber)
Creates versioned (withDeweyNumber
) edge that points to the target entry.
-