Searched refs:distributed_epoch_state (Results 1 – 3 of 3) sorted by relevance
135 distributed_epoch_state = DistributedEpochState(); in Job()143 absl::optional<DistributedEpochState> distributed_epoch_state; member
116 DCHECK(job->distributed_epoch_state.has_value()); in ProduceSplit()117 DistributedEpochState& state = job->distributed_epoch_state.value(); in ProduceSplit()
190 int64 index = job.distributed_epoch_state.value().split_provider_index; in RestoreSplitProvider()318 if (!job->distributed_epoch_state.has_value()) { in GetSplit()323 int64 current_repetition = job->distributed_epoch_state.value().repetition; in GetSplit()