chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asrab...@apache.org
Subject svn commit: r787879 - /hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java
Date Wed, 24 Jun 2009 00:47:18 GMT
Author: asrabkin
Date: Wed Jun 24 00:47:17 2009
New Revision: 787879

URL: http://svn.apache.org/viewvc?rev=787879&view=rev
Log:
CHUKWA-323. Add clear() method to ChunkCatcherConnector.

Modified:
    hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java

Modified: hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java?rev=787879&r1=787878&r2=787879&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java
(original)
+++ hadoop/chukwa/trunk/src/test/org/apache/hadoop/chukwa/datacollection/connector/ChunkCatcherConnector.java
Wed Jun 24 00:47:17 2009
@@ -65,5 +65,11 @@
   public void reloadConfiguration() {
     System.out.println("reloadConfiguration");
   }
+  
+  public void clear() throws InterruptedException {
+    ArrayList<Chunk> list = new ArrayList<Chunk>();
+    while(eq.size() > 0)
+      eq.collect(list, 1);
+  }
 
 }



Mime
View raw message