Java源码示例:cascading.scheme.hadoop.TextLine
示例1@Override
public Tap getTextFile(Fields sourceFields, Fields sinkFields, String filename, SinkMode mode) {
if( sourceFields == null ) {
return new Hfs(new TextLine(), filename, mode);
}
return new Hfs( new TextLine( sourceFields, sinkFields ), filename, mode );
}