- Source & Sink are specified in terms of Tap #51
- Available Taps
- Hfs
- Lfs
- Dfs
- FileTap
- Example
- ----- Example 1
- Scheme sourceScheme = new TextLine( new Fields( "line" ) );
- Tap source = new Hfs( sourceScheme, inputPath );
- Scheme sinkScheme = new TextLine(new Fields("department","salary" ));
- Tap sink = new Hfs( sinkScheme, outputPath, SinkMode.REPLACE);
No comments:
Post a Comment