flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject git commit: FLUME-1965. Thrift sink alias doesn't exist
Date Wed, 03 Apr 2013 23:51:40 GMT
Updated Branches:
  refs/heads/trunk 7c8e0bdab -> 612a5199a


FLUME-1965. Thrift sink alias doesn't exist

(Will McQueen via Hari Shreedharan)


Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/612a5199
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/612a5199
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/612a5199

Branch: refs/heads/trunk
Commit: 612a5199a551fddeffcffa48cee9f3e679d5459a
Parents: 7c8e0bd
Author: Hari Shreedharan <hshreedharan@apache.org>
Authored: Wed Apr 3 16:50:22 2013 -0700
Committer: Hari Shreedharan <hshreedharan@apache.org>
Committed: Wed Apr 3 16:50:22 2013 -0700

----------------------------------------------------------------------
 .../apache/flume/conf/sink/SinkConfiguration.java  |    9 ++++++++-
 .../java/org/apache/flume/conf/sink/SinkType.java  |    9 ++++++++-
 2 files changed, 16 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/612a5199/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 5a92749..c6c99d5 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
@@ -111,7 +111,14 @@ public class SinkConfiguration extends ComponentConfiguration {
      *
      * @see AvroSink
      */
-    AVRO("org.apache.flume.conf.sink.AvroSinkConfiguration");
+    AVRO("org.apache.flume.conf.sink.AvroSinkConfiguration"),
+
+    /**
+     * Thrift sink
+     *
+     * @see ThriftSink
+     */
+    THRIFT("org.apache.flume.conf.sink.ThriftSinkConfiguration");
 
     private final String sinkConfigurationName;
 

http://git-wip-us.apache.org/repos/asf/flume/blob/612a5199/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 c117250..7e0288e 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
@@ -64,7 +64,14 @@ public enum SinkType {
    *
    * @see AvroSink
    */
-  AVRO("org.apache.flume.sink.AvroSink");
+  AVRO("org.apache.flume.sink.AvroSink"),
+
+  /**
+   * Thrift sink
+   *
+   * @see ThriftSink
+   */
+  THRIFT("org.apache.flume.sink.ThriftSink");
 
   private final String sinkClassName;
 


Mime
View raw message