@Override public Void call() throws Exception {
  try {
    NodeHolder nodeHolder=processDataRows(dataRows);
    int indexInNodeHolderArray=(sequenceNumber - 1) % numberOfCores;
    blockletDataHolder.put(nodeHolder,indexInNodeHolderArray);
    return null;
  }
 catch (  Throwable throwable) {
    consumerExecutorService.shutdownNow();
    resetBlockletProcessingCount();
    throw new CarbonDataWriterException(throwable.getMessage());
  }
}

@ Override public Void call ( ) throws Exception { try { NodeHolder nodeHolder = processDataRows ( dataRows ) ; int indexInNodeHolderArray = ( sequenceNumber - 1 ) % numberOfCores ; blockletDataHolder . put ( nodeHolder , indexInNodeHolderArray ) ; return null ; } catch ( Throwable throwable ) { consumerExecutorService . shutdownNow ( ) ; resetBlockletProcessingCount ( ) ; throw new CarbonDataWriterException ( throwable . getMessage ( ) ) ; } }
computes a result , or throws an exception if unable to do so .
