Wednesday, October 12, 2016

Tap : 101


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

No comments:

Post a Comment