|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.avro.generic.GenericDatumWriter<Object>
org.apache.pig.piggybank.storage.avro.PigAvroDatumWriter
public class PigAvroDatumWriter
An avro GenericDatumWriter to write pig data as Avro data.
Constructor Summary | |
---|---|
PigAvroDatumWriter(org.apache.avro.Schema schema)
construct with output schema |
Method Summary | |
---|---|
protected Iterator<? extends Object> |
getArrayElements(Object array)
Called by the implementation of GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to enumerate
array elements. |
protected long |
getArraySize(Object array)
Called by the implementation of GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to get the
size of an array. |
protected Object |
getField(Object record,
String name,
int pos)
Called by the implementation of GenericDatumWriter.writeRecord(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to retrieve
a record field value. |
protected boolean |
instanceOf(org.apache.avro.Schema schema,
Object datum)
Recursively check whether "datum" is an instance of "schema" and called by resolveUnion(Schema,Object) ,
unwrappedInstanceOf(Schema,Object) . |
protected int |
resolveUnion(org.apache.avro.Schema union,
Object datum)
Called to resolve union. |
protected void |
write(org.apache.avro.Schema schema,
Object datum,
org.apache.avro.io.Encoder out)
|
protected void |
writeBoolean(Object datum,
org.apache.avro.io.Encoder out)
Write boolean. |
protected void |
writeBytes(Object datum,
org.apache.avro.io.Encoder out)
Called to write a bytes. |
protected void |
writeDouble(Object datum,
org.apache.avro.io.Encoder out)
Write double. |
protected void |
writeFixed(org.apache.avro.Schema schema,
Object datum,
org.apache.avro.io.Encoder out)
Called to write a fixed value. |
protected void |
writeFloat(Object datum,
org.apache.avro.io.Encoder out)
Write float. |
protected void |
writeLong(Object datum,
org.apache.avro.io.Encoder out)
Write long. |
protected void |
writeUnion(org.apache.avro.Schema schema,
Object datum,
org.apache.avro.io.Encoder out)
Called to write union. |
Methods inherited from class org.apache.avro.generic.GenericDatumWriter |
---|
getMapEntries, getMapSize, setSchema, write, writeArray, writeEnum, writeMap, writeRecord, writeString, writeString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PigAvroDatumWriter(org.apache.avro.Schema schema)
Method Detail |
---|
protected void write(org.apache.avro.Schema schema, Object datum, org.apache.avro.io.Encoder out) throws IOException
write
in class org.apache.avro.generic.GenericDatumWriter<Object>
IOException
protected void writeUnion(org.apache.avro.Schema schema, Object datum, org.apache.avro.io.Encoder out) throws IOException
IOException
protected int resolveUnion(org.apache.avro.Schema union, Object datum) throws IOException
IOException
protected boolean instanceOf(org.apache.avro.Schema schema, Object datum) throws IOException
resolveUnion(Schema,Object)
,
unwrappedInstanceOf(Schema,Object)
.
IOException
protected void writeDouble(Object datum, org.apache.avro.io.Encoder out) throws IOException
IOException
protected void writeFloat(Object datum, org.apache.avro.io.Encoder out) throws IOException
IOException
protected void writeLong(Object datum, org.apache.avro.io.Encoder out) throws IOException
IOException
protected void writeBoolean(Object datum, org.apache.avro.io.Encoder out) throws IOException
IOException
protected void writeBytes(Object datum, org.apache.avro.io.Encoder out) throws IOException
writeBytes
in class org.apache.avro.generic.GenericDatumWriter<Object>
IOException
protected void writeFixed(org.apache.avro.Schema schema, Object datum, org.apache.avro.io.Encoder out) throws IOException
writeFixed
in class org.apache.avro.generic.GenericDatumWriter<Object>
IOException
protected Object getField(Object record, String name, int pos)
GenericDatumWriter.writeRecord(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to retrieve
a record field value.
getField
in class org.apache.avro.generic.GenericDatumWriter<Object>
protected long getArraySize(Object array)
GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to get the
size of an array.
getArraySize
in class org.apache.avro.generic.GenericDatumWriter<Object>
protected Iterator<? extends Object> getArrayElements(Object array)
GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to enumerate
array elements.
getArrayElements
in class org.apache.avro.generic.GenericDatumWriter<Object>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |