@ VisibleForTesting protected Callable < Void > createSafeDatasetCommit ( boolean shouldCommitDataInJob , boolean isJobCancelled , DeliverySemantics deliverySemantics , String datasetUrn , JobState . DatasetState datasetState , boolean isMultithreaded , JobContext jobContext ) { return new SafeDatasetCommit ( shouldCommitDataInJob , isJobCancelled , deliverySemantics , datasetUrn , datasetState , isMultithreaded , jobContext ) ; }
The only reason for this methods is so that we can test the parallelization of commits . DO NOT OVERRIDE .