Java 类org.apache.hadoop.io.SequenceFile.ValueBytes 实例源码

项目:hadoop    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:aliyun-oss-hadoop-fs    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:big-c    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:azkaban    文件:AzkabanSequenceFileReader.java   
public ValueBytes createValueBytes() {
  ValueBytes val = null;
  if (!decompress || blockCompressed) {
    val = new UncompressedBytes();
  } else {
    val = new CompressedBytes(codec);
  }
  return val;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-EAR    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-plus    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:FlexMap    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hops    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-TCP    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-on-lustre    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hardfs    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-on-lustre2    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:RDFS    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:azkaban-plugins    文件:AzkabanSequenceFileReader.java   
public ValueBytes createValueBytes() {
  ValueBytes val = null;
  if (!decompress || blockCompressed) {
    val = new UncompressedBytes();
  } else {
    val = new CompressedBytes(codec);
  }
  return val;
}
项目:hadoop-0.20    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hanoi-hadoop-2.0.0-cdh    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:mapreduce-fork    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hortonworks-extension    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hortonworks-extension    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}
项目:hadoop-gpu    文件:BasicTypeSorterBase.java   
public ValueBytes getValue() throws IOException {
  //value[i] is stored in the following byte range:
  //startOffsets[i] + keyLengths[i] through valLengths[i]
  value.reset(keyValBuffer,
              startOffsets[currStartOffsetIndex] + keyLengths[currStartOffsetIndex],
              valLengths[currStartOffsetIndex]);
  return value;
}