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.internal	Contains main implementation.
org.apache.ignite.internal.processors.bulkload
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.query
org.apache.ignite.stream	Contains Ignite Streamer classes.

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>	Ignite.dataStreamer(String cacheName) Gets a new instance of data streamer associated with given cache name.

Uses of IgniteDataStreamer in org.apache.ignite.internal

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

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

Uses of IgniteDataStreamer in org.apache.ignite.internal.processors.bulkload

Constructors in org.apache.ignite.internal.processors.bulkload with parameters of type IgniteDataStreamer

Constructor and Description
BulkLoadStreamerWriter(IgniteDataStreamer<Object,Object> streamer) Creates a cache writer.

Uses of IgniteDataStreamer in org.apache.ignite.internal.processors.datastreamer

Classes in org.apache.ignite.internal.processors.datastreamer that implement IgniteDataStreamer

Modifier and Type	Class and Description
class	DataStreamerImpl<K,V> Data streamer implementation.

Uses of IgniteDataStreamer in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query that return IgniteDataStreamer

Modifier and Type	Method and Description
IgniteDataStreamer<?,?>	SqlClientContext.streamerForCache(String cacheName)

Methods in org.apache.ignite.internal.processors.query with parameters of type IgniteDataStreamer

Modifier and Type	Method and Description
long	GridQueryProcessor.streamUpdateQuery(@Nullable String cacheName, String schemaName, IgniteDataStreamer<?,?> streamer, String qry, Object[] args)
long	GridQueryIndexing.streamUpdateQuery(String schemaName, String qry, @Nullable Object[] params, IgniteDataStreamer<?,?> streamer) Execute an INSERT statement using data streamer as receiver.

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.