try {
Text tw = (Text)field;
String row = tw.toString();
return(deserialize(c, row, separator));
} catch (ClassCastException e) {
throw new SerDeException("columnsetSerDe expects Text", e);
} catch (Exception e) {
throw new SerDeException(e);
}
} catch (SerDeException e) {
// don't want to crap out streaming jobs because of one error.
if(inStreaming) {