List of generateIndexBuildTaskList() Examples

Examples of generateIndexBuildTaskList()

org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()
Requests that the handler generate a plan for building the index; the plan should read the base table and write out the index representation. @param outputs @param inputs @param baseTable the definition of the table being indexed @param index the definition of the index @param indexTblPartitions list of index partitions @param baseTblPartitions list of base table partitions with each element mirrors to the corresponding one in indexTblPartitions @param indexTable the definition of the index table, or null if usesIndexTable() returns null @param inputs inputs for hooks, supplemental outputs going along with the return value @param outputs outputs for hooks, supplemental outputs going along with the return value @return list of tasks to be executed in parallel for building the index @throw HiveException if plan generation fails

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.index.HiveIndexHandler.generateIndexBuildTaskList()

        indexTblPartitions = new ArrayList<Partition>();
        baseTblPartitions = preparePartitions(baseTbl, partSpec,
            indexTbl, db, indexTblPartitions);
      }


      List<Task<?>> ret = handler.generateIndexBuildTaskList(baseTbl,
          index, indexTblPartitions, baseTblPartitions, indexTbl, getInputs(), getOutputs());
      return ret;
    } catch (Exception e) {
      throw new SemanticException(e);
    }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.