Examples of MStorageDescriptor

org.apache.hadoop.hive.metastore.model.MStorageDescriptor

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

  private MStorageDescriptor convertToMStorageDescriptor(StorageDescriptor sd)
      throws MetaException {
    if (sd == null) {
      return null;
    }
    return new MStorageDescriptor(convertToMFieldSchemas(sd.getCols()), sd
        .getLocation(), sd.getInputFormat(), sd.getOutputFormat(), sd
        .isCompressed(), sd.getNumBuckets(), converToMSerDeInfo(sd
        .getSerdeInfo()), sd.getBucketCols(),
        convertToMOrders(sd.getSortCols()), sd.getParameters());
  }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

    StorageDescriptor sd = index.getSd();
    if (sd == null) {
      throw new InvalidObjectException("Storage descriptor is not defined for index.");
    }


    MStorageDescriptor msd = this.convertToMStorageDescriptor(sd);
    MTable origTable = getMTable(index.getDbName(), index.getOrigTableName());
    if (origTable == null) {
      throw new InvalidObjectException(
          "Original table does not exist for the given index.");
    }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

        msd.getParameters());
  }
  
  private MStorageDescriptor convertToMStorageDescriptor(StorageDescriptor sd) throws MetaException {
    if(sd == null) return null;
    return new MStorageDescriptor(
        convertToMFieldSchemas(sd.getCols()),
        sd.getLocation(),
        sd.getInputFormat(),
        sd.getOutputFormat(),
        sd.isCompressed(),

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

  private MStorageDescriptor convertToMStorageDescriptor(StorageDescriptor sd,
      MColumnDescriptor mcd) throws MetaException {
    if (sd == null) {
      return null;
    }
    return new MStorageDescriptor(mcd, sd
        .getLocation(), sd.getInputFormat(), sd.getOutputFormat(), sd
        .isCompressed(), sd.getNumBuckets(), converToMSerDeInfo(sd
        .getSerdeInfo()), sd.getBucketCols(),
        convertToMOrders(sd.getSortCols()), sd.getParameters(),
        (null == sd.getSkewedInfo()) ? null

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

    }


    // If this partition's set of columns is the same as the parent table's,
    // use the parent table's, so we do not create a duplicate column descriptor,
    // thereby saving space
    MStorageDescriptor msd;
    if (useTableCD &&
        mt.getSd() != null && mt.getSd().getCD() != null &&
        mt.getSd().getCD().getCols() != null &&
        part.getSd() != null &&
        convertToFieldSchemas(mt.getSd().getCD().getCols()).

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

    StorageDescriptor sd = index.getSd();
    if (sd == null) {
      throw new InvalidObjectException("Storage descriptor is not defined for index.");
    }


    MStorageDescriptor msd = this.convertToMStorageDescriptor(sd);
    MTable origTable = getMTable(index.getDbName(), index.getOrigTableName());
    if (origTable == null) {
      throw new InvalidObjectException(
          "Original table does not exist for the given index.");
    }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

        throw new
          NoSuchObjectException("Table " + tableName +
          " for which stats gathering is requested doesn't exist.");
      }


      MStorageDescriptor mSDS = mTable.getSd();
      List<MFieldSchema> colList = mSDS.getCD().getCols();


      for(MFieldSchema mCol:colList) {
        if (mCol.getName().equals(mStatsObj.getColName().trim())) {
          foundCol = true;
          break;

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

      throw new
        NoSuchObjectException("Partition " + partName +
        " for which stats gathering is requested doesn't exist");
    }


    MStorageDescriptor mSDS = mPartition.getSd();
    List<MFieldSchema> colList = mSDS.getCD().getCols();


    for(MFieldSchema mCol:colList) {
      if (mCol.getName().equals(mStatsObj.getColName().trim())) {
        foundCol = true;
        break;

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

      if (mTable == null) {
        throw new NoSuchObjectException("Table " + tableName +
        " for which stats is requested doesn't exist.");
      }


      MStorageDescriptor mSDS = mTable.getSd();
      List<MFieldSchema> colList = mSDS.getCD().getCols();


      for(MFieldSchema mCol:colList) {
        if (mCol.getName().equals(colName.trim())) {
          foundCol = true;
          break;

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.model.MStorageDescriptor

        throw new
          NoSuchObjectException("Partition " + partName +
          " for which stats is requested doesn't exist");
      }


      MStorageDescriptor mSDS = mPartition.getSd();
      List<MFieldSchema> colList = mSDS.getCD().getCols();


      for(MFieldSchema mCol:colList) {
        if (mCol.getName().equals(colName.trim())) {
          foundCol = true;
          break;

View Full Code Here

0 1 2 3 4 5

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.