public abstract class StreamAdapter<T,K,V> extends Object
IgniteDataStreamer
.Modifier | Constructor and Description |
---|---|
protected |
StreamAdapter()
Empty constructor.
|
protected |
StreamAdapter(IgniteDataStreamer<K,V> stmr,
StreamTupleExtractor<T,K,V> extractor)
Stream adapter.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addMessage(T msg)
Converts given message to a tuple and adds it to the underlying streamer.
|
Ignite |
getIgnite() |
IgniteDataStreamer<K,V> |
getStreamer() |
StreamTupleExtractor<T,K,V> |
getTupleExtractor() |
void |
setIgnite(Ignite ignite) |
void |
setStreamer(IgniteDataStreamer<K,V> stmr) |
void |
setTupleExtractor(StreamTupleExtractor<T,K,V> extractor) |
protected StreamAdapter()
protected StreamAdapter(IgniteDataStreamer<K,V> stmr, StreamTupleExtractor<T,K,V> extractor)
stmr
- Streamer.extractor
- Tuple extractor.public IgniteDataStreamer<K,V> getStreamer()
public void setStreamer(IgniteDataStreamer<K,V> stmr)
stmr
- Ignite data streamer.public StreamTupleExtractor<T,K,V> getTupleExtractor()
public void setTupleExtractor(StreamTupleExtractor<T,K,V> extractor)
extractor
- Extractor for key-value tuples from messages.protected void addMessage(T msg)
msg
- Message to convert.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.2.0-incubating Release Date : June 16 2015