[IGNITE-430] Implement IgniteSocketStreamer to stream data from TCP socket.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Pending Closed
• Fix Version/s: sprint-5
• Component/s: streaming
• Assignee: Andrey N. Gura
• Reporter: Dmitriy Setrakyan
• Created: 08/Mar/15 03:08
• Updated: 23/Jul/15 10:23
• Resolved: 15/May/15 01:11

Description

We have IgniteDataStreamer which is used to load data into Ignite under high load. It was previously named IgniteDataLoader, see ticket IGNITE-394.

We should create IgniteSocketStreamer which will consume messages from standard TCP socket and stream them into Ignite caches.

More details to follow, but to the least we should be able to:

• Convert TCP messages received on a TCP socket to Ignite data using an optional pluggable converter.
• Specify the cache name for the Ignite cache to load data into.
• Specify other flags available on IgniteDataStreamer class.