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

Tuple.readFields介绍

暂无

代码示例

代码示例来源：origin: org.apache.pig/pig

@Override
public void readFields(DataInput in) throws IOException {
  t.readFields(in);
  this.synthetic = in.readBoolean();
  this.omittable = in.readBoolean();
}

代码示例来源：origin: org.apache.pig/pig

private Tuple readSchemaTuple(DataInput in, byte type) throws IOException {
  int id;
  switch (type) {
  case (SCHEMA_TUPLE_BYTE_INDEX): id = in.readUnsignedByte(); break;
  case (SCHEMA_TUPLE_SHORT_INDEX): id = in.readUnsignedShort(); break;
  case (SCHEMA_TUPLE): id = in.readInt(); break;
  default: throw new RuntimeException("Invalid type given to readSchemaTuple: " + type);
}
  Tuple st = SchemaTupleFactory.getInstance(id).newTuple();
  st.readFields(in);
  return st;
}

代码示例来源：origin: org.apache.pig/pig

@Override
public void readFields(DataInput in) throws IOException {
  t.readFields(in);
  targetOps = new ArrayList<OperatorKey>();
  int size = in.readInt();
  for (int i = 0; i < size; i++) {
    OperatorKey target = new OperatorKey();
    // Ideally I should be able to call target.read(in).
    // Since it doesn't support it yet handling it here
    int scopeSz = in.readInt();
    byte[] buf = new byte[scopeSz];
    in.readFully(buf);
    target.scope = new String(buf);
    target.id = in.readLong();
    targetOps.add(target);
  }
}

代码示例来源：origin: org.apache.pig/pig

c.tuple.readFields(in);
  mMergeQ.add(c);
} catch (EOFException eof) {

代码示例来源：origin: com.twitter.elephantbird/elephant-bird-pig

@Override
public void readFields(DataInput in) throws IOException {
 Tuple t = tf.newTuple(realTuple.size());
 t.readFields(in);
 reference(t);
}

代码示例来源：origin: org.apache.pig/pig

do {
  try {
    c.tuple.readFields(in);

代码示例来源：origin: org.apache.pig/pig

Tuple t2 = mFact.newTuple();
try {
  t1.readFields(new DataInputStream(
      new ByteArrayInputStream(bb1.array(), s1, bb1.limit())));
  t2.readFields(new DataInputStream(
      new ByteArrayInputStream(bb2.array(), s2, bb2.limit())));
} catch (IOException ioe) {

代码示例来源：origin: org.apache.pig/pig

Tuple t1 = mFact.newTuple();
Tuple t2 = mFact.newTuple();
t1.readFields(new DataInputStream(new ByteArrayInputStream(bb1.array(), s1, bb1.limit())));
t2.readFields(new DataInputStream(new ByteArrayInputStream(bb2.array(), s2, bb2.limit())));