(final RecordWriter w)
| 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) |
nothing calls this directly
no test coverage detected