Emitters

StreamAnalytix provides built-it operators called Emitters to emit data to a destination. Emitters defines the destination stage of a pipeline that could be a NoSql store, Indexer, Relational database, or third party BI tool.

For Spark pipelines, you can use the following emitters:

Emitters

Description

Native HDFS

Writes data into HDFS.

Advance HDFS

Write data into HDFS with advance configuration.

Cassandra

Writes data to a Cassandra cluster.

HBase

Writes data to an HBase cluster.

Elasticsearch

Writes data to an Elasticsearch cluster.

Solr

Writes data to a Solr cluster.

Kafka

Writes data to Kafka.

RabbitMQ

Writes data to RabbitMQ.

MapRStreams

Writes data to MapRStreams.

JDBC

Writes data to JDBS.

Foreach

Passes data to the custom for each implementation.

Streaming

Writes data to built-in RT Dashboards.

Router

Writes into another pipeline.

Custom

Writes data into any destination.

 

For Storm pipelines, you can use the following channels:

Emitters

Description

HDFS

Writes data into HDFS.

Hive

Write data into Hive tables.

Cassandra

Writes data to a Cassandra cluster.

HBase

Writes data to a HBase cluster.

Elasticsearch

Writes data to a Elasticsearch cluster.

Solr

Writes data to a Solr cluster.

Kafka

Writes data to Kafka.

RabbitMQ

Writes data to RabbitMQ.

MapRStreams

Writes data to MapRStreams.

JDBC

Writes data to JDBS.

ActiveMQ

Writes data to ActiveMQ.

Streaming

Writes data to built-in RT Dashboards.

Router

Writes into another pipeline.

Custom

Writes data into any destination.