hadoop BinaryRecordInput 源码

haddop BinaryRecordInput 代码

文件路径：/hadoop-tools/hadoop-streaming/src/main/java/org/apache/hadoop/record/BinaryRecordInput.java

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.hadoop.record;

import java.io.DataInput;
import java.io.IOException;
import java.io.DataInputStream;
import java.io.InputStream;

import org.apache.hadoop.classification.InterfaceAudience;
import org.apache.hadoop.classification.InterfaceStability;

/**
 * @deprecated Replaced by <a href="http://hadoop.apache.org/avro/">Avro</a>.
 */
@Deprecated
@InterfaceAudience.Public
@InterfaceStability.Stable
public class BinaryRecordInput implements RecordInput {
    
  private DataInput in;
    
  static private class BinaryIndex implements Index {
    private int nelems;
    private BinaryIndex(int nelems) {
      this.nelems = nelems;
    }
    @Override
    public boolean done() {
      return (nelems <= 0);
    }
    @Override
    public void incr() {
      nelems--;
    }
  }
    
  private BinaryRecordInput() {}
    
  private void setDataInput(DataInput inp) {
    this.in = inp;
  }
    
  private static final ThreadLocal<BinaryRecordInput> B_IN =
      new ThreadLocal<BinaryRecordInput>() {
      @Override
      protected BinaryRecordInput initialValue() {
        return new BinaryRecordInput();
      }
    };
    
  /**
   * Get a thread-local record input for the supplied DataInput.
   * @param inp data input stream
   * @return binary record input corresponding to the supplied DataInput.
   */
  public static BinaryRecordInput get(DataInput inp) {
    BinaryRecordInput bin = B_IN.get();
    bin.setDataInput(inp);
    return bin;
  }
    
  /** Creates a new instance of BinaryRecordInput */
  public BinaryRecordInput(InputStream strm) {
    this.in = new DataInputStream(strm);
  }
    
  /** Creates a new instance of BinaryRecordInput */
  public BinaryRecordInput(DataInput din) {
    this.in = din;
  }
    
  @Override
  public byte readByte(final String tag) throws IOException {
    return in.readByte();
  }
    
  @Override
  public boolean readBool(final String tag) throws IOException {
    return in.readBoolean();
  }
    
  @Override
  public int readInt(final String tag) throws IOException {
    return Utils.readVInt(in);
  }
    
  @Override
  public long readLong(final String tag) throws IOException {
    return Utils.readVLong(in);
  }
    
  @Override
  public float readFloat(final String tag) throws IOException {
    return in.readFloat();
  }
    
  @Override
  public double readDouble(final String tag) throws IOException {
    return in.readDouble();
  }
    
  @Override
  public String readString(final String tag) throws IOException {
    return Utils.fromBinaryString(in);
  }
    
  @Override
  public Buffer readBuffer(final String tag) throws IOException {
    final int len = Utils.readVInt(in);
    final byte[] barr = new byte[len];
    in.readFully(barr);
    return new Buffer(barr);
  }
    
  @Override
  public void startRecord(final String tag) throws IOException {
    // no-op
  }
    
  @Override
  public void endRecord(final String tag) throws IOException {
    // no-op
  }
    
  @Override
  public Index startVector(final String tag) throws IOException {
    return new BinaryIndex(readInt(tag));
  }
    
  @Override
  public void endVector(final String tag) throws IOException {
    // no-op
  }
    
  @Override
  public Index startMap(final String tag) throws IOException {
    return new BinaryIndex(readInt(tag));
  }
    
  @Override
  public void endMap(final String tag) throws IOException {
    // no-op
  }
}

相关信息

hadoop 源码目录

相关文章

hadoop BinaryRecordOutput 源码

hadoop Buffer 源码

hadoop CsvRecordOutput 源码

hadoop Index 源码

hadoop Record 源码

hadoop RecordComparator 源码

hadoop RecordInput 源码

hadoop RecordOutput 源码

hadoop Utils 源码