### Question:
DataStreamWriterExample { public static void main(String[] args) throws Exception { boolean hadoop_cluster = false; if (args.length>1){ hadoop_cluster = Boolean.parseBoolean(args[0]); } final ExecutionEnvironment env; if(hadoop_cluster){ env = ExecutionEnvironment.getExecutionEnvironment(); env.getConfig().disableSysoutLogging(); }else{ Configuration conf = new Configuration(); conf.setInteger("taskmanager.network.numberOfBuffers", 12000); conf.setInteger("taskmanager.numberOfTaskSlots",Main.PARALLELISM); env = ExecutionEnvironment.createLocalEnvironment(conf); env.setParallelism(Main.PARALLELISM); env.getConfig().disableSysoutLogging(); } DataFlink<DataInstance> dataFlink = new DataSetGenerator().generate(env,1234,1000,2,3); DataFlinkWriter.writeDataToARFFFolder(dataFlink, "datasets/simulated/distributed.arff"); }  static void main(String[] args);  }### Answer:
@Test public void test() throws Exception { DataStreamWriterExample.main(null); }