The operators listed on this page appear as part of the dialog invoked by the Adapters, Java Operators icon. Click an operator's name or icon in the table below to open the topic page for that operator.
To place a global Java operator on the EventFlow canvas, drag the Adapters, Java Operators icon onto the canvas from the Palette view.
This opens the Insert an Operator or Adapter dialog that
includes both the global Java operators discussed on this page, plus the full set of
StreamBase adapters. To restrict the list to show only the operators on this page,
enter sb.operator
in the search field. To place an
operator on the canvas, double-click the operator's entry in the dialog, or select an
operator and click .
A different set of operators appear in the Operators and Adapters drawer of the Palette view in StreamBase Studio. If you do not find an operator you are looking for on this page, look on the Operator Overview page.
Icon | Operator | Description |
---|---|---|
![]() |
Drools operator | The Drools operator is a Java operator that provides a way for StreamBase applications to implement rule-based decision-making in the course of an EventFlow application. This operator embeds version 5.0 of the Drools Core rules engine, also known as JBoss Rules. You implement the operator by providing a rules file and a Java Interface file that describes the fields of interest in the operator's incoming tuple. |
![]() |
External Process operator | The External Process operator is a Java operator that provides a way for StreamBase applications to run arbitrary operating system commands as if typed at the shell command prompt for the current operating system. This feature is especially useful in StreamBase high availability design patterns, where an HA monitoring application in one container might need to send an sbadmin command to an application in another container or on another StreamBase Server to restart or change leadership status of the other application. |
![]() |
Field Serializer operator | The Field Serializer operator is a Java operator that provides a way to serialize the unused fields of a large tuple into a single blob field, leaving untouched the fields that your application must process. At the end of your processing chain, after processing the fields of interest, you can deserialize the blob field to reconstruct the tuple's unused fields. This effectively compresses a large tuple as it passes through your application, for a potential throughput and performance improvement. |
![]() |
FTP operator | The FTP operator is a Java operator that sends FTP client commands to an FTP server, and allows you to specify FTP protocol-level commands, if desired. This operator sends commands, dependent upon the value of each tuple it receives. It does so asynchronously, so as to not incur high latency in the running StreamBase application. |
![]() |
H2O Model Evaluator operator |
The H2O Model Evaluator operator enables StreamBase applications to execute numerical models generated with H2O. |
![]() |
HBase Admin operator |
The TIBCO StreamBase® Adapter for Apache HBase is implemented as a suite of five global Java operators, including the HBase Admin, Delete, Get, Put, and Scan operators. The HBase Admin operator allows a StreamBase application to handle data administration calls to a connected HBase database. The HBase Delete operator allows a StreamBase application to delete rows from a specified HBase table. The HBase Get operator allows a StreamBase application to extract rows by ID from a connected HBase database. The HBase Put operator allows a StreamBase application to insert data into a connected HBase database table. Finally, the HBase Scan operator allows a StreamBase application to return the entire contents of, or a range of rows from, a specified HBase table. |
![]() |
HBase Delete operator | |
![]() |
HBase Get operator | |
![]() |
HBase Put operator | |
![]() |
HBase Scan operator | |
![]() |
JMS and TIBCO EMS operators |
The JMS operators allow an application to connect to a JMS server and exchange messages with it. This is a suite of five single-purpose operators, each handling a particular action: JMS Producer, JMS Consumer, JMS Connect, JMS Ack, and JMS Commit. These five operators can be used with any JMS-compliant message server. There are also five TIBCO EMS operators that are tuned to work only with a TIBCO EMS message bus: EMS Producer, EMS Consumer, EMS Connect, EMS Ack, and EMS Commit. The JMS adapters from previous releases are still available but deprecated, now renamed the JMS Input and Output Legacy Adapters. |
![]() |
JSON to Tuple operator |
The JSON to Tuple Java operator converts JSON strings to StreamBase tuples. The operator's input port schema must contain a user defined string field that passes an JSON-encoded string to the operator. The operator parses the JSON string and populates tuple fields corresponding to the data found in the string. Each JSON string enqueued to the operator results in a single tuple emitted on its output port. |
![]() |
Microsoft .NET operator | The Microsoft .NET operator provides a way to execute .NET code within the context of your StreamBase application. |
![]() |
Runtime Schema Cast operator | The Runtime Schema Cast operator is a Java operator that casts its input schema to its configured target output schema at run time, expanding the subfields of any capture field in the input schema either by flattening or nesting the captured subfields. |
![]() |
Spark MLlib Model Evaluator operator |
The Spark MLlib Model Evaluator operator enables StreamBase applications to execute numerical models generated with Apache Spark MLib. |
![]() |
TERR operator | The TIBCO Enterprise Runtime for R operator (or the TERR operator) enables StreamBase to use TIBCO's implementation of the R language to analyse and manipulate data. |
![]() |
TIBCO ActiveMatrix BPM operator |
The ActiveMatrix BPM operator allow an application to connect to a TIBCO ActiveMatrix BPM server and execute REST API calls. |
![]() |
TIBCO ActiveSpaces operators |
The TIBCO ActiveSpaces operators allow an application to connect to a TIBCO ActiveSpaces metaspace and exchange tuples with it. This is a suite of seven single-purpose operators, each handling one of the following actions: Browse, Control, Get/Take, Listen, Lock/Unlock, Put, and Transaction Operations. The TIBCO ActiveSpaces operator from previous releases is still available, now renamed the TIBCO ActiveSpaces Legacy operator. |
![]() |
TIBCO StreamBase Admin operator | The TIBCO StreamBase Admin operator is a Java operator that provides a way to directly run in Studio the equivalent of the sbadmin command-line utility without opening a shell window. Use the Admin operator to start, stop, pause, resume, and obtain status from running StreamBase applications, modules, and containers. |
![]() |
Tuple to JSON operator |
The Tuple to JSON Java operator converts StreamBase tuples to JSON-encoded data. Each tuple enqueued to the operator results in a single JSON string emitted on its output port. |
![]() |
Tuple to XML operator |
The Tuple to XML Java operator converts StreamBase tuples to XML-encoded messages. Each field in the operator's input port schema populates an element or attribute in the resulting XML message. Each tuple enqueued to the operator results in a single XML message emitted on its output port. |
![]() |
WITSML operators |
The WITSML operators allow an application to connect to a WITSML data store. |
![]() |
XML Normalizer operator |
The XML Normalizer operator is a global Java operator that parses a designated field containing a string in XML format, and emits one tuple for each top-level element extracted from the XML string field. Each emitted tuple contains a user-defined set of string fields parsed from the input XML string, plus an optional field that reports any XML parsing errors. All fields in the input tuple other than the XML string field are optionally passed through unchanged to each emitted tuple, except input fields of type tuple or list, which are not supported and are emitted as null. |
![]() |
XML to Tuple operator |
The XML to Tuple Java operator converts XML-encoded messages to StreamBase tuples. The operator's input port schema has a single string field that passes an XML-encoded message to the operator. The operator parses the XML message and populates tuple fields corresponding to the elements and attributes found in the message. Each XML message enqueued to the operator results in a single tuple emitted on its output port. |
Also see the following related topics: