| 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() | 
| static FileSpec | TezCompiler. getTempFileSpec(PigContext pigContext)Returns a temporary DFS Path | 
| 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) | 
| LOStore(LogicalPlan plan,
       FileSpec outputFileSpec,
       StoreFuncInterface storeFunc,
       String signature,
       boolean disambiguationEnabled) | 
Copyright © 2007-2017 The Apache Software Foundation