|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ResourceSchema | |
---|---|
org.apache.hadoop.zebra.pig | Implementation of PIG Storer/Loader Interfaces |
org.apache.pig | Public interfaces and classes for Pig. |
org.apache.pig.backend.hadoop.hbase | |
org.apache.pig.builtin | This package contains builtin Pig UDFs. |
org.apache.pig.builtin.mock | |
org.apache.pig.impl.io | |
org.apache.pig.impl.logicalLayer.schema | |
org.apache.pig.impl.util | |
org.apache.pig.piggybank.storage | |
org.apache.pig.piggybank.storage.avro |
Uses of ResourceSchema in org.apache.hadoop.zebra.pig |
---|
Methods in org.apache.hadoop.zebra.pig that return ResourceSchema | |
---|---|
ResourceSchema |
TableLoader.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
Methods in org.apache.hadoop.zebra.pig with parameters of type ResourceSchema | |
---|---|
void |
TableStorer.checkSchema(ResourceSchema schema)
|
void |
TableStorer.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
Uses of ResourceSchema in org.apache.pig |
---|
Methods in org.apache.pig that return ResourceSchema | |
---|---|
ResourceSchema |
ResourceSchema.ResourceFieldSchema.getSchema()
Get the schema for this field. |
ResourceSchema |
LoadMetadata.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
Get a schema for the data to be loaded. |
ResourceSchema |
ResourceSchema.setFields(ResourceSchema.ResourceFieldSchema[] fields)
Set all the fields. |
ResourceSchema |
ResourceSchema.setSortKeyOrders(ResourceSchema.Order[] sortKeyOrders)
Set the order for each sort key. |
ResourceSchema |
ResourceSchema.setSortKeys(int[] sortKeys)
Set the sort keys for htis data. |
ResourceSchema |
ResourceSchema.setVersion(int version)
|
Methods in org.apache.pig with parameters of type ResourceSchema | |
---|---|
void |
StoreFuncWrapper.checkSchema(ResourceSchema resourceSchema)
|
void |
StoreFuncInterface.checkSchema(ResourceSchema s)
Set the schema for data to be stored. |
void |
StoreFunc.checkSchema(ResourceSchema s)
Set the schema for data to be stored. |
static boolean |
ResourceSchema.equals(ResourceSchema rs1,
ResourceSchema rs2)
Test whether two ResourceSchemas are the same. |
ResourceSchema.ResourceFieldSchema |
ResourceSchema.ResourceFieldSchema.setSchema(ResourceSchema schema)
Set the schema for this field. |
void |
StoreMetadata.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
Store schema of the data being written |
void |
StoreFuncMetadataWrapper.storeSchema(ResourceSchema resourceSchema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
Uses of ResourceSchema in org.apache.pig.backend.hadoop.hbase |
---|
Methods in org.apache.pig.backend.hadoop.hbase with parameters of type ResourceSchema | |
---|---|
void |
HBaseStorage.checkSchema(ResourceSchema s)
|
Uses of ResourceSchema in org.apache.pig.builtin |
---|
Fields in org.apache.pig.builtin declared as ResourceSchema | |
---|---|
protected ResourceSchema |
PigStorage.schema
|
protected ResourceSchema |
JsonStorage.schema
|
protected ResourceSchema |
JsonLoader.schema
|
Methods in org.apache.pig.builtin that return ResourceSchema | |
---|---|
ResourceSchema |
PigStorage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
JsonMetadata.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
For JsonMetadata schema is considered optional This method suppresses (and logs) errors if they are encountered. |
ResourceSchema |
JsonLoader.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
BinStorage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
JsonMetadata.getSchema(String location,
org.apache.hadoop.mapreduce.Job job,
boolean isSchemaOn)
Read the schema from json metadata file If isSchemaOn parameter is false, the errors are suppressed and logged |
Methods in org.apache.pig.builtin with parameters of type ResourceSchema | |
---|---|
void |
PigStorage.checkSchema(ResourceSchema s)
|
void |
JsonStorage.checkSchema(ResourceSchema s)
|
void |
BinStorage.checkSchema(ResourceSchema s)
|
void |
PigStorage.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
void |
JsonStorage.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
void |
JsonMetadata.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
Uses of ResourceSchema in org.apache.pig.builtin.mock |
---|
Methods in org.apache.pig.builtin.mock that return ResourceSchema | |
---|---|
ResourceSchema |
Storage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
Methods in org.apache.pig.builtin.mock with parameters of type ResourceSchema | |
---|---|
void |
Storage.checkSchema(ResourceSchema s)
|
void |
Storage.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
Uses of ResourceSchema in org.apache.pig.impl.io |
---|
Methods in org.apache.pig.impl.io that return ResourceSchema | |
---|---|
ResourceSchema |
TFileStorage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
ReadToEndLoader.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
InterStorage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
Methods in org.apache.pig.impl.io with parameters of type ResourceSchema | |
---|---|
void |
TFileStorage.checkSchema(ResourceSchema s)
|
void |
InterStorage.checkSchema(ResourceSchema s)
|
Uses of ResourceSchema in org.apache.pig.impl.logicalLayer.schema |
---|
Methods in org.apache.pig.impl.logicalLayer.schema with parameters of type ResourceSchema | |
---|---|
static Schema |
Schema.getPigSchema(ResourceSchema rSchema)
|
Uses of ResourceSchema in org.apache.pig.impl.util |
---|
Methods in org.apache.pig.impl.util that return ResourceSchema | |
---|---|
static ResourceSchema |
Utils.getSchema(LoadFunc wrappedLoadFunc,
String location,
boolean checkExistence,
org.apache.hadoop.mapreduce.Job job)
|
static ResourceSchema |
Utils.getSchemaWithInputSourceTag(ResourceSchema schema)
This method adds FieldSchema of 'input source tag/path' as the first field. |
Methods in org.apache.pig.impl.util with parameters of type ResourceSchema | |
---|---|
static ResourceSchema |
Utils.getSchemaWithInputSourceTag(ResourceSchema schema)
This method adds FieldSchema of 'input source tag/path' as the first field. |
Uses of ResourceSchema in org.apache.pig.piggybank.storage |
---|
Methods in org.apache.pig.piggybank.storage that return ResourceSchema | |
---|---|
ResourceSchema |
AllLoader.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
ResourceSchema |
HiveColumnarLoader.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
|
Methods in org.apache.pig.piggybank.storage with parameters of type ResourceSchema | |
---|---|
void |
AllLoader.storeSchema(ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
|
Uses of ResourceSchema in org.apache.pig.piggybank.storage.avro |
---|
Methods in org.apache.pig.piggybank.storage.avro that return ResourceSchema | |
---|---|
static ResourceSchema |
AvroSchema2Pig.convert(org.apache.avro.Schema schema)
Convert an Avro schema to a Pig schema |
ResourceSchema |
AvroStorage.getSchema(String location,
org.apache.hadoop.mapreduce.Job job)
Get avro schema from "location" and return the converted PigSchema. |
Methods in org.apache.pig.piggybank.storage.avro with parameters of type ResourceSchema | |
---|---|
void |
AvroStorage.checkSchema(ResourceSchema s)
Append newly specified schema |
static org.apache.avro.Schema |
PigSchema2Avro.convert(ResourceSchema pigSchema,
boolean nullable)
Convert a pig ResourceSchema to avro schema |
static org.apache.avro.Schema |
PigSchema2Avro.validateAndConvert(org.apache.avro.Schema avroSchema,
ResourceSchema pigSchema)
Validate whether pigSchema is compatible with avroSchema |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |