Classes |
|
| class | BaseWindow |
| class | Checkpoint |
| Class that represents an individual checkpoint i.e. More... |
|
| class | CheckpointContext |
| Class that represents a checkpointing context for an operator. More... |
|
| class | Collection |
| Class that serves as an interface for the. More... |
|
| class | ConnectionNotification |
| class | ConsistentRegionContext |
| This is an optional context that can be acquired by using the CONSISTENT_REGION string defined in. More... |
|
| class | ConstTupleAttribute |
| Class that serves as a reflective interface for const tuple attributes. More... |
|
| class | ConstValueHandle |
| Class for reflective manipulation of const values of spl types. More... |
|
| class | FilterExpression |
| Class that represents a filter expression clause for import specifications. More... |
|
| class | Meta |
| class | Metric |
| Class that represents a metric object, used for port, operator, and pe metrics. More... |
|
| class | Notification |
| Represents a notification emitted by an MBean. More... |
|
| class | Operator |
| Class that serves as the base class of all SPL primitive operators. More... |
|
| class | OperatorContext |
| Class that represents the context of an operator. More... |
|
| class | OperatorInputPort |
| Class that represents an operator input port. More... |
|
| class | OperatorMetrics |
| Class that represents operator metrics. More... |
|
| class | OperatorOutputPort |
| Class that represents an operator output port. More... |
|
| class | OperatorPort |
| Class that forms a common base for operator ports. More... |
|
| class | OperatorThread |
| Class that represents an operator thread. More... |
|
| class | OptionalContext |
| Class that serves as a base for all optional operator contexts. More... |
|
| class | ParameterValue |
| Class representing one parameter value at runtime. More... |
|
| class | PartitionAgePartitionEvictionPolicy |
| Eviction policy based on the age of partition. More... |
|
| class | PartitionCountPartitionEvictionPolicy |
| Partitions should be evicted when there are too many partitions. More... |
|
| class | PartitionEvictionPolicy |
| Class that represents when partitions should be evicted from the window. More... |
|
| class | PEMetrics |
| Class that represents PE metrics. More... |
|
| class | ProcessingElement |
| Class that represents a processing element. More... |
|
| class | Punctuation |
| class | Python |
| class | StreamProperty |
| Class that represents a stream property. More... |
|
| class | SubscriptionExpression |
| Class that represents a subscription expression clause for import specifications. More... |
|
| class | timestamp |
| Class that represents a timestamp type. More... |
|
| class | Tuple |
| Class that serves as a reflective interface for the tuple types. More... |
|
| class | TupleCountPartitionEvictionPolicy |
| Partitions should be evicted when there are too many tuples. More... |
|
| class | ValueHandle |
| Class for reflective manipulation of values of SPL types. More... |
|
| class | WindowPolicy |
| Class that represents the eviction policies or the trigger policies of a window. More... |
|
| class | WindowTracker |
| Class for tracking which window is active at any time. More... |
|