public class AvroGenericRecordWritable extends Object implements org.apache.hadoop.io.Writable
Constructor and Description |
---|
AvroGenericRecordWritable() |
AvroGenericRecordWritable(org.apache.avro.generic.GenericRecord record) |
AvroGenericRecordWritable(ZoneId writerTimezone) |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.Schema |
getFileSchema() |
org.apache.avro.generic.GenericRecord |
getRecord() |
UID |
getRecordReaderID() |
ZoneId |
getWriterTimezone() |
void |
readFields(byte[] bytes,
int offset,
int length,
org.apache.avro.Schema writerSchema,
org.apache.avro.Schema readerSchema) |
void |
readFields(byte[] bytes,
org.apache.avro.Schema writerSchema,
org.apache.avro.Schema readerSchema) |
void |
readFields(DataInput in) |
void |
setFileSchema(org.apache.avro.Schema originalSchema) |
void |
setRecord(org.apache.avro.generic.GenericRecord record) |
void |
setRecordReaderID(UID recordReaderID) |
void |
write(DataOutput out) |
public AvroGenericRecordWritable()
public AvroGenericRecordWritable(org.apache.avro.generic.GenericRecord record)
public AvroGenericRecordWritable(ZoneId writerTimezone)
public org.apache.avro.generic.GenericRecord getRecord()
public void setRecord(org.apache.avro.generic.GenericRecord record)
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(byte[] bytes, int offset, int length, org.apache.avro.Schema writerSchema, org.apache.avro.Schema readerSchema) throws IOException
IOException
public void readFields(byte[] bytes, org.apache.avro.Schema writerSchema, org.apache.avro.Schema readerSchema) throws IOException
IOException
public UID getRecordReaderID()
public void setRecordReaderID(UID recordReaderID)
public org.apache.avro.Schema getFileSchema()
public void setFileSchema(org.apache.avro.Schema originalSchema)
public ZoneId getWriterTimezone()
Copyright © 2022 The Apache Software Foundation. All rights reserved.