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

Tuple.write介绍

暂无

代码示例

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

@Override
public void write(DataOutput out) throws IOException {
  t.write(out);
  out.writeBoolean(synthetic);
  out.writeBoolean(omittable);
}

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

private void writeTuple(DataOutput out, Tuple t) throws IOException {
  if (t instanceof TypeAwareTuple) {
    t.write(out);
  } else {
    SedesHelper.writeGenericTuple(out, t);
}
}

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

@Override
public void write(DataOutput out) throws IOException {
  t.write(out);
  out.writeInt(targetOps.size());
  for (OperatorKey target : targetOps) {
    // Ideally I should be able to call target.write(out).
    // Since it doesn't support it yet handling it here
    out.writeInt(target.scope.length());
    out.writeBytes(target.scope);
    out.writeLong(target.id);
  }
}

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

@Override
public void write(DataOutput out) throws IOException {
 convertAll();
 realTuple.write(out);
}

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

@Override
public void write(DataOutput out) throws IOException {
  out.writeLong(size());
  Iterator<Tuple> it = iterator();
  while (it.hasNext()) {
    Tuple item = it.next();
    item.write(out);
  }    
}

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

/**
 * Write a bag's contents to disk.
 * @param out DataOutput to write data to.
 * @throws IOException (passes it on from underlying calls).
 */
public void write(DataOutput out) throws IOException {
  // We don't care whether this bag was sorted or distinct because
  // using the iterator to write it will guarantee those things come
  // correctly.  And on the other end there'll be no reason to waste
  // time re-sorting or re-applying distinct.
  out.writeLong(size());
  Iterator<Tuple> it = iterator();
  while (it.hasNext()) {
    Tuple item = it.next();
    item.write(out);
  }    
}

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

/**
 * Write a bag's contents to disk.
 * @param out DataOutput to write data to.
 * @throws IOException (passes it on from underlying calls).
 */
public void write(DataOutput out) throws IOException {
  // We don't care whether this bag was sorted or distinct because
  // using the iterator to write it will guarantee those things come
  // correctly.  And on the other end there'll be no reason to waste
  // time re-sorting or re-applying distinct.
  out.writeLong(size());
  Iterator<Tuple> it = iterator();
  while (it.hasNext()) {
    Tuple item = it.next();
    item.write(out);
  }
}

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

@Override
public void write(DataOutput out) throws IOException {
  Tuple t = mTupleFactory.newTupleNoCopy(getAll());
  t.write(out);
}

代码示例来源：origin: com.twitter/parquet-pig

@Override
public void write(DataOutput dataOutput) throws IOException {
 Tuple t = TF.newTuple(json());
 t.write(dataOutput);
}

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

Tuple t;
while ((t = readFromPriorityQ()) != null) {
  t.write(out);

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

Tuple t;
while ((t = readFromPriorityQ()) != null) {
  t.write(out);

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

Tuple t;
while ((t = readFromTree()) != null) {
  t.write(out);

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

Tuple t;
while ((t = readFromTree()) != null) {
  t.write(out);

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

t.write(out);
spilled++;

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

Arrays.sort(array);
for (int i = 0; i < array.length; i++) {
  array[i].write(out);
  spilled++;