SPL Operator Runtime Python API  7.2.1.0
Classes
streams Namespace Reference

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...
 

Streams