ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dmitriy Setrakyan (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (IGNITE-532) Implement IgniteAkkaStreamer to stream data from Akka actors.
Date Sun, 29 Mar 2015 19:32:52 GMT

    [ https://issues.apache.org/jira/browse/IGNITE-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14385903#comment-14385903
] 

Dmitriy Setrakyan commented on IGNITE-532:
------------------------------------------

I actually like the design. I do believe that we will have to have the "IgniteKeyExtractor"
abstraction to get keys out of Akka messages or streams.

I think we can split this work into 2 parts:
# Akka Actor integration
# Akka Stream integration

The code snippet that you provided for Akka extension with Scala trait looks nice, so my suggestion
would be to complete that first before moving to Akka streams.

What do you think?

> 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: Joshua Goldie
>
> 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.4#6332)

Mime
View raw message