Page History

/**
 * The Class HCatCommandDesc contains methods which help in validating,
 * building command descriptors and queries.
 */
public abstract class HCatCommandDesc{

       /**
     * Adds the partition.
     *
     * @param partInfo An instance of HCatAddPartitionDesc.
     * @throws HCatException the h cat exception
     */
    public abstract void validateCommandDescaddPartition(HCatAddPartitionDesc partInfo) throws HCatException;
    abstract String buildQuery() throws HCatException;
    abstract boolean isValidationComplete();

}

public class HCatCreateDBDesc extends HCatCommandDesc {

    /**
     * Drops partition.
     *
    private String* databaseName;
@param dbName The  private String locationUri;database name.
    private String* comment;
@param tableName The table privatename.
 Map<String, String> dbProperties;

  * @param /**
partitionName The partition name, Comma *separated Getslist the database propertiesof col_name='value'.
     *
 @param ifExists Hive returns *an error @returnif the database propertiespartition specified does not exist, unless ifExists is set to true.
     * @throws HCatException
     */
    Map<String, String> getDatabaseProperties() {
public abstract void dropPartition(String dbName, String tableName,
            return this.dbProperties;
    }String partitionName, boolean ifExists) throws HCatException;

    /**
     * SetsList thepartitions databaseby propertiesfilter.
     *
     * @param dbPropsdbName theThe dbdatabase propsname.
     */
 @param tblName The public void setDatabaseProperties(Map<String, String> dbProps) {table name.
     * @param filter this.dbPropertiesThe =filter dbProps;string,
    }

    /**
    for *example Gets"part1 the name.
     *= \"p1_abc\" and part2 <= "\p2_test\"". Filtering can
     * @return   thebe name
done only on string partition */keys.
    String getName() {
   * @return list of partitions
     return this.databaseName;
    }

* @throws HCatException the h cat exception
     */**
     * Sets the name.public abstract List<HCatPartition> listPartitionsByFilter(String dbName, String tblName,
     *
     * @param databaseNameString thefilter) newthrows nameHCatException;

     /**/
    public * voidMark setName(String databaseName) {partition for event.
     *
    this.databaseName =* databaseName;
@param dbName The database }name.

     /*** @param tblName The table name.
     * @param GetspartKVs the comment.
part k    *vs
     * @return@param eventType the event commenttype
     */
 @throws HCatException the Stringh getComment()cat {exception
     */
    return this.comment;
    }

public abstract void markPartitionForEvent(String dbName, String tblName,
      /**
     * SetsMap<String, the comment.
  String> partKVs, PartitionEventType eventType)
   *
     * @param comment the newthrows commentHCatException;

     /*/*
    public * voidChecks setComment(String comment) {
   if is partition marked for event.
     this.comment*
 = comment;
   * }

@param dbName the db /**name
     * @param GetstblName the tbl location.name
     *
 @param partKVs the part * @return the locationk vs
     */
 @param eventType the String getLocation() {event type
     * @return true, return this.locationUri;
    }

if is partition marked for event
     /**
 @throws HCatException the h * Sets the location.cat exception
     */
    public *abstract @paramboolean location the new location
isPartitionMarkedForEvent(String dbName, String tblName,
        */
    public void setLocation(String location) {Map<String, String> partKVs, PartitionEventType eventType)
        this.locationUri = location;
  throws  }HCatException;

    /**
 @return
    /* Gets the @throwsdelegation HCatExceptiontoken.
     * @see org.apache.hcatalog.api.HCatCommandDescBuilder#buildCommandDesc()
     */
 @param owner the @Overrideowner
    public void validateCommandDesc()
      * @param renewerKerberosPrincipalName the renewer kerberos principal name
     * throws@return the HCatExceptiondelegation {token

    }

 * @throws HCatException /*the @paramh desccat exception
     */*
 @return
   public /*abstract @throws HCatException
     * @see org.apache.hcatalog.api.HCatCommandDescBuilder#buildQuery(java.lang.Class)
String getDelegationToken(String owner, String renewerKerberosPrincipalName) throws
        */HCatException;

    @Override/**
    String buildQuery()* throwsRenew HCatExceptiondelegation {token.
     *
   // TODO Auto-generated* method@param stub
tokenStrForm the token str form
    return null;
* @return the long
 }

    /* @return
@throws HCatException the h  * @see org.apache.hcatalog.api.HCatCommandDesc#isValidationComplete()cat exception
     */
    @Override
public abstract long renewDelegationToken(String boolean isValidationComplete() {tokenStrForm) throws HCatException;

    /**
    // TODO* Auto-generatedCancel methoddelegation stubtoken.
     *
   return false;
 * @param  }

}

public class HCatCreateTableDesc extends HCatCommandDesc{

tokenStrForm the token str form
    private String* tableName;
@throws HCatException the h private boolean isExternal;cat exception
    private ArrayList<HCatFieldSchema> cols; */
    privatepublic ArrayList<HCatFieldSchema>abstract partCols;
    private ArrayList<String> bucketCols;
    private ArrayList<Order> sortCols;
    private int numBuckets;void cancelDelegationToken(String tokenStrForm) throws HCatException;

    /**
     * Close the hcatalog client.
    private String dbName;*
    private String* comment;
@throws HCatException the h private String fileFormat;cat exception
    private String location; */
    privatepublic Stringabstract storageHandler;
    private Map<String, String> tblProps;
    private boolean ifNotExists;

    ArrayList<HCatFieldSchema> getColsStringvoid close() {
      return this.getCols();
    }

    boolean getIfNotExists() {
        return this.ifNotExists;
    }

    /**
     * Sets the if not exists.
     * If true, the user will not receive an error if the table already exists.
     * @param ifNotExists the new if not exists
     */
    public void setIfNotExists(boolean ifNotExists) {
      this.ifNotExists = ifNotExists;
    }

   String getTableName() {
        return this.tableName;
    }

    String getDatabaseName(){
        return this.dbName;
    }

    /**
     * Sets the database name.
     *
     * @param dbName the new database name
     */
    public void setDatabaseName(String dbName){
        this.dbName = dbName;
    }

    /**
     * Sets the table name.
     *
     * @param tableName the new table name
     */
    public void setTableName(String tableName) {
      this.tableName = tableName;
    }

    ArrayList<HCatFieldSchema> getCols() {
       // ArrayList<FieldSchema> cols = this.tableDesc.getCols();
        return null;
    }

    /**
     * Sets the table columns.
     *
     * @param cols List of columns.
     */
    public void setCols(ArrayList<HCatFieldSchema> cols) {
        //convert and set.
      this.cols = null;
    }

    ArrayList<HCatFieldSchema> getPartCols() {
        return null;
    }

    /**
     * Sets the part cols.
     *
     * @param partCols List of partition columns.
     */
    public void setPartCols(ArrayList<HCatFieldSchema> partCols) {
      //this.partCols = partCols;
    }

    ArrayList<String> getBucketCols() {
        return this.bucketCols;
    }

    /**
     * Sets the bucket cols.
     *
     * @param bucketCols The list of columns to be used for clustering.
     */
    public void setBucketCols(ArrayList<String> bucketCols) {
      this.bucketCols = bucketCols;
    }

    int getNumBuckets() {
        return this.numBuckets;
    }

    /**
     * Sets the num buckets.
     *
     * @param numBuckets The number of buckets.
     */
    public void setNumBuckets(int numBuckets) {
      this.numBuckets = numBuckets;
    }

    String getComment() {
        return this.comment;
    }

    /**
     * Sets the comment.
     *
     * @param comment The comment for the table.
     */
    public void setComment(String comment) {
      this.comment = comment;
    }


    String getStorageHandler() {
        return this.storageHandler;
    }

    /**
     * Sets the storage handler.
     *
     * @param storageHandler the new storage handler
     */
    public void setStorageHandler(String storageHandler) {
      this.storageHandler = storageHandler;
    }

    String getLocation() {
        return this.location;
    }

    /**
     * Sets the location.
     *
     * @param location the new location
     */
    public void setLocation(String location) {
      this.location = location;
    }

    boolean getExternal() {
        return this.isExternal;
    }

    /**
     * Sets the external.
     *
     * @param isExternal True/False, indicating if the table is an external table.
     */
    public void setExternal(boolean isExternal) {
      this.isExternal = isExternal;
    }

    ArrayList<Order> getSortCols() {
        return this.sortCols;
    }

    /**
     * Sets the sort cols.
     *
     * @param sortCols the sortCols to set
     */
    public void setSortCols(ArrayList<Order> sortCols) {
      this.sortCols = sortCols;
    }

    /**
     * @return the table properties
     */
    Map<String, String> getTblProps() {
        return this.tblProps;
    }

    /**
     * @param tblProps
     *          the table properties to set
     */
    public void setTblProps(Map<String, String> tblProps) {
      this.tblProps = tblProps;
    }

    /**
     * Sets the file format.
     *
     * @param format the new file format
     */
    public void setFileFormat(String format){
        this.fileFormat = format;
    }

    String getFileFormat(){
        return this.fileFormat;
    }

    /* @return
    /* @throws HCatException
     * @see org.apache.hcatalog.api.HCatCommandDescBuilder#buildCommandDesc()
     */
    @Override
    public void validateCommandDesc() throws HCatException {
        // TODO Auto-generated method stub
    }


    /* @param desc
    /* @return
    /* @throws HCatException
     * @see org.apache.hcatalog.api.HCatCommandDescBuilder#buildQuery(org.apache.hcatalog.api.HCatCommandDescBuilder)
     */
    @Override
    String buildQuery() throws HCatException {
        // TODO Auto-generated method stub
        return null;
    }


    /* @return
     * @see org.apache.hcatalog.api.HCatCommandDesc#isValidationComplete()
     */
    @Override
    boolean isValidationComplete() {
        // TODO Auto-generated method stub
        return false;
    }

public class HCatAddPartitionDesc extends HCatCommandDesc {

    //private AddPartitionDesc addPartDesc;
    private String dbName;
    private String tableName;
    private String location;
    private LinkedHashMap<String,String> partSpec;

    /**
     * @return database name
     */
     String getDbName() {
         return this.dbName;
    }

    /**
     * Sets the db name.
     *
     * @param dbName database name
     */
    public void setDbName(String dbName) {
      this.dbName = dbName;
    }

    /**
     * @return the table we're going to add the partitions to.
     */
     String getTableName() {
      return this.tableName;
    }

    /**
     * Sets the table name.
     *
     * @param tableName the table we're going to add the partitions to.
     */
    public void setTableName(String tableName) {
      this.tableName = tableName;
    }

    String getLocation() {
      return this.location;
    }

    /**
     * Sets the location.
     *
     * @param location The location of partition in relation to table
     */
    public void setLocation(String location) {
      this.location = location;
    }

    /**
     * @return partition specification.
     */
     LinkedHashMap<String, String> getPartSpec() {
         return this.partSpec;
    }

    /**
     * Adds the partition name and value.
     *
     * @param colName The column name.
     * @param value The value.
     */
    public void addPartSpec(String colName, String value) {
      this.partSpec.put(colName, value);
    }

    @Override
    public void validateCommandDesc()
            throws HCatException {

    }

    /* @return
    /* @throws HCatException
     * @see org.apache.hcatalog.api.HCatCommandDesc#buildQuery()
     */
    @Override
    String buildQuery() throws HCatException {
        // TODO Auto-generated method stub
        return null;
    }

    /* @return
     * @see org.apache.hcatalog.api.HCatCommandDesc#isValidationComplete()
     */
    @Override
    boolean isValidationComplete() {
        // TODO Auto-generated method stub
        return false;
    }

}

 Configuration config = new Configuration();
 config.add("hive-site.xml");
 HCatClient client = HCatClient.create(config);

 HCatCreateTableDesc desc = new HCatCreateTableDesc();
 desc.setTableName("demo_table");
 desc.setDatabaseName("db1");
 desc.setFileFormat("rcfile");
 ArrayList<HCatFieldSchema> cols = new ArrayList<HCatFieldSchema>();
 cols.add(new HCatFieldSchema("col1", Type.INT, "comment1"));
 cols.add(new HCatFieldSchema("col2", Type.STRING, "comment2"));
 desc.setCols(cols);

 //Validate
 desc.validateCommandDesc();
 boolean success = client.createTable(desc);