Searched defs:outputCommitCoordinator (Results 1 – 3 of 3) sorted by relevance
71 val outputCommitCoordinator = SparkEnv.get.outputCommitCoordinator constant
69 val outputCommitCoordinator: OutputCommitCoordinator, constant368 val outputCommitCoordinator = mockOutputCommitCoordinator.getOrElse { constant
70 var outputCommitCoordinator: OutputCommitCoordinator = null variable