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

Method prepareToWrite

src/org/apache/pig/builtin/AvroStorage.java:505–512  ·  view source on GitHub ↗
(final RecordWriter w)

Source from the content-addressed store, hash-verified

503 * .RecordWriter)
504 */
505 @SuppressWarnings({ "unchecked", "rawtypes" })
506 @Override
507 public final void prepareToWrite(final RecordWriter w) throws IOException {
508 if (this.udfContextSignature == null)
509 throw new IOException(this.getClass().toString() + ".prepareToWrite called without setting udf context signature");
510 writer = (RecordWriter<NullWritable, Object>) w;
511 ((AvroRecordWriter) writer).prepareToWrite(getOutputAvroSchema());
512 }
513
514 /*
515 * @see org.apache.pig.StoreFuncInterface#putNext(org.apache.pig.data.Tuple)

Callers

nothing calls this directly

Calls 4

getOutputAvroSchemaMethod · 0.95
getClassMethod · 0.80
prepareToWriteMethod · 0.65
toStringMethod · 0.45

Tested by

no test coverage detected