Updated Branches: refs/heads/flume-1.4 f8c24a494 -> e9b12c898
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/e9b12c89 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/e9b12c89 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/e9b12c89 Branch: refs/heads/flume-1.4 Commit: e9b12c89833b4bea2268bcd8386e9a21d4742ee2 Parents: f8c24a4 Author: Hari Shreedharan <[email protected]> Authored: Wed Apr 3 16:50:22 2013 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Wed Apr 3 16:51:08 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/e9b12c89/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/e9b12c89/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;
