class SavepointOutputFormat extends RichOutputFormat<CheckpointMetadata> {

	@Override
	public void open(int taskNumber, int numTasks) throws IOException {
		Preconditions.checkState(numTasks == 1, "SavepointOutputFormat should only be executed with parallelism 1");

		targetLocation = createSavepointLocation(savepointPath);
	}

	public  SavepointOutputFormat(Path savepointPath);

}