|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of FileSpec in org.apache.pig.backend.hadoop.executionengine |
---|
Fields in org.apache.pig.backend.hadoop.executionengine declared as FileSpec | |
---|---|
FileSpec |
MapRedResult.outFileSpec
|
protected FileSpec |
HJob.outFileSpec
|
Constructors in org.apache.pig.backend.hadoop.executionengine with parameters of type FileSpec | |
---|---|
MapRedResult(FileSpec outFileSpec,
int parallelismRequest)
|
Uses of FileSpec in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type FileSpec | |
---|---|
Exception |
MapReduceLauncher.getError(FileSpec spec)
Get the exception that caused a failure on the backend for a store location (if any). |
Uses of FileSpec in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return FileSpec | |
---|---|
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 |
Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type FileSpec | |
---|---|
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 |
Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type FileSpec | |
---|---|
POFRJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
List<List<PhysicalPlan>> ppLists,
List<List<Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple)
|
|
POLoad(OperatorKey k,
FileSpec lFile)
|
|
POLoad(OperatorKey k,
int rp,
FileSpec lFile)
|
Uses of FileSpec in org.apache.pig.backend.hadoop.executionengine.util |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.util that return FileSpec | |
---|---|
static FileSpec |
MapRedUtil.checkLeafIsStore(PhysicalPlan plan,
PigContext pigContext)
|
Uses of FileSpec in org.apache.pig.impl.builtin |
---|
Method parameters in org.apache.pig.impl.builtin with type arguments of type FileSpec | |
---|---|
void |
SampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs,
PigContext pc)
|
void |
PoissonSampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs,
PigContext pc)
Computes the number of samples for the loader |
Uses of FileSpec in org.apache.pig.newplan.logical.relational |
---|
Methods in org.apache.pig.newplan.logical.relational that return FileSpec | |
---|---|
FileSpec |
LOStore.getFileSpec()
|
FileSpec |
LOLoad.getFileSpec()
|
FileSpec |
LOStore.getInputSpec()
|
FileSpec |
LOStore.getOutputSpec()
|
Methods in org.apache.pig.newplan.logical.relational with parameters of type FileSpec | |
---|---|
void |
LOStore.setInputSpec(FileSpec in)
|
Constructors in org.apache.pig.newplan.logical.relational with parameters of type FileSpec | |
---|---|
LOLoad(FileSpec loader,
LogicalSchema schema,
LogicalPlan plan,
org.apache.hadoop.conf.Configuration conf)
|
|
LOStore(LogicalPlan plan,
FileSpec outputFileSpec)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |