[ https://issues.apache.org/jira/browse/IGNITE-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006401#comment-15006401 ]
Anton Vinogradov commented on IGNITE-529: ----------------------------------------- Roman, I've reduced test duration from minute to 8 seconds (reconfigured settings.xml IpFinder) & added ignite-log4j fo fix errors at test's output. Also I've made couple of minor changes ;) https://github.com/avinogradovgg/ignite/commit/ff517041dc18b75ba652d96e1531ffc0a68b725b Code seems to be ready to be committed in case you agree with my changes. Also, we have to describe usage of IgniteSink at https://apacheignite.readme.io/v1.5/docs. Could you please prepare article text? > Implement IgniteFlumeStreamer to stream data from Apache Flume > -------------------------------------------------------------- > > Key: IGNITE-529 > URL: https://issues.apache.org/jira/browse/IGNITE-529 > Project: Ignite > Issue Type: Sub-task > Components: streaming > Reporter: Dmitriy Setrakyan > Assignee: Roman Shtykh > > 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 Flume|http://flume.apache.org/] for more information. > We should create {{IgniteFlumeStreamer}} which will consume messages from > Apache Flume and stream them into Ignite caches. > More details to follow, but to the least we should be able to: > * Convert Flume data 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)