Examples of com.datasalt.pangool.tuplemr.MultipleOutputsCollector

   *             super.setup() should be called if MultipleOutputs are to be used. Therefore we have created another
   *             signature with the MultipleOutputsCollector in order to avoid this, which will be the official setup()
   *             method in the future (this one will be declared final in further versions).
   */
  protected void setup(Mapper<I1, I2, O1, O2>.Context context) throws IOException, InterruptedException {
    collector = new MultipleOutputsCollector(context);
    this.setup(context, collector);
  }

      InterruptedException {
    map(key, value, context, collector);
  }


  protected void setup(Mapper<I1, I2, O1, O2>.Context context) throws IOException, InterruptedException {
    collector = new MultipleOutputsCollector(context);
  }

Related Classes of com.datasalt.pangool.tuplemr.MultipleOutputsCollector

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.