Repository: flume Updated Branches: refs/heads/flume-1.5 a345f611b -> 6b72df25c
FLUME-2329: Add an alias for the Morphline Solr Sink (Hari Shreedharan via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/6b72df25 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/6b72df25 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/6b72df25 Branch: refs/heads/flume-1.5 Commit: 6b72df25c102937eb57eba92243598a0bcfa2e8b Parents: a345f61 Author: Jarek Jarcec Cecho <[email protected]> Authored: Fri Feb 28 16:06:50 2014 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Fri Feb 28 16:07:37 2014 -0800 ---------------------------------------------------------------------- .../org/apache/flume/conf/sink/SinkConfiguration.java | 11 ++++++++++- .../main/java/org/apache/flume/conf/sink/SinkType.java | 9 ++++++++- 2 files changed, 18 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/6b72df25/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java ---------------------------------------------------------------------- diff --git a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java index 965d2c5..ac11558 100644 --- a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java +++ b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java @@ -139,7 +139,16 @@ public class SinkConfiguration extends ComponentConfiguration { * * @see org.apache.flume.sink.hbase.AsyncHBaseSink */ - ASYNCHBASE("org.apache.flume.sink.hbase.HBaseSinkConfiguration"); + ASYNCHBASE("org.apache.flume.sink.hbase.HBaseSinkConfiguration"), + + + /** + * MorphlineSolr sink + * + * @see org.apache.flume.sink.solr.morphline.MorphlineSolrSink + */ + MORPHLINE_SOLR("org.apache.flume.sink.solr.morphline" + + ".MorphlineSolrSinkConfiguration"); private final String sinkConfigurationName; http://git-wip-us.apache.org/repos/asf/flume/blob/6b72df25/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java ---------------------------------------------------------------------- diff --git a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java index 8ce372d..0a1cd7a 100644 --- a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java +++ b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java @@ -92,7 +92,14 @@ public enum SinkType { * * @see org.apache.flume.sink.hbase.AsyncHBaseSink */ - ASYNCHBASE("org.apache.flume.sink.hbase.AsyncHBaseSink"); + ASYNCHBASE("org.apache.flume.sink.hbase.AsyncHBaseSink"), + + /** + * MorphlineSolr sink + * + * @see org.apache.flume.sink.solr.morphline.MorphlineSolrSink + */ + MORPHLINE_SOLR("org.apache.flume.sink.solr.morphline.MorphlineSolrSink"); private final String sinkClassName;
