[
https://issues.apache.org/jira/browse/IGNITE-429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946541#comment-14946541
]
Chandresh Pancholi commented on IGNITE-429:
-------------------------------------------
GitHub user chandresh-pancholi opened a pull request:
https://github.com/apache/ignite/pull/138
[Ignite-429] Implement IgniteStormStreamer to stream data from Apache Storm
Added java1.7 compatibility and javadoc in StormSpout class.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chandresh-pancholi/ignite master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/ignite/pull/138.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 #138
commit 7fa633cfb0cfb8144e780d9572a3a4fbe518bbd4
Author: chandresh pancholi <[email protected]>
Date: 2015-10-07T08:52:12Z
Adding javadoc in StormSpout class and make streamer compatible with java1.7
----
> Implement IgniteStormStreamer to stream data from Apache Storm
> --------------------------------------------------------------
>
> Key: IGNITE-429
> URL: https://issues.apache.org/jira/browse/IGNITE-429
> Project: Ignite
> Issue Type: Sub-task
> Components: streaming
> Reporter: Dmitriy Setrakyan
> Assignee: Chandresh Pancholi
>
> We have {{IgniteDataStreamer}} which is used to load data into Ignite under
> high load. It was previously named {{IgniteDataLoader}}, see ticket
> IGNITE-394.
> See [Apache Storm|https://storm.apache.org/] for more information.
> We should create {{IgniteStormStreamer}} which will consume tuples from Storm
> and stream them into Ignite caches.
> More details to follow, but to the least we should be able to:
> - Convert/Intercept Storm tuples 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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
