Updated Branches: refs/heads/flume-1.3.0 268223e03 -> c9d0760f3
FLUME-1480: Replace object descriptor with detailed component type plus name (Ted Malaska via Brock Noland) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/c9d0760f Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c9d0760f Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c9d0760f Branch: refs/heads/flume-1.3.0 Commit: c9d0760f3f21f9338eef23a1a54b66fb89f62ce5 Parents: 268223e Author: Brock Noland <[email protected]> Authored: Mon Sep 10 16:45:14 2012 -0500 Committer: Brock Noland <[email protected]> Committed: Mon Sep 10 16:45:37 2012 -0500 ---------------------------------------------------------------------- .../org/apache/flume/channel/AbstractChannel.java | 5 +++++ .../java/org/apache/flume/sink/AbstractSink.java | 3 +++ .../org/apache/flume/source/AbstractSource.java | 4 ++++ 3 files changed, 12 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/c9d0760f/flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java b/flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java index 352bf08..e662de9 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java +++ b/flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java @@ -64,4 +64,9 @@ public abstract class AbstractChannel public void configure(Context context) { } + + public String toString() { + return this.getClass().getName() + "{name: " + name + "}"; + } + } http://git-wip-us.apache.org/repos/asf/flume/blob/c9d0760f/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java b/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java index 7ecc1c9..54bf869 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java +++ b/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java @@ -74,4 +74,7 @@ abstract public class AbstractSink implements Sink, LifecycleAware { return name; } + public String toString() { + return this.getClass().getName() + "{name:" + name + ", channel:" + channel.getName() + "}"; + } } http://git-wip-us.apache.org/repos/asf/flume/blob/c9d0760f/flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java b/flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java index 5eeb687..861cc42 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java +++ b/flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java @@ -73,4 +73,8 @@ abstract public class AbstractSource implements Source { public synchronized String getName() { return name; } + + public String toString() { + return this.getClass().getName() + "{name:" + name + ",state:" + lifecycleState +"}"; + } }
