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.platform.client.streamer
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	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	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	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	Description
class	DataStreamerImpl<K,V>	Data streamer implementation.

Uses of IgniteDataStreamer in org.apache.ignite.internal.processors.platform.client.streamer

Methods in org.apache.ignite.internal.processors.platform.client.streamer that return IgniteDataStreamer

Modifier and Type	Method	Description
IgniteDataStreamer<KeyCacheObject,CacheObject>	ClientDataStreamerHandle.getStreamer()	Gets the wrapped streamer.

Constructors in org.apache.ignite.internal.processors.platform.client.streamer with parameters of type IgniteDataStreamer

Constructor	Description
ClientDataStreamerHandle(IgniteDataStreamer<KeyCacheObject,CacheObject> streamer)	Ctor.

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	Description
IgniteDataStreamer<?,?>	SqlClientContext.streamerForCache(String cacheName)

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

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

Uses of IgniteDataStreamer in org.apache.ignite.stream

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

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

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

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

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

Constructor	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.