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.storm |
StormStreamer -- integration with Apache Storm.
|
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<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 |
StormStreamer<K,V>
Apache Storm streamer implemented as a Storm bolt.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.0 Release Date : October 15 2020