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

Method putNext

src/org/apache/pig/impl/streaming/InputHandler.java:69–76  ·  view source on GitHub ↗

Send the given input Tuple to the managed executable. @param t input Tuple @throws IOException

(Tuple t)

Source from the content-addressed store, hash-verified

67 * @throws IOException
68 */
69 public void putNext(Tuple t) throws IOException {
70 if (newSerializer != null) {
71 WritableByteArray buf = newSerializer.serializeToBytes(t);
72 out.write(buf.getData(), 0, buf.getLength());
73 } else {
74 out.write(serializer.serialize(t));
75 }
76 }
77
78 /**
79 * Close the <code>InputHandler</code> since there is no more input

Callers

nothing calls this directly

Calls 5

getDataMethod · 0.95
getLengthMethod · 0.95
serializeMethod · 0.65
serializeToBytesMethod · 0.45
writeMethod · 0.45

Tested by

no test coverage detected