Modifier and Type | Field and Description |
---|---|
FileSpec |
MapRedResult.outFileSpec |
protected FileSpec |
HJob.outFileSpec |
Modifier and Type | Field and Description |
---|---|
protected Map<FileSpec,Exception> |
Launcher.failureMap |
Constructor and Description |
---|
MapRedResult(FileSpec outFileSpec,
int parallelismRequest) |
Modifier and Type | Method and Description |
---|---|
Exception |
MapReduceLauncher.getError(FileSpec spec)
Get the exception that caused a failure on the backend for a
store location (if any).
|
Modifier and Type | Field and Description |
---|---|
protected FileSpec[] |
POFRJoin.replFiles |
Modifier and Type | Method and Description |
---|---|
FileSpec |
POStore.getInputSpec() |
FileSpec |
POLoad.getLFile() |
FileSpec[] |
POFRJoin.getReplFiles() |
FileSpec |
POStore.getSFile() |
FileSpec |
POSplit.getSplitStore()
Returns the name of the file associated with this operator
|
Modifier and Type | Method and Description |
---|---|
void |
POStore.setInputSpec(FileSpec lFile) |
void |
POLoad.setLFile(FileSpec file) |
void |
POFRJoin.setReplFiles(FileSpec[] replFiles) |
void |
POStore.setSFile(FileSpec sFile) |
void |
POSplit.setSplitStore(FileSpec splitStore)
Sets the name of the file associated with this operator
|
Constructor and Description |
---|
POFRJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
List<List<PhysicalPlan>> ppLists,
List<List<Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple) |
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) |
POLoad(OperatorKey k,
FileSpec lFile) |
POLoad(OperatorKey k,
int rp,
FileSpec lFile) |
Modifier and Type | Method and Description |
---|---|
FileSpec |
TezOperator.VertexGroupInfo.getSFile() |
Modifier and Type | Method and Description |
---|---|
ArrayList<FileSpec> |
TezOperator.LoaderInfo.getInp() |
Modifier and Type | Method and Description |
---|---|
void |
TezOperator.VertexGroupInfo.setSFile(FileSpec sFile) |
Modifier and Type | Method and Description |
---|---|
void |
TezOperator.LoaderInfo.setInp(ArrayList<FileSpec> inp) |
Modifier and Type | Method and Description |
---|---|
static FileSpec |
MapRedUtil.checkLeafIsStore(PhysicalPlan plan,
PigContext pigContext) |
Modifier and Type | Method and Description |
---|---|
void |
SampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
FileSpec |
LOStore.getFileSpec() |
FileSpec |
LOLoad.getFileSpec() |
FileSpec |
LOStore.getInputSpec() |
FileSpec |
LOStore.getOutputSpec() |
Modifier and Type | Method and Description |
---|---|
void |
LOStore.setInputSpec(FileSpec in) |
Constructor and Description |
---|
LOLoad(FileSpec loader,
LogicalSchema schema,
LogicalPlan plan,
org.apache.hadoop.conf.Configuration conf,
LoadFunc loadFunc,
String signature)
Used from the LogicalPlanBuilder
|
LOStore(LogicalPlan plan,
FileSpec outputFileSpec,
StoreFuncInterface storeFunc,
String signature) |
Copyright © 2007-2012 The Apache Software Foundation