Searched refs:DISTRIBUTED_EPOCH (Results 1 – 8 of 8) sorted by relevance
51 EXPECT_EQ(mode, ProcessingMode::DISTRIBUTED_EPOCH); in TEST()64 ProcessingModeToString(ProcessingMode::DISTRIBUTED_EPOCH)); in TEST()
49 DISTRIBUTED_EPOCH = 2; enumerator
42 DISTRIBUTED_EPOCH = 2, enumerator
41 mode = ProcessingMode::DISTRIBUTED_EPOCH; in ParseProcessingMode()52 case ProcessingMode::DISTRIBUTED_EPOCH: in ProcessingModeToString()
134 if (processing_mode == ProcessingMode::DISTRIBUTED_EPOCH) { in Job()
175 if (job->processing_mode == ProcessingMode::DISTRIBUTED_EPOCH) { in Start()513 case ProcessingMode::DISTRIBUTED_EPOCH: in CreateJob()520 if (processing_mode == ProcessingMode::DISTRIBUTED_EPOCH) { in CreateJob()
155 case DISTRIBUTED_EPOCH: { in EnsureTaskInitialized()
40 DISTRIBUTED_EPOCH = "distributed_epoch" variable in ProcessingMode46 ProcessingMode.PARALLEL_EPOCHS, ProcessingMode.DISTRIBUTED_EPOCH