fix for code review comments

2014-05-16 15:32:58 -07:00 · 2014-05-16 15:32:58 -07:00 · 389319dd6e
parent 09ad32c5c5
commit 389319dd6e
1 changed files with 4 additions and 1 deletions
--- 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);

  /**