org.apache.pig.piggybank.storage.avro

Class AvroSchema2Pig

java.lang.Object

org.apache.pig.piggybank.storage.avro.AvroSchema2Pig

public class AvroSchema2Pig
extends java.lang.Object

This class converts Avro schema to Pig schema

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ARRAY_FIELD
static java.lang.String	FIELD
static java.lang.String	MAP_VALUE_FIELD
static java.lang.String	RECORD

Constructor Summary

Constructors

Constructor and Description
AvroSchema2Pig()

Method Summary

Methods

Modifier and Type	Method and Description
protected static void	add2BagSchema(ResourceSchema.ResourceFieldSchema fieldSchema, ResourceSchema.ResourceFieldSchema subFieldSchema) Add a field schema to a bag schema
static ResourceSchema	convert(org.apache.avro.Schema schema) Convert an Avro schema to a Pig schema
static ResourceSchema.ResourceFieldSchema	getPigSchema(byte pigType, java.lang.String fieldName) Wrap a pig type to a field schema

Methods inherited from class java.lang.Object

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

Field Detail

RECORD

public static java.lang.String RECORD

FIELD

public static java.lang.String FIELD

ARRAY_FIELD

public static java.lang.String ARRAY_FIELD

MAP_VALUE_FIELD

public static java.lang.String MAP_VALUE_FIELD

Constructor Detail

AvroSchema2Pig

public AvroSchema2Pig()

Method Detail

getPigSchema

public static ResourceSchema.ResourceFieldSchema getPigSchema(byte pigType,
                                              java.lang.String fieldName)

Wrap a pig type to a field schema

convert

public static ResourceSchema convert(org.apache.avro.Schema schema)
                              throws java.io.IOException

Convert an Avro schema to a Pig schema

Throws:

java.io.IOException

add2BagSchema

protected static void add2BagSchema(ResourceSchema.ResourceFieldSchema fieldSchema,
                 ResourceSchema.ResourceFieldSchema subFieldSchema)
                             throws java.io.IOException

Add a field schema to a bag schema

Throws:

java.io.IOException