}
static Schema getSchemaFromString(String schemaString, byte defaultType) throws ParseException {
ByteArrayInputStream stream = new ByteArrayInputStream(schemaString.getBytes()) ;
QueryParser queryParser = new QueryParser(stream) ;
Schema schema = queryParser.TupleSchema() ;
Schema.setSchemaDefaultType(schema, defaultType);
return schema;
}
static Object getPigConstant(String pigConstantAsString) throws ParseException {