List of finishJob() Examples

Examples of finishJob()

io.druid.segment.realtime.plumber.Plumber.finishJob()
Perform any final processing and clean up after ourselves. Should be called after all data has been fed into sinks and persisted.

Examples of io.druid.segment.realtime.plumber.Plumber.finishJob()

    }


    plumber.persist(firehose.commit());


    try {
      plumber.finishJob();
    }
    finally {
      log.info(
          "Task[%s] interval[%s] partition[%d] took in %,d rows (%,d processed, %,d unparseable, %,d thrown away)"
          + " and output %,d rows",

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.