Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.aftermatch | |
org.apache.flink.cep.nfa.sharedbuffer |
Modifier and Type | Method and Description |
---|---|
EventId |
ComputationState.getStartEventID() |
EventId |
SharedBuffer.getStartEventId(int run)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Map<EventId,Lockable<V>> |
SharedBuffer.getEventsBuffer()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static ComputationState |
ComputationState.createState(String currentState,
NodeId previousEntry,
DeweyNumber version,
long startTimestamp,
EventId startEventID) |
Constructor and Description |
---|
SharedBuffer(Map<EventId,Lockable<V>> eventsBuffer,
Map<NodeId,Lockable<SharedBufferNode>> pages,
Map<Tuple2<String,org.apache.flink.cep.nfa.SharedBuffer.ValueTimeWrapper<V>>,NodeId> mappingContext,
Map<Integer,EventId> starters)
Deprecated.
|
SharedBuffer(Map<EventId,Lockable<V>> eventsBuffer,
Map<NodeId,Lockable<SharedBufferNode>> pages,
Map<Tuple2<String,org.apache.flink.cep.nfa.SharedBuffer.ValueTimeWrapper<V>>,NodeId> mappingContext,
Map<Integer,EventId> starters)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected EventId |
SkipPastLastStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
protected EventId |
NoSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
protected EventId |
SkipToNextStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
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.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
NoSkipStrategy.shouldPrune(EventId startEventID,
EventId pruningId) |
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.
|
Modifier and Type | Method and Description |
---|---|
protected EventId |
SkipPastLastStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
protected EventId |
NoSkipStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
protected EventId |
SkipToNextStrategy.getPruningId(Collection<Map<String,List<EventId>>> match) |
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.
|
void |
AfterMatchSkipStrategy.prune(Collection<ComputationState> matchesToPrune,
Collection<Map<String,List<EventId>>> matchedResult,
SharedBufferAccessor<?> sharedBufferAccessor)
Prunes matches/partial matches based on the chosen strategy.
|
Modifier and Type | Field and Description |
---|---|
static Comparator<EventId> |
EventId.COMPARATOR |
Modifier and Type | Method and Description |
---|---|
EventId |
EventId.EventIdSerializer.copy(EventId from) |
EventId |
EventId.EventIdSerializer.copy(EventId from,
EventId reuse) |
EventId |
EventId.EventIdSerializer.createInstance() |
EventId |
EventId.EventIdSerializer.deserialize(DataInputView source) |
EventId |
EventId.EventIdSerializer.deserialize(EventId reuse,
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.
|
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.
|
TypeSerializerSnapshot<EventId> |
EventId.EventIdSerializer.snapshotConfiguration() |
Modifier and Type | Method and 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,
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,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
SharedBuffer.init(Map<EventId,Lockable<V>> events,
Map<NodeId,Lockable<SharedBufferNode>> entries)
Deprecated.
Only for state migration!
|
Map<String,List<V>> |
SharedBufferAccessor.materializeMatch(Map<String,List<EventId>> match)
Extracts the real event from the sharedBuffer with pre-extracted eventId.
|
Constructor and Description |
---|
NodeId(EventId eventId,
String pageName) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.