Modifier and Type | Method and Description |
---|---|
Schema |
PigServer.dumpSchema(String alias)
Write the schema for an alias to System.out.
|
Schema |
PigServer.dumpSchemaNested(String alias,
String nestedAlias)
Write the schema for a nestedAlias to System.out.
|
Schema |
FuncSpec.getInputArgsSchema() |
Schema |
EvalFunc.getInputSchema()
This method is intended to be called by the user in
EvalFunc to get the input
schema of the EvalFunc |
Schema |
EvalFunc.outputSchema(Schema input)
Report the schema of the output of this UDF.
|
Modifier and Type | Method and Description |
---|---|
protected String |
EvalFunc.getSchemaName(String name,
Schema input) |
Schema |
EvalFunc.outputSchema(Schema input)
Report the schema of the output of this UDF.
|
void |
FuncSpec.setInputArgsSchema(Schema inputArgsSchema) |
void |
EvalFunc.setInputSchema(Schema input)
This method is for internal use.
|
Constructor and Description |
---|
FuncSpec(String funcSpec,
Schema inputArgsSchema) |
FuncSpec(String className,
String[] ctorArgs,
Schema inputArgsSchema) |
ResourceSchema(Schema pigSchema)
Construct a ResourceSchema from a
Schema |
ResourceSchema(Schema pigSchema,
SortInfo sortInfo)
Only for use by Pig internal code.
|
Modifier and Type | Method and Description |
---|---|
Schema |
POUserFunc.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
POUserFunc.outputSchema(Schema input) |
Modifier and Type | Field and Description |
---|---|
protected Schema[] |
POFRJoin.inputSchemas |
protected Schema[] |
POFRJoin.keySchemas |
Modifier and Type | Method and Description |
---|---|
Schema |
POStore.getSchema() |
Schema |
POSkewedJoin.getSchema(int i) |
Modifier and Type | Method and Description |
---|---|
void |
POSkewedJoin.addSchema(Schema s) |
void |
POStore.setSchema(Schema schema) |
Constructor and Description |
---|
POForEach(OperatorKey operatorKey,
int requestedParallelism,
List<PhysicalPlan> innerPlans,
List<Boolean> flattenList,
Schema schema) |
POFRJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
List<List<PhysicalPlan>> ppLists,
List<List<Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple,
Schema[] inputSchemas,
Schema[] keySchemas) |
POFRJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
List<List<PhysicalPlan>> ppLists,
List<List<Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple,
Schema[] inputSchemas,
Schema[] keySchemas) |
POMergeJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
MultiMap<PhysicalOperator,PhysicalPlan> inpPlans,
List<List<Byte>> keyTypes,
LOJoin.JOINTYPE joinType,
Schema leftInputSchema,
Schema rightInputSchema,
Schema mergedInputSchema) |
Modifier and Type | Method and Description |
---|---|
Schema |
Storage.Data.getSchema(String location) |
static Schema |
Storage.schema(String schema) |
Modifier and Type | Method and Description |
---|---|
void |
Storage.Data.set(String location,
Schema schema,
Collection<Tuple> data)
to set the data in a location with a known schema
|
void |
Storage.Data.set(String location,
Schema schema,
Tuple... data)
to set the data in a location with a known schema
|
void |
Storage.Data.setSchema(String location,
Schema schema)
to set the schema for a given location
|
Modifier and Type | Method and Description |
---|---|
Schema |
TypeAwareTuple.getSchema() |
protected static Schema |
SchemaTuple.staticSchemaGen(String s) |
Modifier and Type | Method and Description |
---|---|
protected static void |
SchemaTupleClassGenerator.generateSchemaTuple(Schema s,
boolean appendable,
int id,
File codeDir,
SchemaTupleClassGenerator.GenContext... contexts)
This class actually generates the code for a given Schema.
|
static SchemaTupleFactory |
SchemaTupleFactory.getInstance(Schema s) |
static SchemaTupleFactory |
SchemaTupleFactory.getInstance(Schema s,
boolean isAppendable) |
static SchemaTupleFactory |
SchemaTupleFactory.getInstance(Schema s,
boolean isAppendable,
SchemaTupleClassGenerator.GenContext context)
This method is the publicly facing method which returns a SchemaTupleFactory
which will generate SchemaTuples of the given Schema.
|
static boolean |
SchemaTupleFactory.isGeneratable(Schema s)
This method inspects a Schema to see whether or
not a SchemaTuple implementation can be generated
for the types present.
|
static SchemaTupleFactory |
SchemaTupleBackend.newSchemaTupleFactory(Schema s,
boolean isAppendable,
SchemaTupleClassGenerator.GenContext context) |
static int |
SchemaTupleFrontend.registerToGenerateIfPossible(Schema udfSchema,
boolean isAppendable,
SchemaTupleClassGenerator.GenContext context)
This method "registers" a Schema to be generated.
|
Modifier and Type | Method and Description |
---|---|
Schema |
StructuresHelper.SchemaKey.get() |
Modifier and Type | Method and Description |
---|---|
static int |
StructuresHelper.SchemaKey.hashCode(Schema s) |
Constructor and Description |
---|
SchemaKey(Schema s) |
Modifier and Type | Method and Description |
---|---|
Schema |
StreamingUDF.outputSchema(Schema input) |
Schema |
IdentityColumn.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
StreamingUDF.outputSchema(Schema input) |
Schema |
IdentityColumn.outputSchema(Schema input) |
Modifier and Type | Field and Description |
---|---|
Schema |
Schema.FieldSchema.schema
If this is a tuple itself, it can have a schema.
|
Modifier and Type | Method and Description |
---|---|
Schema |
Schema.clone()
Make a deep copy of a schema.
|
static Schema |
Schema.generateNestedSchema(byte topLevelType,
byte... innerTypes) |
static Schema |
Schema.getPigSchema(ResourceSchema rSchema) |
Schema |
Schema.merge(Schema other,
boolean otherTakesAliasPrecedence)
Merge this schema with the other schema
|
Schema |
Schema.mergePrefixSchema(Schema other,
boolean otherTakesAliasPrecedence)
Recursively prefix merge two schemas
|
Schema |
Schema.mergePrefixSchema(Schema other,
boolean otherTakesAliasPrecedence,
boolean allowMergeableTypes)
Recursively prefix merge two schemas
|
static Schema |
Schema.mergeSchema(Schema schema,
Schema other,
boolean otherTakesAliasPrecedence)
Recursively merge two schemas
|
static Schema |
Schema.mergeSchema(Schema schema,
Schema other,
boolean otherTakesAliasPrecedence,
boolean allowDifferentSizeMerge,
boolean allowIncompatibleTypes)
Recursively merge two schemas
|
static Schema |
Schema.mergeSchemaByAlias(Schema schema1,
Schema schema2)
Merges two schemas using their column aliases
(unlike mergeSchema(..) functions which merge using positions)
Schema will not be merged if types are incompatible,
as per DataType.mergeType(..)
For Tuples and Bags, SubSchemas have to be equal be considered compatible
|
static Schema |
Schema.mergeSchemasByAlias(Collection<Schema> schemas)
Merges collection of schemas using their column aliases
(unlike mergeSchema(..) functions which merge using positions)
Schema will not be merged if types are incompatible,
as per DataType.mergeType(..)
For Tuples and Bags, SubSchemas have to be equal be considered compatible
|
static Schema |
SchemaUtil.newBagSchema(Byte[] dataTypes)
Create a new tuple schema according one array: the type of fields, the
tuple name is t, and the bag name is b.
|
static Schema |
SchemaUtil.newBagSchema(List<Byte> dataTypes)
Create a new tuple schema according one list: types of fields, the
default names of fields are f0,f1,f2..., and the tuple is t, the bag name
is b.
|
static Schema |
SchemaUtil.newBagSchema(List<String> names,
List<Byte> dataTypes)
Create a bag schema according two list: name of fields, type of fields,
and the default bag name is b, the default tuple name is t.
|
static Schema |
SchemaUtil.newBagSchema(String[] names,
Byte[] dataTypes)
Create a new tuple schema according two arrays: names of field,types of
fields.
|
static Schema |
SchemaUtil.newBagSchema(String bagName,
String tupleName,
List<String> fieldNames,
List<Byte> dataTypes)
Create a bag schema according the bag name,tuple name and two list: name
of fields, type of fields
|
static Schema |
SchemaUtil.newBagSchema(String bagName,
String tupleName,
String[] fieldNames,
Byte[] dataTypes) |
static Schema |
SchemaUtil.newTupleSchema(Byte[] dataTypes)
Create a new tuple schema according one array: types of fields, the
default names of fields are f0,f1,f2..., and the tuple name is t.
|
static Schema |
SchemaUtil.newTupleSchema(List<Byte> dataTypes)
Create a new tuple schema according one list: types of fields, the
default names of fields are f0,f1,f2..., and the tuple name is t.
|
static Schema |
SchemaUtil.newTupleSchema(List<String> fieldNames,
List<Byte> dataTypes)
Create a new tuple schema according the two list: names of fields, types
of fields, the default tuple name is t.
|
static Schema |
SchemaUtil.newTupleSchema(String[] names,
Byte[] dataTypes)
Create a new tuple schema according the two arrays: names of fields,
types of fields, the default tuple name is t.
|
static Schema |
SchemaUtil.newTupleSchema(String tupleName,
List<String> fieldNames,
List<Byte> dataTypes)
Create a new tuple schema according the tuple name and two list: names of
fields, types of fields
|
static Schema |
SchemaUtil.newTupleSchema(String tupleName,
String[] fieldNames,
Byte[] dataTypes)
Create a new tuple schema according the tuple name and two arrays: names
of fields, types of fields
|
Modifier and Type | Method and Description |
---|---|
static boolean |
Schema.castable(Schema cast,
Schema input)
Recursively compare two schemas to check if the input schema
can be cast to the cast schema
|
static boolean |
Schema.equals(Schema schema,
Schema other,
boolean relaxInner,
boolean relaxAlias)
Recursively compare two schemas for equality
|
Schema |
Schema.merge(Schema other,
boolean otherTakesAliasPrecedence)
Merge this schema with the other schema
|
Schema |
Schema.mergePrefixSchema(Schema other,
boolean otherTakesAliasPrecedence)
Recursively prefix merge two schemas
|
Schema |
Schema.mergePrefixSchema(Schema other,
boolean otherTakesAliasPrecedence,
boolean allowMergeableTypes)
Recursively prefix merge two schemas
|
static Schema |
Schema.mergeSchema(Schema schema,
Schema other,
boolean otherTakesAliasPrecedence)
Recursively merge two schemas
|
static Schema |
Schema.mergeSchema(Schema schema,
Schema other,
boolean otherTakesAliasPrecedence,
boolean allowDifferentSizeMerge,
boolean allowIncompatibleTypes)
Recursively merge two schemas
|
static Schema |
Schema.mergeSchemaByAlias(Schema schema1,
Schema schema2)
Merges two schemas using their column aliases
(unlike mergeSchema(..) functions which merge using positions)
Schema will not be merged if types are incompatible,
as per DataType.mergeType(..)
For Tuples and Bags, SubSchemas have to be equal be considered compatible
|
void |
Schema.reconcile(Schema other)
Reconcile this schema with another schema.
|
static void |
Schema.setSchemaDefaultType(Schema s,
byte t)
Recursively set NULL type to the specifid type in a schema
|
static void |
Schema.stringifySchema(StringBuilder sb,
Schema schema,
byte type) |
static void |
Schema.stringifySchema(StringBuilder sb,
Schema schema,
byte type,
int indentLevel) |
Modifier and Type | Method and Description |
---|---|
static Schema |
Schema.mergeSchemasByAlias(Collection<Schema> schemas)
Merges collection of schemas using their column aliases
(unlike mergeSchema(..) functions which merge using positions)
Schema will not be merged if types are incompatible,
as per DataType.mergeType(..)
For Tuples and Bags, SubSchemas have to be equal be considered compatible
|
Constructor and Description |
---|
FieldSchema(String a,
Schema s)
Constructor for tuple fields.
|
FieldSchema(String a,
Schema s,
byte t)
Constructor for tuple fields.
|
Schema(Schema s)
Copy Constructor.
|
Modifier and Type | Method and Description |
---|---|
static Schema |
Utils.getSchemaFromBagSchemaString(String schemaString)
getSchemaFromBagSchemaString
NOTE: use this call when you need to generate a Schema object
from the representation generated by
Schema#toString . |
static Schema |
Utils.getSchemaFromString(String schemaString) |
static Schema |
Utils.getScriptSchema(String loadFuncSignature,
org.apache.hadoop.conf.Configuration conf)
A helper function for retrieving the script schema set by the LOLoad
function.
|
Modifier and Type | Method and Description |
---|---|
static void |
CompilerUtils.addEmptyBagOuterJoin(PhysicalPlan fePlan,
Schema inputSchema,
boolean skewedRightOuterJoin,
String isFirstReduceOfKeyClassName) |
Modifier and Type | Method and Description |
---|---|
static Schema |
Util.fixSchemaAddTupleInBag(Schema sch)
If schema argument has fields where a bag does not contain a tuple schema,
it inserts a tuple schema.
|
static Schema |
Util.translateSchema(LogicalSchema schema)
This function translates the new LogicalSchema into old Schema format required
by PhysicalOperators
|
Modifier and Type | Method and Description |
---|---|
static Schema |
Util.fixSchemaAddTupleInBag(Schema sch)
If schema argument has fields where a bag does not contain a tuple schema,
it inserts a tuple schema.
|
static LogicalSchema |
Util.translateSchema(Schema schema) |
Modifier and Type | Method and Description |
---|---|
static boolean |
TypeCheckingExpVisitor.schemaEqualsForMatching(Schema inputSchema,
Schema udfSchema,
EvalFunc.SchemaType udfSchemaType,
boolean ignoreByteArrays)
Compare two schemas for equality for argument matching purposes.
|
Modifier and Type | Method and Description |
---|---|
Schema |
Stitch.outputSchema(Schema inputSch) |
Schema |
Over.outputSchema(Schema inputSch) |
Schema |
MaxTupleBy1stField.outputSchema(Schema input) |
Schema |
IsNumeric.outputSchema(Schema input) |
Schema |
IsLong.outputSchema(Schema input) |
Schema |
IsInt.outputSchema(Schema input) |
Schema |
IsFloat.outputSchema(Schema input) |
Schema |
IsDouble.outputSchema(Schema input) |
Schema |
ExtremalTupleByNthField.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
Stitch.outputSchema(Schema inputSch) |
Schema |
Over.outputSchema(Schema inputSch) |
Schema |
MaxTupleBy1stField.outputSchema(Schema input) |
Schema |
IsNumeric.outputSchema(Schema input) |
Schema |
IsLong.outputSchema(Schema input) |
Schema |
IsInt.outputSchema(Schema input) |
Schema |
IsFloat.outputSchema(Schema input) |
Schema |
IsDouble.outputSchema(Schema input) |
Schema |
ExtremalTupleByNthField.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
DiffDate.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
DiffDate.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
UnixToISO.outputSchema(Schema input) |
Schema |
ISOToUnix.outputSchema(Schema input) |
Schema |
CustomFormatToISO.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
UnixToISO.outputSchema(Schema input) |
Schema |
ISOToUnix.outputSchema(Schema input) |
Schema |
CustomFormatToISO.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
ISOYearsBetween.outputSchema(Schema input) |
Schema |
ISOSecondsBetween.outputSchema(Schema input) |
Schema |
ISOMonthsBetween.outputSchema(Schema input) |
Schema |
ISOMinutesBetween.outputSchema(Schema input) |
Schema |
ISOHoursBetween.outputSchema(Schema input) |
Schema |
ISODaysBetween.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
ISOYearsBetween.outputSchema(Schema input) |
Schema |
ISOSecondsBetween.outputSchema(Schema input) |
Schema |
ISOMonthsBetween.outputSchema(Schema input) |
Schema |
ISOMinutesBetween.outputSchema(Schema input) |
Schema |
ISOHoursBetween.outputSchema(Schema input) |
Schema |
ISODaysBetween.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
ISOToYear.outputSchema(Schema input) |
Schema |
ISOToWeek.outputSchema(Schema input) |
Schema |
ISOToSecond.outputSchema(Schema input) |
Schema |
ISOToMonth.outputSchema(Schema input) |
Schema |
ISOToMinute.outputSchema(Schema input) |
Schema |
ISOToHour.outputSchema(Schema input) |
Schema |
ISOToDay.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
ISOToYear.outputSchema(Schema input) |
Schema |
ISOToWeek.outputSchema(Schema input) |
Schema |
ISOToSecond.outputSchema(Schema input) |
Schema |
ISOToMonth.outputSchema(Schema input) |
Schema |
ISOToMinute.outputSchema(Schema input) |
Schema |
ISOToHour.outputSchema(Schema input) |
Schema |
ISOToDay.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
Decode.outputSchema(Schema input) |
Schema |
BinCond.outputSchema(Schema input) |
Schema |
Bin.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
Decode.outputSchema(Schema input) |
Schema |
BinCond.outputSchema(Schema input) |
Schema |
Bin.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
COV.outputSchema(Schema input)
Deprecated.
|
Schema |
COR.outputSchema(Schema input)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Schema |
COV.outputSchema(Schema input)
Deprecated.
|
Schema |
COR.outputSchema(Schema input)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Schema |
UPPER.outputSchema(Schema input)
Deprecated.
This method gives a name to the column.
|
Schema |
Stuff.outputSchema(Schema input) |
Schema |
Reverse.outputSchema(Schema input) |
Schema |
RegexMatch.outputSchema(Schema input) |
Schema |
RegexExtractAll.outputSchema(Schema input)
Deprecated.
|
Schema |
RegexExtract.outputSchema(Schema input)
Deprecated.
|
Schema |
REPLACE_MULTI.outputSchema(Schema input) |
Schema |
LookupInFiles.outputSchema(Schema input) |
Schema |
LENGTH.outputSchema(Schema input) |
Schema |
HashFNV.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
UPPER.outputSchema(Schema input)
Deprecated.
This method gives a name to the column.
|
Schema |
Stuff.outputSchema(Schema input) |
Schema |
Reverse.outputSchema(Schema input) |
Schema |
RegexMatch.outputSchema(Schema input) |
Schema |
RegexExtractAll.outputSchema(Schema input)
Deprecated.
|
Schema |
RegexExtract.outputSchema(Schema input)
Deprecated.
|
Schema |
REPLACE_MULTI.outputSchema(Schema input) |
Schema |
LookupInFiles.outputSchema(Schema input) |
Schema |
LENGTH.outputSchema(Schema input) |
Schema |
HashFNV.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
Top.outputSchema(Schema input)
Deprecated.
|
Schema |
ToTuple.outputSchema(Schema input)
Deprecated.
|
Schema |
SearchQuery.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
Top.outputSchema(Schema input)
Deprecated.
|
Schema |
ToTuple.outputSchema(Schema input)
Deprecated.
|
Schema |
SearchQuery.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
GroovyEvalFunc.outputSchema(Schema input) |
Schema |
GroovyAccumulatorEvalFunc.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
GroovyEvalFunc.outputSchema(Schema input) |
Schema |
GroovyAccumulatorEvalFunc.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
RubySchema.getInternalSchema()
This is a helper method to pull out the native Java type from the ruby object.
|
Schema |
JrubyEvalFunc.outputSchema(Schema input)
This method uses the schema method of the function encapsulation object to get the Schema information for
the Ruby method.
|
Schema |
JrubyAccumulatorEvalFunc.outputSchema(Schema input)
This provides the Schema of the output, and leverages the get_output_schema function on the class object
that is defined on the ruby side.
|
static Schema |
RubySchema.rubyArgToSchema(Object arg)
This is a helper function which converts objects into Schema objects.
|
static Schema |
PigJrubyLibrary.rubyToPig(RubySchema rbObject)
A type specific conversion routine.
|
Modifier and Type | Method and Description |
---|---|
Schema |
JrubyEvalFunc.outputSchema(Schema input)
This method uses the schema method of the function encapsulation object to get the Schema information for
the Ruby method.
|
Schema |
JrubyAccumulatorEvalFunc.outputSchema(Schema input)
This provides the Schema of the output, and leverages the get_output_schema function on the class object
that is defined on the ruby side.
|
static RubySchema |
PigJrubyLibrary.pigToRuby(org.jruby.Ruby ruby,
Schema object)
A type specific conversion routine.
|
Constructor and Description |
---|
RubySchema(org.jruby.Ruby ruby,
org.jruby.RubyClass rc,
Schema s)
This constructor sets the encapsulated Schema to be equal to the
given Schema.
|
RubySchema(org.jruby.Ruby ruby,
org.jruby.RubyClass rc,
Schema s,
boolean copy)
This constructor sets the encapsulated Schema to be equal to
the given Schema.
|
Modifier and Type | Method and Description |
---|---|
Schema |
JsFunction.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
JsFunction.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
JythonFunction.outputSchema(Schema input) |
Modifier and Type | Method and Description |
---|---|
Schema |
JythonFunction.outputSchema(Schema input) |
Copyright © 2007-2017 The Apache Software Foundation