Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.backend.hadoop.accumulo | |
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | |
org.apache.pig.backend.hadoop.hbase | |
org.apache.pig.builtin |
This package contains builtin Pig UDFs.
|
org.apache.pig.data |
This package contains implementations of Pig specific data types as well as
support functions for reading, writing, and using all Pig data types.
|
org.apache.pig.impl.util | |
org.apache.pig.impl.util.hive |
Modifier and Type | Method and Description |
---|---|
ResourceSchema.ResourceFieldSchema[] |
ResourceSchema.getFields()
Get field schema for each field
|
ResourceSchema.ResourceFieldSchema |
ResourceSchema.ResourceFieldSchema.setDescription(java.lang.String description)
Set the description
|
ResourceSchema.ResourceFieldSchema |
ResourceSchema.ResourceFieldSchema.setName(java.lang.String name)
Set the name of this filed.
|
ResourceSchema.ResourceFieldSchema |
ResourceSchema.ResourceFieldSchema.setSchema(ResourceSchema schema)
Set the schema for this field.
|
ResourceSchema.ResourceFieldSchema |
ResourceSchema.ResourceFieldSchema.setType(byte type)
Set the type of this field
|
Modifier and Type | Method and Description |
---|---|
DataBag |
LoadCaster.bytesToBag(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
Cast data from bytearray to bag value.
|
java.util.Map<java.lang.String,java.lang.Object> |
LoadCaster.bytesToMap(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
Cast data from bytearray to map value.
|
Tuple |
LoadCaster.bytesToTuple(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
Cast data from bytearray to tuple value.
|
ResourceSchema |
ResourceSchema.setFields(ResourceSchema.ResourceFieldSchema[] fields)
Set all the fields.
|
Modifier and Type | Method and Description |
---|---|
DataBag |
AccumuloBinaryConverter.bytesToBag(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
NOT IMPLEMENTED
|
java.util.Map<java.lang.String,java.lang.Object> |
AccumuloBinaryConverter.bytesToMap(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
NOT IMPLEMENTED
|
Tuple |
AccumuloBinaryConverter.bytesToTuple(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
NOT IMPLEMENTED
|
protected org.apache.hadoop.io.Text |
AbstractAccumuloStorage.objectToText(java.lang.Object o,
ResourceSchema.ResourceFieldSchema fieldSchema) |
protected byte |
AbstractAccumuloStorage.schemaToType(java.lang.Object o,
int i,
ResourceSchema.ResourceFieldSchema[] fieldSchemas) |
protected byte |
AbstractAccumuloStorage.schemaToType(java.lang.Object o,
ResourceSchema.ResourceFieldSchema fieldSchema) |
protected byte[] |
AbstractAccumuloStorage.tupleToBytes(Tuple tuple,
int i,
ResourceSchema.ResourceFieldSchema[] fieldSchemas) |
protected org.apache.hadoop.io.Text |
AbstractAccumuloStorage.tupleToText(Tuple tuple,
int i,
ResourceSchema.ResourceFieldSchema[] fieldSchemas) |
Modifier and Type | Method and Description |
---|---|
void |
POCast.setFieldSchema(ResourceSchema.ResourceFieldSchema s) |
Modifier and Type | Method and Description |
---|---|
DataBag |
HBaseBinaryConverter.bytesToBag(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
NOT IMPLEMENTED
|
java.util.Map<java.lang.String,java.lang.Object> |
HBaseBinaryConverter.bytesToMap(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema) |
Tuple |
HBaseBinaryConverter.bytesToTuple(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema)
NOT IMPLEMENTED
|
Modifier and Type | Method and Description |
---|---|
DataBag |
Utf8StorageConverter.bytesToBag(byte[] b,
ResourceSchema.ResourceFieldSchema schema) |
DataBag |
TextLoader.bytesToBag(byte[] b,
ResourceSchema.ResourceFieldSchema schema)
TextLoader does not support conversion to Bag
|
java.util.Map<java.lang.String,java.lang.Object> |
Utf8StorageConverter.bytesToMap(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema) |
java.util.Map<java.lang.String,java.lang.Object> |
TextLoader.bytesToMap(byte[] b,
ResourceSchema.ResourceFieldSchema schema) |
Tuple |
Utf8StorageConverter.bytesToTuple(byte[] b,
ResourceSchema.ResourceFieldSchema fieldSchema) |
Tuple |
TextLoader.bytesToTuple(byte[] b,
ResourceSchema.ResourceFieldSchema schema)
TextLoader does not support conversion to Tuple
|
Modifier and Type | Method and Description |
---|---|
static Schema.FieldSchema |
DataType.determineFieldSchema(ResourceSchema.ResourceFieldSchema rcFieldSchema)
Determine the field schema of an ResourceFieldSchema
|
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
CastUtils.convertToType(LoadCaster caster,
byte[] bytes,
ResourceSchema.ResourceFieldSchema fieldSchema,
byte dataType) |
Modifier and Type | Method and Description |
---|---|
static ResourceSchema.ResourceFieldSchema |
HiveUtils.getResourceFieldSchema(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo ti) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo |
HiveUtils.getTypeInfo(ResourceSchema.ResourceFieldSchema fs) |
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo |
HiveUtils.getTypeInfo(ResourceSchema.ResourceFieldSchema fs,
boolean keepSingleFieldTuple) |
Copyright © 2007-2025 The Apache Software Foundation