Package | Description |
---|---|
org.apache.flink.cep.nfa |
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.
|
static DeweyNumber |
DeweyNumber.fromString(String deweyNumberString)
Creates a dewey number from a string representation.
|
DeweyNumber |
SharedBuffer.SharedBufferEdge.getVersion() |
DeweyNumber |
ComputationState.getVersion() |
DeweyNumber |
DeweyNumber.increase()
Creates a new dewey number from this such that its last digit is increased by
one.
|
Modifier and Type | Method and Description |
---|---|
Collection<com.google.common.collect.LinkedHashMultimap<K,V>> |
SharedBuffer.extractPatterns(K key,
V value,
long timestamp,
DeweyNumber version)
Returns all elements from the previous relation starting at the given value with the
given key and timestamp.
|
boolean |
DeweyNumber.isCompatibleWith(DeweyNumber other)
Checks whether this dewey number is compatible to the other dewey number.
|
void |
SharedBuffer.put(K key,
V value,
long timestamp,
DeweyNumber version)
Stores given value (value + timestamp) under the given key.
|
void |
SharedBuffer.put(K key,
V value,
long timestamp,
K previousKey,
V previousValue,
long previousTimestamp,
DeweyNumber version)
Stores given value (value + timestamp) under the given key.
|
Constructor and Description |
---|
ComputationState(State<T> currentState,
T event,
long timestamp,
DeweyNumber version,
long startTimestamp) |
SharedBufferEdge(org.apache.flink.cep.nfa.SharedBuffer.SharedBufferEntry<K,V> target,
DeweyNumber version) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.