## 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.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.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<?,?>` | GridQueryProcessor.`createStreamer(String spaceName, PreparedStatement nativeStmt, long autoFlushFreq, int nodeBufSize, int nodeParOps, boolean allowOverwrite)`
`IgniteDataStreamer<?,?>` | GridQueryIndexing.`createStreamer(String spaceName, PreparedStatement nativeStmt, long autoFlushFreq, int nodeBufSize, int nodeParOps, boolean allowOverwrite)`

Methods in org.apache.ignite.internal.processors.query with parameters of type IgniteDataStreamer
Modifier and Type | Method and Description
--- | ---
`long` | GridQueryProcessor.`streamUpdateQuery(String spaceName, IgniteDataStreamer<?,?> streamer, String qry, Object[] args)`
`long` | GridQueryIndexing.`streamUpdateQuery(String spaceName, String qry, Object[] params, IgniteDataStreamer<?,?> streamer)` Perform a MERGE 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.

2017 Copyright © Apache Software Foundation

Follow @ApacheIgnite

Ignite Fabric | : ver. 2.0.0
Release Date | : April 30 2017