flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: FLUME-2329: Add an alias for the Morphline Solr Sink
Date Sat, 01 Mar 2014 00:08:54 GMT
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 <jarcec@apache.org>
Authored: Fri Feb 28 16:06:50 2014 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
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;
 


Mime
View raw message