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 <[email protected]> Authored: Wed Apr 3 16:50:22 2013 -0700 Committer: Hari Shreedharan <[email protected]> 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;
