@@ -0,0 +1,2176 @@
+/*%0A * Copyright (c) 2007-2013 Concurrent, Inc. All Rights Reserved.%0A *%0A * Project and contact information: http://www.cascading.org/%0A *%0A * This file is part of the Cascading project.%0A *%0A * Licensed under the Apache License, Version 2.0 (the %22License%22);%0A * you may not use this file except in compliance with the License.%0A * You may obtain a copy of the License at%0A *%0A *     http://www.apache.org/licenses/LICENSE-2.0%0A *%0A * Unless required by applicable law or agreed to in writing, software%0A * distributed under the License is distributed on an %22AS IS%22 BASIS,%0A * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0A * See the License for the specific language governing permissions and%0A * limitations under the License.%0A */%0A%0Apackage com.amazonaws.vivanih.hadoop.cascading;%0A%0Aimport java.util.Properties;%0A%0Aimport cascading.flow.FlowConnector;%0Aimport cascading.flow.FlowDef;%0Aimport cascading.flow.hadoop.HadoopFlowConnector;%0A//import cascading.flow.hadoop2.Hadoop2MR1FlowConnector;%0Aimport cascading.pipe.Pipe;%0Aimport cascading.property.AppProps;%0Aimport cascading.scheme.hadoop.TextDelimited;%0Aimport cascading.tap.Tap;%0Aimport cascading.tap.hadoop.Hfs;%0A%0A%0Apublic class%0A  Main%0A  %7B%0A  public static void%0A  main( String%5B%5D args )%0A    %7B%0A    String inPath = args%5B 0 %5D;%0A    String outPath = args%5B 1 %5D;%0A%0A    Properties properties = new Properties();%0A    AppProps.setApplicationJarClass( properties, Main.class );%0A   // AppProps.setApplicationJarPath(properties, %22/home/hadoop/impatient.jar%22); %0A    //FlowConnector flowConnector = new Hadoop2MR1FlowConnector( properties );%0A    FlowConnector flowConnector = new HadoopFlowConnector( properties );%0A%0A    // create the source tap%0A    Tap inTap = new Hfs( new TextDelimited( true, %22%5Ct%22 ), inPath );%0A%0A    // create the sink tap%0A    Tap outTap = new Hfs( new TextDelimited( true, %22%5Ct%22 ), outPath );%0A%0A    // specify a pipe to connect the taps%0A    Pipe copyPipe = new Pipe( %22copy%22 );%0A%0A    // connect the taps, pipes, etc., into a flow%0A    FlowDef flowDef = FlowDef.flowDef()%0A     .addSource( copyPipe, inTap )%0A     .addTailSink( copyPipe, outTap );%0A%0A    // run the flow%0A    flowConnector.connect( flowDef ).complete();%0A    %7D%0A  %7D%0A

Create Main.java