public class LOLoad extends LogicalRelationalOperator
Modifier and Type | Class and Description |
---|---|
static class |
LOLoad.CastState |
alias, lineNum, mCustomPartitioner, mPinnedOptions, requestedParallelism, schema
Constructor and Description |
---|
LOLoad(FileSpec loader,
LogicalSchema schema,
LogicalPlan plan,
org.apache.hadoop.conf.Configuration conf,
LoadFunc loadFunc,
String signature)
Used from the LogicalPlanBuilder
|
LOLoad(LogicalSchema schema,
LogicalPlan plan)
used for pattern matching
|
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
LOLoad.CastState |
getCastState() |
org.apache.hadoop.conf.Configuration |
getConfiguration() |
LogicalSchema |
getDeterminedSchema() |
FileSpec |
getFileSpec() |
long |
getLimit() |
LoadFunc |
getLoadFunc() |
LogicalSchema |
getSchema()
Get the schema for this load.
|
String |
getSchemaFile() |
LogicalSchema |
getScriptSchema() |
String |
getSignature() |
boolean |
isCastAdjusted() |
boolean |
isEqual(Operator other)
This is like a shallow equals comparison.
|
boolean |
isTmpLoad() |
void |
resetUid()
Erase all cached uid, regenerate uid when we regenerating schema.
|
void |
setCastState(LOLoad.CastState state) |
void |
setLimit(long limit) |
void |
setRequiredFields(List<Integer> requiredFields) |
void |
setScriptSchema(LogicalSchema schema) |
void |
setTmpLoad(boolean isTmpLoad) |
String |
toString() |
checkEquality, fixDuplicateUids, getAlias, getCustomPartitioner, getLineNumber, getRequestedParallelism, isPinnedOption, neverUseForRealSetSchema, pinOption, resetSchema, setAlias, setCustomPartitioner, setRequestedParallelism, setSchema
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public LOLoad(LogicalSchema schema, LogicalPlan plan)
schema
- schema user specified in script, or null if not
specified.plan
- logical plan this load is part of.public LOLoad(FileSpec loader, LogicalSchema schema, LogicalPlan plan, org.apache.hadoop.conf.Configuration conf, LoadFunc loadFunc, String signature)
loader
- FuncSpec for load function to use for this load.schema
- schema user specified in script, or null if not specified.plan
- logical plan this load is part of.conf
- loadFunc
- the LoadFunc that was instantiated from loadersignature
- the signature that will be passed to the LoadFuncpublic String getSchemaFile()
public LoadFunc getLoadFunc() throws FrontendException
FrontendException
public void setScriptSchema(LogicalSchema schema)
public LogicalSchema getSchema() throws FrontendException
getSchema
in class LogicalRelationalOperator
FrontendException
public FileSpec getFileSpec()
public void accept(PlanVisitor v) throws FrontendException
Operator
accept
in class Operator
v
- Visitor to accept.FrontendException
public LogicalSchema getDeterminedSchema()
public boolean isEqual(Operator other) throws FrontendException
Operator
isEqual
in class Operator
FrontendException
public void setCastState(LOLoad.CastState state)
public LOLoad.CastState getCastState()
public boolean isCastAdjusted()
public org.apache.hadoop.conf.Configuration getConfiguration()
public void resetUid()
LogicalRelationalOperator
resetUid
in class LogicalRelationalOperator
public String toString()
toString
in class LogicalRelationalOperator
public String getSignature()
public boolean isTmpLoad()
public void setTmpLoad(boolean isTmpLoad)
public LogicalSchema getScriptSchema()
public long getLimit()
public void setLimit(long limit)
Copyright © 2007-2017 The Apache Software Foundation