public class TupleAvroEncoder extends Object
Constructor and Description |
---|
TupleAvroEncoder(org.apache.avro.Schema schema)
Constructor
|
Modifier and Type | Method and Description |
---|---|
byte[] |
flush() |
org.apache.avro.generic.GenericRecord |
getAvroRecord(Tuple tuple) |
Tuple |
getTuple(org.apache.avro.generic.GenericData.Record record) |
TupleAvroEncoder |
startEncoding() |
TupleAvroEncoder |
write(Tuple tuple) |
public TupleAvroEncoder(org.apache.avro.Schema schema)
schema
- the avro schemapublic org.apache.avro.generic.GenericRecord getAvroRecord(Tuple tuple)
tuple
- the input tuplepublic Tuple getTuple(org.apache.avro.generic.GenericData.Record record)
record
- public TupleAvroEncoder startEncoding()
public TupleAvroEncoder write(Tuple tuple) throws IOException
IOException
public byte[] flush() throws IOException
IOException
Copyright © 2023. All rights reserved.