You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2013/04/04 01:51:40 UTC
git commit: FLUME-1965. Thrift sink alias doesn't exist
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 <hs...@apache.org>
Authored: Wed Apr 3 16:50:22 2013 -0700
Committer: Hari Shreedharan <hs...@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;