private String getIndexedColFamQuals(TableDesc tableDesc, String indexColumns, String colMap) {
    StringBuilder sb = new StringBuilder();

    String cols = indexColumns;


    String hiveColString = tableDesc.getProperties().getProperty(serdeConstants.LIST_COLUMNS);
    // if there are actual accumulo index columns defined then build
    // the comma separated list of accumulo columns
    if (cols == null || cols.isEmpty() || "*".equals(indexColumns)) {
      // skip rowid
      cols = hiveColString.substring(hiveColString.indexOf(',')+1);
    }

    String[] hiveTypes = tableDesc.getProperties()
        .getProperty(serdeConstants.LIST_COLUMN_TYPES).split(":");
    String[] accCols = colMap.split(",");
    String[] hiveCols = hiveColString.split(",");
    Set<String> indexSet = new HashSet<String>();

    for (String idx : cols.split(",")) {
      indexSet.add(idx.trim());
    }

    for (int i = 0; i < hiveCols.length; i++) {
      if (indexSet.contains(hiveCols[i].trim())) {
        if (sb.length() > 0) {
          sb.append(",");
        }
        sb.append(accCols[i].trim() + ":" + AccumuloIndexLexicoder.getRawType(hiveTypes[i]));
      }
    }

    return sb.toString();
  }
Push down table properties into the JobConf.

@param desc
         Hive table description
@param jobProps
         Properties that will be added to the JobConf by Hive
accumulo-handler/src/java/org/apache/hadoop/hive/accumulo/AccumuloStorageHandler.java