org.thales.punch.libraries.punchlang.api

Class TupleAvroEncoder

java.lang.Object

org.thales.punch.libraries.punchlang.api.TupleAvroEncoder

public class TupleAvroEncoder
extends Object

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
TupleAvroEncoder(org.apache.avro.Schema schema) Constructor

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TupleAvroEncoder

public TupleAvroEncoder(org.apache.avro.Schema schema)

Constructor

Parameters:

schema - the avro schema

Method Detail

getAvroRecord

public org.apache.avro.generic.GenericRecord getAvroRecord(Tuple tuple)

Parameters:

tuple - the input tuple

Returns:

the avro record

getTuple

public Tuple getTuple(org.apache.avro.generic.GenericData.Record record)

Parameters:

record -

Returns:

the corresponding tuple

startEncoding

public TupleAvroEncoder startEncoding()

write

public TupleAvroEncoder write(Tuple tuple)
                       throws IOException

Throws:

IOException

flush

public byte[] flush()
             throws IOException

Throws:

IOException