public class AvroSchema2Pig
extends java.lang.Object
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 and Description |
---|
AvroSchema2Pig() |
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
|
public static java.lang.String RECORD
public static java.lang.String FIELD
public static java.lang.String ARRAY_FIELD
public static java.lang.String MAP_VALUE_FIELD
public static ResourceSchema.ResourceFieldSchema getPigSchema(byte pigType, java.lang.String fieldName)
public static ResourceSchema convert(org.apache.avro.Schema schema) throws java.io.IOException
java.io.IOException
protected static void add2BagSchema(ResourceSchema.ResourceFieldSchema fieldSchema, ResourceSchema.ResourceFieldSchema subFieldSchema) throws java.io.IOException
java.io.IOException
Copyright © 2007-2012 The Apache Software Foundation