本文整理了Java中org.apache.pig.data.Tuple.readFields()
方法的一些代码示例,展示了Tuple.readFields()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.readFields()
方法的具体详情如下:
包路径:org.apache.pig.data.Tuple
类名称: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())));
内容来源于网络,如有侵权,请联系作者删除!