[
https://issues.apache.org/jira/browse/FLUME-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13649898#comment-13649898
]
Israel Ekpo commented on FLUME-2035:
------------------------------------
Hi Saikat,
Following up on the thread in the developers mailing list, here are my
recommendations:
My recommendation will be to take a look at how similar sinks are implemented
You can grab the source code from here
git clone http://git-wip-us.apache.org/repos/asf/flume.git flume
You can use the logic there for the implemented sinks as a general guide.
Then create a module for your sink just like how the elasticsearch and the
other sinks were implemented.
I would recommend that you build your sink first as a standalone project and
then place the compiled jars in your $FLUME_HOME/lib directory to make sure it
is working.
This will simplify the development process before integrating it with the
entire project as a module.
Once you are satisfied then you can write unit tests for it and move it into
the module suggested above for onward submission to the project as a patch.
All the source files should contain the Apache 2.0 license without any @author
annotations in the javadocs.
Creating a local git branch from the URL above to keep track of your work
locally with make saving changes easier to manage.
After everything has been integrated as a sink module in the flume project, run
"mvn clean install" to ensure all is well.
Once you have your patch ready:
(1) Upload the patche file(s) to the JIRA issue and set the status to PATCH
AVAILABLE.
(2) Create a review for your patch files here:
https://reviews.apache.org/
Pick "flume-git" as the repository and "Flume" as the group
(3) Link the Review to the JIRA issue in JIRA
(4) You can take a look at other code reviews here for some examples:
https://reviews.apache.org/groups/Flume/
> GraphSink for flume
> -------------------
>
> Key: FLUME-2035
> URL: https://issues.apache.org/jira/browse/FLUME-2035
> Project: Flume
> Issue Type: New Feature
> Components: Sinks+Sources
> Reporter: Saikat Kanjilal
> Original Estimate: 168h
> Remaining Estimate: 168h
>
> The goal of this feature is to implement a graph sink for flume , the sink
> will connect to both Titan and neo4j and others through an abstraction layer.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
