fix for code review comments

chinnurtb · May 16, 2014 · 389319d · 389319d
1 parent 09ad32c
commit 389319d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/Plumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/Plumber.java
@@ -31,8 +31,11 @@ public interface Plumber
    */
   public void startJob();
 
+  /**
+   * @param row - the row to insert
+   * @return - indicating how many rows were added, -1 means that an error occurred
+   */
   public int add(InputRow row);
-  public Sink getSink(long timestamp);
   public <T> QueryRunner<T> getQueryRunner(Query<T> query);
 
   /**