[ https://issues.apache.org/jira/browse/IGNITE-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968888#comment-15968888 ]
Maksim Kozlov commented on IGNITE-532: -------------------------------------- Hi guys, I have some questions about the issue: 1. Akka-stream workflow implementation few stages: {noformat} akka-stream source -> akka-stream flow -> akka-stream sink (ignite-stream) {noformat} Will it be enough to implement the creation of a Sink object in ignite-stream for workflow akka-stream? 2. Support for the akka-actor is relevant? > Implement IgniteAkkaStreamer to stream data from Akka actors. > ------------------------------------------------------------- > > Key: IGNITE-532 > URL: https://issues.apache.org/jira/browse/IGNITE-532 > Project: Ignite > Issue Type: Sub-task > Components: streaming > Reporter: Dmitriy Setrakyan > Assignee: Maksim Kozlov > > 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|http://akka.io/] 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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)