code: @SuppressWarnings("unchecked")
  	private static DataSet<StringTriple> getDataSet(ExecutionEnvironment env, ParameterTool params) {
  		if (params.has("input")) {
  			return env.readCsvFile(params.get("input"))
  				.fieldDelimiter(";")
  				.pojoType(StringTriple.class);
  		} else {
  			System.out.println("Executing EmptyFieldsCountAccumulator example with default input data set.");
  			System.out.println("Use --input to specify file input.");
  			return env.fromCollection(getExampleInputTuples());
  		}
  	}
docs: *************************************************************************