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

Packages that use EventId

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

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

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

Modifier and Type	Method	Description
EventId	SharedBuffer.getStartEventId(int run)	Deprecated.
EventId	ComputationState.getStartEventID()

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

Modifier and Type	Method	Description
Map<EventId,Lockable<V>>	SharedBuffer.getEventsBuffer()	Deprecated.

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

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

Constructor parameters in org.apache.flink.cep.nfa with type arguments of type EventId

Constructor	Description
SharedBuffer(Map<EventId,Lockable<V>> eventsBuffer, Map<NodeId,Lockable<SharedBufferNode>> pages, Map<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.cep.nfa.SharedBuffer.ValueTimeWrapper<V>>,NodeId> mappingContext, Map<Integer,EventId> starters)	Deprecated.

Uses of EventId in org.apache.flink.cep.nfa.aftermatch

Methods in org.apache.flink.cep.nfa.aftermatch that return EventId

Modifier and Type	Method	Description
protected abstract EventId	AfterMatchSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)	Retrieves event id of the pruning element from the given match based on the strategy.
protected EventId	NoSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)
protected EventId	SkipPastLastStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)
protected EventId	SkipToNextStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)

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

Modifier and Type	Method	Description
protected abstract boolean	AfterMatchSkipStrategy.shouldPrune(EventId startEventID, EventId pruningId)	Tells if the partial/completed match starting at given id should be prunned by given pruningId.
protected boolean	NoSkipStrategy.shouldPrune(EventId startEventID, EventId pruningId)

Method parameters in org.apache.flink.cep.nfa.aftermatch with type arguments of type EventId

Modifier and Type	Method	Description
protected abstract EventId	AfterMatchSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)	Retrieves event id of the pruning element from the given match based on the strategy.
protected EventId	NoSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)
protected EventId	SkipPastLastStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)
protected EventId	SkipToNextStrategy.getPruningId(Collection<Map<String,List<EventId>>> match)

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

Fields in org.apache.flink.cep.nfa.sharedbuffer with type parameters of type EventId

Modifier and Type	Field	Description
static Comparator<EventId>	EventId.COMPARATOR

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

Modifier and Type	Method	Description
EventId	EventId.EventIdSerializer.copy(EventId from)
EventId	EventId.EventIdSerializer.copy(EventId from, EventId reuse)
EventId	EventId.EventIdSerializer.createInstance()
EventId	EventId.EventIdSerializer.deserialize(EventId reuse, org.apache.flink.core.memory.DataInputView source)
EventId	EventId.EventIdSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)
EventId	NodeId.getEventId()
EventId	SharedBufferAccessor.registerEvent(V value, long timestamp)	Adds another unique event to the shared buffer and assigns a unique id for it.

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

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.
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<EventId>	EventId.EventIdSerializer.snapshotConfiguration()

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

Modifier and Type	Method	Description
int	EventId.compareTo(EventId o)
EventId	EventId.EventIdSerializer.copy(EventId from)
EventId	EventId.EventIdSerializer.copy(EventId from, EventId reuse)
EventId	EventId.EventIdSerializer.deserialize(EventId reuse, 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.
void	SharedBufferAccessor.releaseEvent(EventId eventId)	Decreases the reference counter for the given event so that it can be removed once the reference counter reaches 0.
void	EventId.EventIdSerializer.serialize(EventId record, org.apache.flink.core.memory.DataOutputView target)

Method parameters in org.apache.flink.cep.nfa.sharedbuffer with type arguments of type EventId

Modifier and Type	Method	Description
Map<String,List<V>>	SharedBufferAccessor.materializeMatch(Map<String,List<EventId>> match)	Extracts the real event from the sharedBuffer with pre-extracted eventId.

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

Constructor	Description
NodeId(EventId eventId, String pageName)