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 using StreamTupleExtractor and streams into IgniteDataStreamer instance.