private static String getColumnTypeKey(HCatFieldSchema fieldSchema) {
      return fieldSchema.getName() + "_" + (fieldSchema.getTypeInfo() == null ?
        fieldSchema.getType() : fieldSchema.getTypeInfo());
    }
todo: when job is complete, should print the msgCount table to log
hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatBaseStorer.java