// Magically get HowlTypeInfo from Pig's Schema.
<<<<<<< HEAD
return new HowlTypeInfo("");
// byte type = fSchema.type;
// HowlTypeInfo howlTypeInfo;
// switch(type){
// case DataType.BAG:
// case DataType.TUPLE:
// List fieldNames = new ArrayList();
// List typeInfos = new ArrayList();
// for( FieldSchema fieldSchema : fSchema.schema.getFields()){
// fieldNames.add( fieldSchema.alias);
// getTypeInfoFrom(fieldSchema).toString();
// }
// return new HowlTypeInfo(TypeInfoFactory.getStructTypeInfo(fieldNames, typeInfos));
// case DataType.MAP:
// default:
// return new HowlTypeInfo(getHiveTypeString(type));
// }
=======
return HowlTypeInfoUtils.getHowlTypeInfo("");
// for(FieldSchema fSchema : pigSchema.getFields()){
// byte type = fSchema.type;
// HowlTypeInfo howlTypeInfo;
// if(type == org.apache.pig.data.DataType.BAG || type == org.apache.pig.data.DataType.TUPLE){
// howlTypeInfo = new HowlTypeInfo(fSchema.alias,convertPigSchemaToHiveSchemaStr(fSchema.schema.toString()),"");
// }
//
// else if (type == org.apache.pig.data.DataType.MAP){
// // We only allow map
// howlFSchema = new HowlFieldSchema(fSchema.alias,"map","");
// }
// else{
// howlFSchema = new HowlFieldSchema(fSchema.alias,getHiveTypeString(fSchema.type),"");
//
// }
// fieldSchemas.add(howlFSchema);
// }
>>>>>>> fce284d3232ebcce913c129db785aa96117140ed
}
private String getHiveTypeString(byte type){ |