Package org.apache.beam.runners.spark.translation.streaming

Class ParDoStateUpdateFn.SparkTimerInternalsIterator

java.lang.Object

org.apache.beam.runners.spark.translation.streaming.ParDoStateUpdateFn.SparkTimerInternalsIterator

All Implemented Interfaces:

Iterator<org.apache.beam.runners.core.TimerInternals.TimerData>

Enclosing class:

ParDoStateUpdateFn<KeyT,ValueT,InputT extends KV<KeyT,ValueT>,OutputT>

public static class ParDoStateUpdateFn.SparkTimerInternalsIterator
extends Object
implements Iterator<org.apache.beam.runners.core.TimerInternals.TimerData>

An iterator implementation that processes timers from SparkTimerInternals. This iterator is used in stateful processing to handle timer-based operations.

Method Summary

Modifier and Type	Method	Description
void	deleteTimer(org.apache.beam.runners.core.TimerInternals.TimerData timerData)
boolean	hasNext()
org.apache.beam.runners.core.TimerInternals.TimerData	next()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<org.apache.beam.runners.core.TimerInternals.TimerData>

next

public org.apache.beam.runners.core.TimerInternals.TimerData next()

Specified by:

next in interface Iterator<org.apache.beam.runners.core.TimerInternals.TimerData>

deleteTimer

public void deleteTimer(org.apache.beam.runners.core.TimerInternals.TimerData timerData)