Package org.apache.ignite.stream.socket
Contains socket streamer implementation.
-
Interface Summary Interface Description SocketMessageConverter<T> Socket message converter. -
Class Summary Class Description SocketStreamer<T,K,V> Server that receives data from TCP socket, converts it to key-value pairs usingStreamTupleExtractor
and streams intoIgniteDataStreamer
instance.