Operators
- ASN1Encode
- The ASN1Encode operator creates ASN.1 DER-encoded data from XML documents that fit to the provided ASN.1 specification.
- ASN1Parse
- The ASN1Parse operator parses a binary data stream that contains ASN.1-encoded data, extracts parts of the data, and sends the data as tuples to downstream operators.
- BloomFilter
- The BloomFilter operator detects duplicate tuples in a memory-efficient way.
- CSVParse
- The CSVParse operator parses an input line of comma-separated values (CSV) that is received in an rstring type input tuple attribute, splits the line into fields (also called items), and assigns the field values to attributes in the output port schema.
- DirectoryWatch
- The DirectoryWatch operator monitors configured directories and reports changes in them.
- ExceptionCatcher
- The ExceptionCatcher operator catches exceptions from fused downstream operators and reports these exceptions via tuples that are sent to its optional second output port.
- ScheduledBeacon
- The ScheduledBeacon operator is a utility source that generates tuples on-the-fly.
- StructureParse
- The StructureParse operator parses a binary data stream, which contains fixed-size structures; therefore, the data is passed in using a blob attribute.