Operators: spl 2.0.0

Operators

Aggregate: The Aggregate operator is used to compute user-specified aggregations over tuples that are gathered in a window.
Barrier: The Barrier operator is used to synchronize tuples from two or more streams.
Beacon: The Beacon operator is a utility source that generates tuples on an ad hoc basis.
CharacterTransform: The CharacterTransform operator is used to convert from one encoding in blob to another encoding in blob.
Compress: The Compress operator is used to compress data in a blob and generate blob output.
ControlNotificationSource: The ControlNotificationSource operator provides a connector between control events and data streams by turning control notifications into tuples.
Custom: The Custom operator is a special logic-related operator that can receive and send any number of streams and does not do anything by itself.
DeDuplicate: The DeDuplicate operator suppresses duplicate tuples that are seen within a specified time period.
Decompress: The Decompress operator decompresses data in blob input and generates blob output that contains the decompressed data.
Delay: The Delay operator is used to delay a stream by an amount while it keeps the inter-arrival times of tuples and punctuation intact.
DirectoryScan: The DirectoryScan operator watches a directory, and generates file names on the output, one for each file that is found in the directory.
DynamicFilter: The DynamicFilter is a version of the Filter operator that can decide at run time which input tuples are passed through, based on control input it receives.
EndpointSink: The EndpointSink operator enables data exchange between a Streams job and external clients.
EndpointSource: The EndpointSource operator enables data exchange between a Streams job and external clients.
Export: The Export operator sends a stream from the current application, making it available to Import operators of applications that are running in the same streaming middleware instance.
FileSink: The FileSink operator writes tuples to a file.
FileSource: The FileSource operator reads data from a file and produces tuples as a result.
Filter: The Filter operator removes tuples from a stream by passing along only those tuples that satisfy a user-specified condition.
Format: The Format operator is similar to the FileSink, TCPSink, and UDPSink operators, in that it converts SPL tuples into formatted data.
Functor: The Functor operator is used to transform input tuples into output ones, and optionally filter them as in a Filter operator.
Gate: The Gate operator is used to control the rate at which tuples are passed through.
Import: The Import operator receives tuples from streams that are made available by Export operators of applications that are running in the same streaming middleware instance.
JavaOp: The JavaOp operator is used to call out to operators implemented in Java by using the Java Operator API.
JobControlPlane: The JobControlPlane composite operator must be added to any application with a consistent region.
Join: The Join operator is used to correlate tuples from two streams that are based on user-specified match predicates and window configurations.
MetricsSink: The MetricsSink operator reads tuples and populates metrics with the values.
Pair: The Pair operator is used to pair tuples from two or more streams.
Parse: The Parse operator is similar to the FileSource, TCPSource, and UDPSource operators, in that it transforms input data in a raw form into well-structured SPL tuples.
Punctor: The Punctor operator is used to transform input tuples into output ones and add window punctuation to the output.
PythonOp: The PythonOp operator is used to call out to operators implemented in Python by using the Python Operator API.
ReplayableStart: The ReplayableStart operator forwards tuples and punctuations from its input port to its output port.
Sort: The Sort operator is used to order tuples that are based on user-specified ordering expressions and window configurations.
Split: The Split operator is used to split a stream into one or more output streams, which are based on a user-specified split condition.
Switch: The Switch operator is used to temporarily stop tuples from flowing.
TCPSink: The TCPSink operator writes data to a TCP socket in the form of tuples.
TCPSource: The TCPSource operator reads data from a TCP socket and creates tuples out of it.
ThreadedSplit: The ThreadedSplit operator splits tuples across multiple output ports to improve concurrency.
Throttle: The Throttle operator is used to pace a stream to make it flow at a specified rate.
UDPSink: The UDPSink operator writes data to a UDP socket in the form of tuples (and punctuation).
UDPSource: The UDPSource operator reads data from a UDP socket and creates tuples and punctuation out of it.
Union: The Union operator merges the streams that are connected to multiple input ports into a single stream.
XMLParse: The XMLParse operator accepts a single input stream and generates tuples as a result.