Repository: flume Updated Branches: refs/heads/trunk 7296e1a8b -> 9688cad6f
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/9688cad6 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/9688cad6 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/9688cad6 Branch: refs/heads/trunk Commit: 9688cad6faabfebf8ec9690abd4ba320dd795890 Parents: 7296e1a 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:06:50 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/9688cad6/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/9688cad6/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;
