MCPcopy Create free account
hub / github.com/apache/pig / write

Method write

src/org/apache/pig/data/SchemaTuple.java:141–156  ·  view source on GitHub ↗
(DataOutput out, boolean writeIdentifiers)

Source from the content-addressed store, hash-verified

139 protected abstract void generatedCodeSetIterator(Iterator<Object> l) throws ExecException;
140
141 protected void write(DataOutput out, boolean writeIdentifiers) throws IOException {
142 if (writeIdentifiers) {
143 int id = getSchemaTupleIdentifier();
144 if (id < BinInterSedes.UNSIGNED_BYTE_MAX) {
145 out.writeByte(BinInterSedes.SCHEMA_TUPLE_BYTE_INDEX);
146 out.writeByte(id);
147 } else if (id < BinInterSedes.UNSIGNED_SHORT_MAX) {
148 out.writeByte(BinInterSedes.SCHEMA_TUPLE_SHORT_INDEX);
149 out.writeShort(id);
150 } else {
151 out.writeByte(BinInterSedes.SCHEMA_TUPLE);
152 out.writeInt(id);
153 }
154 }
155 writeElements(out);
156 }
157
158 protected static void write(DataOutput out, DataBag v) throws IOException {
159 bis.writeDatum(out, v, DataType.BAG);

Callers 15

write_user_exceptionFunction · 0.45
mainMethod · 0.45
close_controllerMethod · 0.45
processCatMethod · 0.45
writeWithTabsMethod · 0.45
depthFirstMethod · 0.45
writeDatumMethod · 0.45
preMergeMethod · 0.45
preMergeMethod · 0.45
writeDatumMethod · 0.45
writeTupleMethod · 0.45
spillMethod · 0.45

Calls 11

writeElementsMethod · 0.95
writeBytesMethod · 0.95
writeChararrayMethod · 0.95
writeSignedVarIntMethod · 0.80
writeSignedVarLongMethod · 0.80
writeFloatMethod · 0.80
writeDoubleMethod · 0.80
writeLongMethod · 0.80
writeDatumMethod · 0.65
getOffsetMethod · 0.45

Tested by

no test coverage detected