Package org.apache.ignite.stream
Class StreamAdapter<T,K,V>
- java.lang.Object
- 
- org.apache.ignite.stream.StreamAdapter<T,K,V>
 
- 
- Direct Known Subclasses:
- SocketStreamer
 
 public abstract class StreamAdapter<T,K,V> extends Object Convenience adapter for streamers. Adapters are optional components for streaming from different data sources. The purpose of adapters is to convert different message formats into Ignite stream key-value tuples and feed the tuples into the providedIgniteDataStreamer.Two types of tuple extractors are supported: - A single tuple extractor, which extracts either no or 1 tuple out of a message. See
     see setTupleExtractor(StreamTupleExtractor).
- A multiple tuple extractor, which is capable of extracting multiple tuples out of a single message, in the
     form of a Map. SeesetMultipleTupleExtractor(StreamMultipleTupleExtractor).
 
- 
- 
Constructor SummaryConstructors Modifier Constructor Description protectedStreamAdapter()Empty constructor.protectedStreamAdapter(IgniteDataStreamer<K,V> stmr, StreamMultipleTupleExtractor<T,K,V> extractor)Stream adapter.protectedStreamAdapter(IgniteDataStreamer<K,V> stmr, StreamSingleTupleExtractor<T,K,V> extractor)Stream adapter.
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected voidaddMessage(T msg)Converts given message to 1 or many tuples (depending on the type of extractor) and adds it/them to the underlying streamer.IgnitegetIgnite()StreamMultipleTupleExtractor<T,K,V>getMultipleTupleExtractor()StreamSingleTupleExtractor<T,K,V>getSingleTupleExtractor()IgniteDataStreamer<K,V>getStreamer()StreamTupleExtractor<T,K,V>getTupleExtractor()Deprecated.voidsetIgnite(Ignite ignite)voidsetMultipleTupleExtractor(StreamMultipleTupleExtractor<T,K,V> multipleTupleExtractor)voidsetSingleTupleExtractor(StreamSingleTupleExtractor<T,K,V> singleTupleExtractor)voidsetStreamer(IgniteDataStreamer<K,V> stmr)voidsetTupleExtractor(StreamTupleExtractor<T,K,V> extractor)Deprecated.
 
- 
- 
- 
Field Detail- 
igniteprotected Ignite ignite Ignite.
 
- 
 - 
Constructor Detail- 
StreamAdapterprotected StreamAdapter() Empty constructor.
 - 
StreamAdapterprotected StreamAdapter(IgniteDataStreamer<K,V> stmr, StreamSingleTupleExtractor<T,K,V> extractor) Stream adapter.- Parameters:
- stmr- Streamer.
- extractor- Tuple extractor (1:1).
 
 - 
StreamAdapterprotected StreamAdapter(IgniteDataStreamer<K,V> stmr, StreamMultipleTupleExtractor<T,K,V> extractor) Stream adapter.- Parameters:
- stmr- Streamer.
- extractor- Tuple extractor (1:n).
 
 
- 
 - 
Method Detail- 
getStreamerpublic IgniteDataStreamer<K,V> getStreamer() - Returns:
- Provided data streamer.
 
 - 
setStreamerpublic void setStreamer(IgniteDataStreamer<K,V> stmr) - Parameters:
- stmr- Ignite data streamer.
 
 - 
getTupleExtractor@Deprecated public StreamTupleExtractor<T,K,V> getTupleExtractor() Deprecated.- Returns:
- Provided tuple extractor.
- See Also:
- getSingleTupleExtractor()
 
 - 
setTupleExtractor@Deprecated public void setTupleExtractor(StreamTupleExtractor<T,K,V> extractor) Deprecated.- Parameters:
- extractor- Extractor for a single key-value tuple from the message.
- See Also:
- setSingleTupleExtractor(StreamSingleTupleExtractor)
 
 - 
getSingleTupleExtractorpublic StreamSingleTupleExtractor<T,K,V> getSingleTupleExtractor() - Returns:
- Provided single tuple extractor.
 
 - 
setSingleTupleExtractorpublic void setSingleTupleExtractor(StreamSingleTupleExtractor<T,K,V> singleTupleExtractor) - Parameters:
- singleTupleExtractor- Extractor for key-value tuples from messages.
 
 - 
getMultipleTupleExtractorpublic StreamMultipleTupleExtractor<T,K,V> getMultipleTupleExtractor() - Returns:
- Provided tuple extractor (for 1:n cardinality).
 
 - 
setMultipleTupleExtractorpublic void setMultipleTupleExtractor(StreamMultipleTupleExtractor<T,K,V> multipleTupleExtractor) - Parameters:
- multipleTupleExtractor- Extractor for 1:n tuple extraction.
 
 - 
addMessageprotected void addMessage(T msg) Converts given message to 1 or many tuples (depending on the type of extractor) and adds it/them to the underlying streamer.- Parameters:
- msg- Message to convert.
 
 
- 
 
-