类org.apache.hadoop.io.file.tfile.Utils.Version源码实例Demo

下面列出了怎么用org.apache.hadoop.io.file.tfile.Utils.Version的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: hadoop   文件: TFile.java
public TFileMeta(DataInput in) throws IOException {
  version = new Version(in);
  if (!version.compatibleWith(TFile.API_VERSION)) {
    throw new RuntimeException("Incompatible TFile fileVersion.");
  }
  recordCount = Utils.readVLong(in);
  strComparator = Utils.readString(in);
  comparator = makeComparator(strComparator);
}
 
源代码2 项目: hadoop   文件: BCFile.java
/**
 * Constructor
 * 
 * @param fin
 *          FS input stream.
 * @param fileLength
 *          Length of the corresponding file
 * @throws IOException
 */
public Reader(FSDataInputStream fin, long fileLength, Configuration conf)
    throws IOException {
  this.in = fin;
  this.conf = conf;

  // move the cursor to the beginning of the tail, containing: offset to the
  // meta block index, version and magic
  fin.seek(fileLength - Magic.size() - Version.size() - Long.SIZE
      / Byte.SIZE);
  long offsetIndexMeta = fin.readLong();
  version = new Version(fin);
  Magic.readAndVerify(fin);

  if (!version.compatibleWith(BCFile.API_VERSION)) {
    throw new RuntimeException("Incompatible BCFile fileBCFileVersion.");
  }

  // read meta index
  fin.seek(offsetIndexMeta);
  metaIndex = new MetaIndex(fin);

  // read data:BCFile.index, the data block index
  BlockReader blockR = getMetaBlock(DataIndex.BLOCK_NAME);
  try {
    dataIndex = new DataIndex(blockR);
  } finally {
    blockR.close();
  }
}
 
源代码3 项目: big-c   文件: TFile.java
public TFileMeta(DataInput in) throws IOException {
  version = new Version(in);
  if (!version.compatibleWith(TFile.API_VERSION)) {
    throw new RuntimeException("Incompatible TFile fileVersion.");
  }
  recordCount = Utils.readVLong(in);
  strComparator = Utils.readString(in);
  comparator = makeComparator(strComparator);
}
 
源代码4 项目: big-c   文件: BCFile.java
/**
 * Constructor
 * 
 * @param fin
 *          FS input stream.
 * @param fileLength
 *          Length of the corresponding file
 * @throws IOException
 */
public Reader(FSDataInputStream fin, long fileLength, Configuration conf)
    throws IOException {
  this.in = fin;
  this.conf = conf;

  // move the cursor to the beginning of the tail, containing: offset to the
  // meta block index, version and magic
  fin.seek(fileLength - Magic.size() - Version.size() - Long.SIZE
      / Byte.SIZE);
  long offsetIndexMeta = fin.readLong();
  version = new Version(fin);
  Magic.readAndVerify(fin);

  if (!version.compatibleWith(BCFile.API_VERSION)) {
    throw new RuntimeException("Incompatible BCFile fileBCFileVersion.");
  }

  // read meta index
  fin.seek(offsetIndexMeta);
  metaIndex = new MetaIndex(fin);

  // read data:BCFile.index, the data block index
  BlockReader blockR = getMetaBlock(DataIndex.BLOCK_NAME);
  try {
    dataIndex = new DataIndex(blockR);
  } finally {
    blockR.close();
  }
}
 
源代码5 项目: attic-apex-malhar   文件: DTBCFile.java
/**
 * Constructor
 *
 * @param fin
 *          FS input stream.
 * @param fileLength
 *          Length of the corresponding file
 * @throws IOException
 */
public Reader(FSDataInputStream fin, long fileLength, Configuration conf)
    throws IOException {
  this.in = fin;
  this.conf = conf;
  // A reader buffer to read the block
  baos = new ByteArrayOutputStream(DTFile.getFSInputBufferSize(conf) * 2);
  this.cacheKeys = new ArrayList<String>();
  // move the cursor to the beginning of the tail, containing: offset to the
  // meta block index, version and magic
  fin.seek(fileLength - Magic.size() - Version.size() - Long.SIZE
      / Byte.SIZE);
  long offsetIndexMeta = fin.readLong();
  version = new Version(fin);
  Magic.readAndVerify(fin);

  if (!version.compatibleWith(DTBCFile.API_VERSION)) {
    throw new RuntimeException("Incompatible BCFile fileBCFileVersion.");
  }

  // read meta index
  fin.seek(offsetIndexMeta);
  metaIndex = new MetaIndex(fin);

  // read data:BCFile.index, the data block index
  BlockReader blockR = getMetaBlock(DataIndex.BLOCK_NAME);
  try {
    dataIndex = new DataIndex(blockR);
  } finally {
    blockR.close();
  }
}
 
源代码6 项目: attic-apex-malhar   文件: DTFile.java
public TFileMeta(DataInput in) throws IOException {
  version = new Version(in);
  if (!version.compatibleWith(DTFile.API_VERSION)) {
    throw new RuntimeException("Incompatible TFile fileVersion.");
  }
  recordCount = Utils.readVLong(in);
  strComparator = Utils.readString(in);
  comparator = makeComparator(strComparator);
}
 
源代码7 项目: RDFS   文件: TFile.java
public TFileMeta(DataInput in) throws IOException {
  version = new Version(in);
  if (!version.compatibleWith(TFile.API_VERSION)) {
    throw new RuntimeException("Incompatible TFile fileVersion.");
  }
  recordCount = Utils.readVLong(in);
  strComparator = Utils.readString(in);
  comparator = makeComparator(strComparator);
}
 
源代码8 项目: RDFS   文件: BCFile.java
/**
 * Constructor
 * 
 * @param fin
 *          FS input stream.
 * @param fileLength
 *          Length of the corresponding file
 * @throws IOException
 */
public Reader(FSDataInputStream fin, long fileLength, Configuration conf)
    throws IOException {
  this.in = fin;
  this.conf = conf;

  // move the cursor to the beginning of the tail, containing: offset to the
  // meta block index, version and magic
  fin.seek(fileLength - Magic.size() - Version.size() - Long.SIZE
      / Byte.SIZE);
  long offsetIndexMeta = fin.readLong();
  version = new Version(fin);
  Magic.readAndVerify(fin);

  if (!version.compatibleWith(BCFile.API_VERSION)) {
    throw new RuntimeException("Incompatible BCFile fileBCFileVersion.");
  }

  // read meta index
  fin.seek(offsetIndexMeta);
  metaIndex = new MetaIndex(fin);

  // read data:BCFile.index, the data block index
  BlockReader blockR = getMetaBlock(DataIndex.BLOCK_NAME);
  try {
    dataIndex = new DataIndex(blockR);
  } finally {
    blockR.close();
  }
}
 
源代码9 项目: hadoop-gpu   文件: TFile.java
public TFileMeta(DataInput in) throws IOException {
  version = new Version(in);
  if (!version.compatibleWith(TFile.API_VERSION)) {
    throw new RuntimeException("Incompatible TFile fileVersion.");
  }
  recordCount = Utils.readVLong(in);
  strComparator = Utils.readString(in);
  comparator = makeComparator(strComparator);
}
 
源代码10 项目: hadoop-gpu   文件: BCFile.java
/**
 * Constructor
 * 
 * @param fin
 *          FS input stream.
 * @param fileLength
 *          Length of the corresponding file
 * @throws IOException
 */
public Reader(FSDataInputStream fin, long fileLength, Configuration conf)
    throws IOException {
  this.in = fin;
  this.conf = conf;

  // move the cursor to the beginning of the tail, containing: offset to the
  // meta block index, version and magic
  fin.seek(fileLength - Magic.size() - Version.size() - Long.SIZE
      / Byte.SIZE);
  long offsetIndexMeta = fin.readLong();
  version = new Version(fin);
  Magic.readAndVerify(fin);

  if (!version.compatibleWith(BCFile.API_VERSION)) {
    throw new RuntimeException("Incompatible BCFile fileBCFileVersion.");
  }

  // read meta index
  fin.seek(offsetIndexMeta);
  metaIndex = new MetaIndex(fin);

  // read data:BCFile.index, the data block index
  BlockReader blockR = getMetaBlock(DataIndex.BLOCK_NAME);
  try {
    dataIndex = new DataIndex(blockR);
  } finally {
    blockR.close();
  }
}
 
源代码11 项目: hadoop   文件: TFile.java
public Version getVersion() {
  return version;
}
 
源代码12 项目: big-c   文件: TFile.java
public Version getVersion() {
  return version;
}
 
源代码13 项目: attic-apex-malhar   文件: DTFile.java
public Version getVersion() {
  return version;
}
 
源代码14 项目: RDFS   文件: TFile.java
public Version getVersion() {
  return version;
}
 
源代码15 项目: hadoop-gpu   文件: TFile.java
public Version getVersion() {
  return version;
}
 
源代码16 项目: hadoop   文件: BCFile.java
/**
 * Get version of BCFile file being read.
 * 
 * @return version of BCFile file being read.
 */
public Version getBCFileVersion() {
  return version;
}
 
源代码17 项目: hadoop   文件: BCFile.java
/**
 * Get version of BCFile API.
 * 
 * @return version of BCFile API.
 */
public Version getAPIVersion() {
  return API_VERSION;
}
 
源代码18 项目: big-c   文件: BCFile.java
/**
 * Get version of BCFile file being read.
 * 
 * @return version of BCFile file being read.
 */
public Version getBCFileVersion() {
  return version;
}
 
源代码19 项目: big-c   文件: BCFile.java
/**
 * Get version of BCFile API.
 * 
 * @return version of BCFile API.
 */
public Version getAPIVersion() {
  return API_VERSION;
}
 
源代码20 项目: attic-apex-malhar   文件: DTBCFile.java
/**
 * Get version of BCFile file being read.
 *
 * @return version of BCFile file being read.
 */
public Version getBCFileVersion() {
  return version;
}
 
源代码21 项目: attic-apex-malhar   文件: DTBCFile.java
/**
 * Get version of BCFile API.
 *
 * @return version of BCFile API.
 */
public Version getAPIVersion() {
  return API_VERSION;
}
 
源代码22 项目: RDFS   文件: BCFile.java
/**
 * Get version of BCFile file being read.
 * 
 * @return version of BCFile file being read.
 */
public Version getBCFileVersion() {
  return version;
}
 
源代码23 项目: RDFS   文件: BCFile.java
/**
 * Get version of BCFile API.
 * 
 * @return version of BCFile API.
 */
public Version getAPIVersion() {
  return API_VERSION;
}
 
源代码24 项目: hadoop-gpu   文件: BCFile.java
/**
 * Get version of BCFile file being read.
 * 
 * @return version of BCFile file being read.
 */
public Version getBCFileVersion() {
  return version;
}
 
源代码25 项目: hadoop-gpu   文件: BCFile.java
/**
 * Get version of BCFile API.
 * 
 * @return version of BCFile API.
 */
public Version getAPIVersion() {
  return API_VERSION;
}
 
 类所在包
 类方法
 同包方法