[ https://issues.apache.org/jira/browse/IGNITE-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16021347#comment-16021347 ]
ASF GitHub Bot commented on IGNITE-532: --------------------------------------- GitHub user dream-x opened a pull request: https://github.com/apache/ignite/pull/1998 IGNITE-532: Implement IgniteAkkaStreamer to stream data from Akka actors. You can merge this pull request into a Git repository by running: $ git pull https://github.com/dream-x/ignite ignite-532 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/ignite/pull/1998.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1998 ---- commit f47ab06b1ca4416eefc10ee80237898864dc67e5 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-03T14:02:17Z Init akka stream module. commit d105635dbe0ae8617404ef82a933a181a07cad8e Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-04T09:49:09Z Add akka-actor and -stream dependency in pom.xml. commit d44d4edaa07d11b9e69aef5e20f4e4ab1249d64e Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-06T16:45:54Z Update akka dependency. commit c63fc6290558fb552fb84e1213d2f85c9e51ddc6 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-06T16:46:19Z wip commit 4aafc72c70941c89da36a26d3d00e23f2f384246 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-13T08:47:01Z Add akka-stream streamer. commit f9b35d691517822fee29dd61cc10b4b160bbd3f6 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-13T08:47:15Z Add akka-stream streamer test. commit b79bc8dfaf9e7ef8a385ee245b09629216e10b17 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-13T08:47:36Z Delete ExampleAkkaStreamToIgniteStream.java commit a835cee93c86ba5f9f5119621d2e5efe73423ed5 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-13T09:01:56Z Delete onComplete test. commit 513d3c75be5ec625f1ca5b6b3d3b27ed2d75aab3 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-13T10:45:51Z wip. commit 924c9ae96b0a91c662ad9c06bd7c919f4935faf6 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-14T08:24:28Z Change version akka to 2.5. commit 09d26b9972931e5595a7bb30e9796ef8816ff455 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-18T14:35:18Z Ignite streamer based on Scala Actor. commit cc3548f429484e24a2454ec2e98961d102e3fe55 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-19T13:57:29Z Refactoring. commit a912475488da162df8f7662489382fec90716024 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-04-27T14:35:59Z wip commit 5dde548ff359f466de9df155aacc093cbfab77fd Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-02T13:32:52Z Add test akka actor streamer. commit cb45c197d377e13f9d489bcc562615d8d7e5a3a2 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-03T11:10:36Z Refactoring scala tests. commit b5be16c5221a91467699aec487543c676635433b Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-03T11:15:14Z Update akka to 2.5 commit ffc3c9975e6dd8fb2e881d6a0c6b3f2708208874 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-03T12:33:18Z Update pom.xml commit 6e9203eec0096f168c89158c16659808f14cc498 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-04T13:31:22Z Refactoring. commit 318748ab26819eab16be9a971b26386ed0244d4c Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-15T09:24:46Z Delete unused code. commit 805490ef138bc351ac357cc80de5329115a4a5a7 Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-22T14:30:45Z Remove java classes. Refactor imports. commit ec7917681480d3b5476a141a30e86b7c89609e4f Author: Max Kozlov <dreamx....@gmail.com> Date: 2017-05-23T15:36:41Z Refactoring code. ---- > 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)