本文整理了Java中org.apache.hadoop.mapred.RecordReader.close方法的一些代码示例，展示了RecordReader.close的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RecordReader.close方法的具体详情如下：
包路径：org.apache.hadoop.mapred.RecordReader
类名称：RecordReader
方法名：close

RecordReader.close介绍

[英]Close this InputSplit to future operations.
[中]将此InputSplit关闭，以便将来进行操作。

代码示例

代码示例来源：origin: prestodb/presto

@Override
public void close()
    throws IOException
{
  delegate.close();
}

代码示例来源：origin: apache/flink

@Override
public void close() throws IOException {
  if (this.recordReader != null) {
    // enforce sequential close() calls
    synchronized (CLOSE_MUTEX) {
      this.recordReader.close();
    }
  }
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 if (curReader != null) {
  curReader.close();
  curReader = null;
 }
}

代码示例来源：origin: apache/hive

@Override
public void doClose() throws IOException {
 if (recordReader != null) {
  recordReader.close();
  recordReader = null;
 }
 idx = 0;
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 vrbReader.close();
 batch.cols = null;
}

代码示例来源：origin: apache/hive

private void closeReader() throws IOException {
 if (this.rr != null) {
  this.rr.close();
  this.rr = null;
 }
}

代码示例来源：origin: apache/hive

@Override
public void doClose() throws IOException {
 recordReader.close();
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 rr.close();
}

代码示例来源：origin: apache/hive

@Override
public void doClose() throws IOException {
 recordReader.close();
}

代码示例来源：origin: apache/incubator-gobblin

@Override
 public void close() throws IOException {
  this.recordReader.close();
 }
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 baseRecordReader.close();
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 reader.close();
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 sourceReader.close();
}

代码示例来源：origin: apache/drill

private void closeReader() throws IOException {
 if (this.rr != null) {
  this.rr.close();
  this.rr = null;
 }
}

代码示例来源：origin: apache/drill

@Override
public void doClose() throws IOException {
 if (recordReader != null) {
  recordReader.close();
  recordReader = null;
 }
 idx = 0;
}

代码示例来源：origin: apache/drill

@Override
public void close() throws IOException {
 vrbReader.close();
 batch.cols = null;
}

代码示例来源：origin: prestodb/presto

@Override
  public void close()
  {
    // some hive input formats are broken and bad things can happen if you close them multiple times
    if (closed) {
      return;
    }
    closed = true;

    updateCompletedBytes();

    try {
      recordReader.close();
    }
    catch (IOException e) {
      throw new UncheckedIOException(e);
    }
  }
}

代码示例来源：origin: apache/hive

@Override
public void close() throws IOException {
 try {
  this.baseReader.close();
 } finally {
  this.deleteEventRegistry.close();
 }
}

代码示例来源：origin: apache/hive

protected org.apache.hadoop.mapred.RecordReader setReaderAtSplit(int splitNum)
  throws IOException {
 JobConf localJc = getLocalFSJobConfClone(jc);
 currentSplitPointer = splitNum;
 if ( rr != null ) {
  rr.close();
 }
 // open record reader to read next split
 rr = inputFormat.getRecordReader(inputSplits[currentSplitPointer], jobCloneUsingLocalFs,
   reporter);
 currentSplitPointer++;
 return rr;
}

代码示例来源：origin: apache/drill

protected org.apache.hadoop.mapred.RecordReader setReaderAtSplit(int splitNum)
  throws IOException {
 JobConf localJc = getLocalFSJobConfClone(jc);
 currentSplitPointer = splitNum;
 if ( rr != null ) {
  rr.close();
 }
 // open record reader to read next split
 rr = inputFormat.getRecordReader(inputSplits[currentSplitPointer], jobCloneUsingLocalFs,
   reporter);
 currentSplitPointer++;
 return rr;
}