[IGNITE-532] Implement IgniteAkkaStreamer to stream data from Akka actors.

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: integrations, streaming
• Assignee: Nikolay Izhikov
• Reporter: Dmitriy Setrakyan
• Created: 20/Mar/15 15:46
• Updated: 20/Dec/19 17:47

Description

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

See Akka for more information. Given that Akka is a Scala frameworks, this streamer should be available in Scala.

We should create IgniteAkkaStreamer which will consume messages from Akka Actors and stream them into Ignite caches.

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

• Convert data from Akka to Ignite using an optional pluggable converter. If not provided, then we should have some default mechanism.
• Specify the cache name for the Ignite cache to load data into.
• Specify other flags available on IgniteDataStreamer class.

Issue Links

• links to: GitHub Pull Request #1019
• links to: GitHub Pull Request #1998