	protected TaskManager createTaskManagerImpl(String taskId, Map<String, String> taskArgs, Map<String, String> pipeArgs) {
		String fileName;
		File file;
		EntityReporter task;
		fileName = getStringArgument(taskId, taskArgs, ARG_FILE_NAME, DEFAULT_FILE_NAME);
		file = new File(fileName);
		task = new EntityReporter(file);
		return new SinkManager(taskId, task, pipeArgs);
	}

	protected TaskManager createTaskManagerImpl(String taskId, Map<String, String> taskArgs, Map<String, String> pipeArgs) {
		String fileName;
		File file;
		IntegrityReporter task;
		fileName = getStringArgument(taskId, taskArgs, ARG_FILE_NAME, DEFAULT_FILE_NAME);
		file = new File(fileName);
		task = new IntegrityReporter(file);
		return new SinkManager(taskId, task, pipeArgs);
	}
