You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by ja...@apache.org on 2014/03/01 01:08:32 UTC
git commit: FLUME-2329: Add an alias for the Morphline Solr Sink
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 <ja...@apache.org>
Authored: Fri Feb 28 16:06:50 2014 -0800
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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;