Uses of Interface
org.apache.ignite.IgniteDataStreamer

Packages that use IgniteDataStreamer

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.sink.flink	IgniteSink -- streaming connector integration with Apache Flink.
org.apache.ignite.stream	Contains Ignite Streamer classes.
org.apache.ignite.stream.kafka.connect	Contains implementation of Kafka Streamer Connector.
org.apache.ignite.stream.storm	StormStreamer -- integration with Apache Storm.

Uses of IgniteDataStreamer in org.apache.ignite

Methods in org.apache.ignite that return IgniteDataStreamer

Modifier and Type	Method and Description
<K,V> IgniteDataStreamer<K,V>	IgniteSpringBean.dataStreamer(@Nullable String cacheName) Gets a new instance of data streamer associated with given cache name.
<K,V> IgniteDataStreamer<K,V>	Ignite.dataStreamer(String cacheName) Gets a new instance of data streamer associated with given cache name.

Uses of IgniteDataStreamer in org.apache.ignite.sink.flink

Fields in org.apache.ignite.sink.flink declared as IgniteDataStreamer

Modifier and Type	Field and Description
protected IgniteDataStreamer	IgniteSink.streamer Ignite Data streamer instance.

Uses of IgniteDataStreamer in org.apache.ignite.stream

Methods in org.apache.ignite.stream that return IgniteDataStreamer

Modifier and Type	Method and Description
IgniteDataStreamer<K,V>	StreamAdapter.getStreamer()

Methods in org.apache.ignite.stream with parameters of type IgniteDataStreamer

Modifier and Type	Method and Description
void	StreamAdapter.setStreamer(IgniteDataStreamer<K,V> stmr)

Constructors in org.apache.ignite.stream with parameters of type IgniteDataStreamer

Constructor and Description
StreamAdapter(IgniteDataStreamer<K,V> stmr, StreamMultipleTupleExtractor<T,K,V> extractor) Stream adapter.
StreamAdapter(IgniteDataStreamer<K,V> stmr, StreamSingleTupleExtractor<T,K,V> extractor) Stream adapter.

Uses of IgniteDataStreamer in org.apache.ignite.stream.kafka.connect

Methods in org.apache.ignite.stream.kafka.connect that return IgniteDataStreamer

Modifier and Type	Method and Description
static IgniteDataStreamer	IgniteSinkTask.StreamerContext.getStreamer() Obtains data streamer instance.

Uses of IgniteDataStreamer in org.apache.ignite.stream.storm

Methods in org.apache.ignite.stream.storm that return IgniteDataStreamer

Modifier and Type	Method and Description
static IgniteDataStreamer	StormStreamer.StreamerContext.getStreamer() Obtains data streamer instance.