Operators
- FTPCommand
- The FTPCommand operator can run an ftp command at a remote host by using the FTP, FTPS, or SFTP protocols.
- FTPPutFile
- The FTPPutFile operator can put a local file on a remote host by using FTP, FTPS, or SFTP protocols.
- FTPReader
- The FTPReader operator is a source operator that can scan a directory at a remote host or receive files from a remote host by using the FTP, FTPS, or SFTP protocols.
- HTTPBLOBInjection
- Embeds a Jetty web server to allow HTTP or HTTPS POST requests to submit a tuple on its output ports.
- HTTPGetJSONContent
- Periodically connects to an HTTP endpoint to GET JSON content as a single tuple.
- HTTPGetStream
- Connects to an HTTP endpoint, reads "chunks" of data and sends it to the output port.
- HTTPGetXMLContent
- Periodically connects to an HTTP endpoint to GET XML content as a single tuple.
- HTTPJSONInjection
- Embeds a Jetty web server to allow HTTP or HTTPS POST requests with mime type application/json to submit a tuple on its output ports.
- HTTPParallelRequest
- The operator HTTPParallelRequest issues HTTP requests in parallel asynchronously from the input stream.
- HTTPPost
- This operator sends incoming tuples to the specified HTTP server as part of a POST request.
- HTTPRequest
- Issue an HTTP request of the specified method for each input tuple.
- HTTPRequestProcess
- Operator accepts a web request and generates corresponding response.
- HTTPTupleInjection
- Embeds a Jetty web server to allow HTTP or HTTPS POST requests to submit a tuple on its output ports.
- HTTPTupleView
- REST HTTP or HTTPS API to view tuples from windowed input ports.
- HTTPXMLInjection
- Embeds a Jetty web server to allow HTTP or HTTPS POST requests to submit a tuple on its output ports.
- HTTPXMLView
- REST API to view tuples from input ports.
- InetSource
- The InetSource operator periodically retrieves data from network servers and generates a stream from those contents.
- WebContext
- Embeds a Jetty web server to provide HTTP or HTTPS REST access to files defined by the context and contextResourceBase parameters.
- WebSocketInject
- Operator recieves messages from WebSocket clients and generates a tuple which is sent to streams.
- WebSocketSend
- Operator transmits tuples recieved on the input port via WebSocket protocol to connected clients.Upon startup, starts WebSocket Server. As tuple arrives on the input port they're converted intoJSON formatted messages and transmitted to all currently connected clients. Clients can connect and disconnect at anytime.