Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.aftermatch | |
org.apache.flink.cep.nfa.sharedbuffer |
Class and Description |
---|
EventId
Composite key for events in
SharedBuffer . |
Lockable
Implements locking logic for incoming event and
SharedBufferNode using a lock reference
counter. |
NodeId
Unique identifier for
SharedBufferNode . |
SharedBufferAccessor
Accessor to SharedBuffer that allows operations on the underlying structures in batches.
|
SharedBufferNode
An entry in
SharedBuffer that allows to store relations between different entries. |
Class and Description |
---|
EventId
Composite key for events in
SharedBuffer . |
SharedBufferAccessor
Accessor to SharedBuffer that allows operations on the underlying structures in batches.
|
Class and Description |
---|
EventId
Composite key for events in
SharedBuffer . |
EventId.EventIdSerializer
TypeSerializer for EventId . |
Lockable
Implements locking logic for incoming event and
SharedBufferNode using a lock reference
counter. |
Lockable.LockableTypeSerializer
Serializer for
Lockable . |
NodeId
Unique identifier for
SharedBufferNode . |
NodeId.NodeIdSerializer
Serializer for
NodeId . |
SharedBufferAccessor
Accessor to SharedBuffer that allows operations on the underlying structures in batches.
|
SharedBufferEdge
Versioned edge in
SharedBuffer that allows retrieving predecessors. |
SharedBufferEdge.SharedBufferEdgeSerializer
Serializer for
SharedBufferEdge . |
SharedBufferNode
An entry in
SharedBuffer that allows to store relations between different entries. |
SharedBufferNode.SharedBufferNodeSerializer
Serializer for
SharedBufferNode . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.