Searched refs:DistributedEpochState (Results 1 – 2 of 2) sorted by relevance
101 struct DistributedEpochState { struct135 distributed_epoch_state = DistributedEpochState(); in Job()143 absl::optional<DistributedEpochState> distributed_epoch_state;
117 DistributedEpochState& state = job->distributed_epoch_state.value(); in ProduceSplit()