import com.inin.analytics.elasticsearch.ConfigParams;
import com.inin.analytics.elasticsearch.IndexingPostProcessor;
public class ExampleIndexingJob implements Tool {
private static Configuration conf;
public static int main(String[] args) throws Exception {
<BUG>if(args.length != 9) {

System.err.println("Invalid # arguments. EG: loadES [pipe separated input] [snapshot working directory (fs/nfs)] [snapshot final destination (s3/nfs/hdfs)] [snapshot repo name] [elasticsearch working data location] [num reducers] [num shards per index] [ES batch commit size] [manifest location]");
return -1;</BUG>
}

import com.inin.analytics.elasticsearch.ConfigParams;
import com.inin.analytics.elasticsearch.IndexingPostProcessor;
public class ExampleIndexingJob implements Tool {
private static Configuration conf;
public static int main(String[] args) throws Exception {
if(args.length != 8) {
System.err.println("Invalid # arguments. EG: loadES [pipe separated input] [snapshot working directory (fs/nfs)] [snapshot final destination (s3/nfs/hdfs)] [snapshot repo name] [elasticsearch working data location] [num reducers] [num shards per index] [manifest location]");
return -1;
}
