| Package | Description |
|---|---|
| org.apache.ignite.stream.camel |
Contains implementation of Camel Streamer.
|
| org.apache.ignite.stream.jms11 |
Contains implementation of JMS queue and topic messages consumer.
|
| org.apache.ignite.stream.kafka |
Contains implementation of Kafka Streamer.
|
| org.apache.ignite.stream.mqtt |
Contains implementation of MQTT topic messages consumer.
|
| org.apache.ignite.stream.socket |
Contains socket streamer implementation.
|
| org.apache.ignite.stream.twitter |
Contains implementation of Twitter Streamer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CamelStreamer<K,V>
This streamer consumes messages from an Apache Camel consumer endpoint and feeds them into an Ignite data streamer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JmsStreamer<T extends javax.jms.Message,K,V>
Streamer that consumes from a JMS destination and feeds key-value pairs into an
IgniteDataStreamer instance. |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaStreamer<T,K,V>
Server that subscribes to topic messages from Kafka broker and streams its to key-value pairs into
IgniteDataStreamer instance. |
| Modifier and Type | Class and Description |
|---|---|
class |
MqttStreamer<K,V>
Streamer that consumes from a MQTT topic and feeds key-value pairs into an
IgniteDataStreamer instance,
using Eclipse Paho as an MQTT client. |
| Modifier and Type | Class and Description |
|---|---|
class |
SocketStreamer<T,K,V>
Server that receives data from TCP socket, converts it to key-value pairs using
StreamTupleExtractor and
streams into IgniteDataStreamer instance. |
| Modifier and Type | Class and Description |
|---|---|
class |
TwitterStreamer<K,V>
Streamer that consumes from a Twitter Streaming API and feeds transformed key-value pairs,
by default
IgniteDataStreamer instance. |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016