Uses of Class
org.apache.flink.cep.nfa.sharedbuffer.NodeId

Packages that use NodeId

Package	Description
org.apache.flink.cep.nfa
org.apache.flink.cep.nfa.sharedbuffer

Uses of NodeId in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa that return NodeId

Modifier and Type	Method	Description
NodeId	ComputationState.getPreviousBufferEntry()

Methods in org.apache.flink.cep.nfa with parameters of type NodeId

Modifier and Type	Method	Description
static ComputationState	ComputationState.createState(String currentState, NodeId previousEntry, DeweyNumber version, long startTimestamp, long previousTimestamp, EventId startEventID)

Uses of NodeId in org.apache.flink.cep.nfa.sharedbuffer

Methods in org.apache.flink.cep.nfa.sharedbuffer that return NodeId

Modifier and Type	Method	Description
NodeId	NodeId.NodeIdSerializer.copy(NodeId from)
NodeId	NodeId.NodeIdSerializer.copy(NodeId from, NodeId reuse)
NodeId	NodeId.NodeIdSerializer.createInstance()
NodeId	NodeId.NodeIdSerializer.deserialize(NodeId reuse, org.apache.flink.core.memory.DataInputView source)
NodeId	NodeId.NodeIdSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)
NodeId	SharedBufferAccessor.put(String stateName, EventId eventId, NodeId previousNodeId, DeweyNumber version)	Stores given value (value + timestamp) under the given state.

Methods in org.apache.flink.cep.nfa.sharedbuffer that return types with arguments of type NodeId

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<NodeId>	NodeId.NodeIdSerializer.snapshotConfiguration()

Methods in org.apache.flink.cep.nfa.sharedbuffer with parameters of type NodeId

Modifier and Type	Method	Description
NodeId	NodeId.NodeIdSerializer.copy(NodeId from)
NodeId	NodeId.NodeIdSerializer.copy(NodeId from, NodeId reuse)
NodeId	NodeId.NodeIdSerializer.deserialize(NodeId reuse, org.apache.flink.core.memory.DataInputView source)
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.
void	NodeId.NodeIdSerializer.serialize(NodeId record, org.apache.flink.core.memory.DataOutputView target)

Constructors in org.apache.flink.cep.nfa.sharedbuffer with parameters of type NodeId

Constructor	Description
SharedBufferEdge(NodeId target, DeweyNumber deweyNumber)	Creates versioned (with DeweyNumber) edge that points to the target entry.