@Override
  public void initialize(InputSplit inputSplit, TaskAttemptContext context)
      throws IOException, InterruptedException {

    if (ContextUtil.hasCounterMethod(context)) {
      BenchmarkCounter.initCounterFromContext(context);
    } else {
      LOG.error(
          String.format("Can not initialize counter because the class '%s' does not have a '.getCounterMethod'",
               context.getClass().getCanonicalName()));
    }

    initializeInternalReader(toParquetSplit(inputSplit), ContextUtil.getConfiguration(context));
  }
@Override
  public void initialize(InputSplit inputSplit, TaskAttemptContext context)
      throws IOException, InterruptedException {

    if (ContextUtil.hasCounterMethod(context)) {
      BenchmarkCounter.initCounterFromContext(context);
    } else {
      LOG.error(
          String.format("Can not initialize counter because the class '%s' does not have a '.getCounterMethod'",
               context.getClass().getCanonicalName()));
    }

    initializeInternalReader(toParquetSplit(inputSplit), ContextUtil.getConfiguration(context));
  }
@ Override public void initialize ( InputSplit inputSplit , TaskAttemptContext context ) throws IOException , InterruptedException { if ( ContextUtil . hasCounterMethod ( context ) ) { BenchmarkCounter . initCounterFromContext ( context ) ; } else { LOG . error ( String . format ( "Can not initialize counter because the class '%s' does not have a '.getCounterMethod'" , context . getClass ( ) . getCanonicalName ( ) ) ) ; } initializeInternalReader ( toParquetSplit ( inputSplit ) , ContextUtil . getConfiguration ( context ) ) ; }
{@inheritDoc}
{