flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject git commit: FLUME-1480: Replace object descriptor with detailed component type plus name
Date Mon, 10 Sep 2012 21:46:08 GMT
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 <brock@apache.org>
Authored: Mon Sep 10 16:45:14 2012 -0500
Committer: Brock Noland <brock@apache.org>
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 +"}";
+  }  
 }


Mime
View raw message