public class AvroWriteSupport extends WriteSupport<org.apache.avro.generic.IndexedRecord>
WriteSupport
for IndexedRecord
s - both Avro Generic and Specific.
Users should use AvroParquetWriter
or AvroParquetOutputFormat
rather than using
this class directly.WriteSupport.WriteContext
Constructor and Description |
---|
AvroWriteSupport() |
AvroWriteSupport(MessageType schema,
org.apache.avro.Schema avroSchema) |
Modifier and Type | Method and Description |
---|---|
WriteSupport.WriteContext |
init(org.apache.hadoop.conf.Configuration configuration)
called first in the task
|
void |
prepareForWrite(RecordConsumer recordConsumer)
This will be called once per row group
|
static void |
setSchema(org.apache.hadoop.conf.Configuration configuration,
org.apache.avro.Schema schema) |
void |
write(org.apache.avro.generic.IndexedRecord record)
called once per record
|
public AvroWriteSupport()
public AvroWriteSupport(MessageType schema, org.apache.avro.Schema avroSchema)
public static void setSchema(org.apache.hadoop.conf.Configuration configuration, org.apache.avro.Schema schema)
public WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)
WriteSupport
init
in class WriteSupport<org.apache.avro.generic.IndexedRecord>
configuration
- the job's configurationpublic void prepareForWrite(RecordConsumer recordConsumer)
WriteSupport
prepareForWrite
in class WriteSupport<org.apache.avro.generic.IndexedRecord>
recordConsumer
- the recordConsumer to write topublic void write(org.apache.avro.generic.IndexedRecord record)
WriteSupport
write
in class WriteSupport<org.apache.avro.generic.IndexedRecord>
record
- one record to write to the previously provided record consumerCopyright © 2015. All rights reserved.