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.
|
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from,
DeweyNumber reuse) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.createInstance() |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DataInputView source) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse,
DataInputView source) |
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.
|
DeweyNumber |
DeweyNumber.increase(int times)
Creates a new dewey number from this such that its last digit is increased by the supplied
number
|
Modifier and Type | Method and Description |
---|---|
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.copy(DeweyNumber from,
DeweyNumber reuse) |
static <T> ComputationState<T> |
ComputationState.createStartState(NFA<T> nfa,
State<T> state,
DeweyNumber version) |
static <T> ComputationState<T> |
ComputationState.createState(NFA<T> nfa,
State<T> currentState,
State<T> previousState,
T event,
int counter,
long timestamp,
DeweyNumber version,
long startTimestamp) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse,
DataInputView source) |
List<Map<K,List<V>>> |
SharedBuffer.extractPatterns(K key,
V value,
long timestamp,
int counter,
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.
|
int |
SharedBuffer.put(K key,
V value,
long timestamp,
DeweyNumber version)
Stores given value (value + timestamp) under the given key.
|
int |
SharedBuffer.put(K key,
V value,
long timestamp,
K previousKey,
V previousValue,
long previousTimestamp,
int previousCounter,
DeweyNumber version)
Stores given value (value + timestamp) under the given key.
|
void |
DeweyNumber.DeweyNumberSerializer.serialize(DeweyNumber record,
DataOutputView target) |
Constructor and Description |
---|
DeweyNumber(DeweyNumber number) |
SharedBufferEdge(org.apache.flink.cep.nfa.SharedBuffer.SharedBufferEntry<K,V> target,
DeweyNumber version) |
Constructor and Description |
---|
SharedBufferSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<DeweyNumber> versionSerializer) |
SharedBufferSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<DeweyNumber> versionSerializer) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.