|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use LogicalSchema | |
---|---|
org.apache.pig | Public interfaces and classes for Pig. |
org.apache.pig.impl.util | |
org.apache.pig.newplan.logical | |
org.apache.pig.newplan.logical.relational | |
org.apache.pig.newplan.logical.rules | |
org.apache.pig.parser | |
org.apache.pig.pen |
Uses of LogicalSchema in org.apache.pig |
---|
Constructors in org.apache.pig with parameters of type LogicalSchema | |
---|---|
ResourceSchema(LogicalSchema pigSchema)
Construct a ResourceSchema from a LogicalSchema |
|
ResourceSchema(LogicalSchema pigSchema,
SortInfo sortInfo)
Only for use by Pig internal code. |
Uses of LogicalSchema in org.apache.pig.impl.util |
---|
Methods in org.apache.pig.impl.util that return LogicalSchema | |
---|---|
static LogicalSchema |
Utils.parseSchema(String schemaString)
|
Uses of LogicalSchema in org.apache.pig.newplan.logical |
---|
Methods in org.apache.pig.newplan.logical that return LogicalSchema | |
---|---|
static LogicalSchema |
Util.translateSchema(Schema schema)
|
Methods in org.apache.pig.newplan.logical with parameters of type LogicalSchema | |
---|---|
static Schema |
Util.translateSchema(LogicalSchema schema)
This function translates the new LogicalSchema into old Schema format required by PhysicalOperators |
Uses of LogicalSchema in org.apache.pig.newplan.logical.relational |
---|
Fields in org.apache.pig.newplan.logical.relational declared as LogicalSchema | |
---|---|
protected LogicalSchema |
LogicalRelationalOperator.schema
|
LogicalSchema |
LogicalSchema.LogicalFieldSchema.schema
|
Methods in org.apache.pig.newplan.logical.relational that return LogicalSchema | |
---|---|
LogicalSchema |
LogicalSchema.deepCopy()
|
LogicalSchema |
LOForEach.dumpNestedSchema(String alias,
String nestedAlias)
|
LogicalSchema |
LOLoad.getDeterminedSchema()
|
LogicalSchema |
LOInnerLoad.getSchema()
|
LogicalSchema |
LOForEach.getSchema()
|
LogicalSchema |
LOFilter.getSchema()
|
LogicalSchema |
LONative.getSchema()
|
abstract LogicalSchema |
LogicalRelationalOperator.getSchema()
Get the schema for the output of this relational operator. |
LogicalSchema |
LOSort.getSchema()
|
LogicalSchema |
LOSplitOutput.getSchema()
|
LogicalSchema |
LOSplit.getSchema()
|
LogicalSchema |
LOUnion.getSchema()
|
LogicalSchema |
LOStore.getSchema()
|
LogicalSchema |
LOLoad.getSchema()
Get the schema for this load. |
LogicalSchema |
LODistinct.getSchema()
|
LogicalSchema |
LOCogroup.getSchema()
|
LogicalSchema |
LOCross.getSchema()
|
LogicalSchema |
LOGenerate.getSchema()
|
LogicalSchema |
LOStream.getSchema()
|
LogicalSchema |
LOLimit.getSchema()
|
LogicalSchema |
LOJoin.getSchema()
|
static LogicalSchema |
LogicalSchema.merge(LogicalSchema s1,
LogicalSchema s2,
LogicalSchema.MergeMode mode)
Merge two schemas. |
static LogicalSchema |
LogicalSchema.mergeSchemaByAlias(LogicalSchema schema1,
LogicalSchema 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 LogicalSchema |
LogicalSchema.mergeSchemasByAlias(List<LogicalSchema> 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 |
LogicalSchema |
LogicalSchema.mergeUid(LogicalSchema uidOnlySchema)
|
Methods in org.apache.pig.newplan.logical.relational that return types with arguments of type LogicalSchema | |
---|---|
List<LogicalSchema> |
LOGenerate.getOutputPlanSchemas()
Get the output schema corresponding to each input expression plan |
List<LogicalSchema> |
LOGenerate.getUidOnlySchemas()
|
List<LogicalSchema> |
LOGenerate.getUserDefinedSchema()
|
Methods in org.apache.pig.newplan.logical.relational with parameters of type LogicalSchema | |
---|---|
static boolean |
LogicalSchema.castable(LogicalSchema inSch,
LogicalSchema outSch)
Recursively compare two schemas to check if the input schema can be cast to the cast schema |
static boolean |
LogicalSchema.equals(LogicalSchema schema,
LogicalSchema other,
boolean relaxInner,
boolean relaxAlias)
Recursively compare two schemas for equality |
static LogicalSchema |
LogicalSchema.merge(LogicalSchema s1,
LogicalSchema s2,
LogicalSchema.MergeMode mode)
Merge two schemas. |
static LogicalSchema |
LogicalSchema.mergeSchemaByAlias(LogicalSchema schema1,
LogicalSchema 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 |
LogicalSchema |
LogicalSchema.mergeUid(LogicalSchema uidOnlySchema)
|
void |
LogicalRelationalOperator.neverUseForRealSetSchema(LogicalSchema schema)
Only to be used by unit tests. |
void |
LogicalRelationalOperator.setSchema(LogicalSchema schema)
|
void |
LOLoad.setScriptSchema(LogicalSchema schema)
|
Method parameters in org.apache.pig.newplan.logical.relational with type arguments of type LogicalSchema | |
---|---|
static LogicalSchema |
LogicalSchema.mergeSchemasByAlias(List<LogicalSchema> 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 |
void |
LOGenerate.setOutputPlanSchemas(List<LogicalSchema> outputPlanSchemas)
|
void |
LOGenerate.setUidOnlySchemas(List<LogicalSchema> uidOnlySchemas)
|
void |
LOGenerate.setUserDefinedSchema(List<LogicalSchema> userDefinedSchema)
|
Constructors in org.apache.pig.newplan.logical.relational with parameters of type LogicalSchema | |
---|---|
LogicalSchema.LogicalFieldSchema(String alias,
LogicalSchema schema,
byte type)
|
|
LogicalSchema.LogicalFieldSchema(String alias,
LogicalSchema schema,
byte type,
long uid)
|
|
LOLoad(FileSpec loader,
LogicalSchema schema,
LogicalPlan plan,
org.apache.hadoop.conf.Configuration conf)
|
|
LOStream(LogicalPlan plan,
ExecutableManager exeManager,
StreamingCommand cmd,
LogicalSchema schema)
|
Uses of LogicalSchema in org.apache.pig.newplan.logical.rules |
---|
Methods in org.apache.pig.newplan.logical.rules with parameters of type LogicalSchema | |
---|---|
protected Set<Integer> |
ColumnPruneHelper.getColumns(LogicalSchema schema,
Set<Long> uids)
|
Uses of LogicalSchema in org.apache.pig.parser |
---|
Methods in org.apache.pig.parser that return LogicalSchema | |
---|---|
LogicalSchema |
QueryParserDriver.parseSchema(String input)
|
Uses of LogicalSchema in org.apache.pig.pen |
---|
Methods in org.apache.pig.pen that return LogicalSchema | |
---|---|
LogicalSchema |
Illustrator.getSchema()
|
Constructors in org.apache.pig.pen with parameters of type LogicalSchema | |
---|---|
Illustrator(LineageTracer lineage,
LinkedList<IdentityHashSet<Tuple>> equivalenceClasses,
int maxRecords,
IllustratorAttacher attacher,
LogicalSchema schema,
PigContext hadoopPigContext)
|
Constructor parameters in org.apache.pig.pen with type arguments of type LogicalSchema | |
---|---|
IllustratorAttacher(PhysicalPlan plan,
LineageTracer lineage,
int maxRecords,
Map<POLoad,LogicalSchema> poLoadToSchemaMap,
PigContext hadoopPigContext)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |