org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class ReduceFnRunnerHelpers<K,InputT,W extends BoundedWindow>

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.ReduceFnRunnerHelpers<K,InputT,W>

public class ReduceFnRunnerHelpers<K,InputT,W extends BoundedWindow>
extends java.lang.Object

Helpers to use ReduceFnRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReduceFnRunnerHelpers.GABWOutputWindowedValue<K,V> OutputWindowedValue for ReduceFnRunner.

Constructor Summary

Constructors

Constructor and Description
ReduceFnRunnerHelpers()

Method Summary

Modifier and Type	Method and Description
static <K,InputT,W extends BoundedWindow> void	fireEligibleTimers(org.apache.beam.runners.core.InMemoryTimerInternals timerInternals, org.apache.beam.runners.core.ReduceFnRunner<K,InputT,java.lang.Iterable<InputT>,W> reduceFnRunner)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceFnRunnerHelpers

public ReduceFnRunnerHelpers()

Method Detail

fireEligibleTimers

public static <K,InputT,W extends BoundedWindow> void fireEligibleTimers(org.apache.beam.runners.core.InMemoryTimerInternals timerInternals,
                                                                         org.apache.beam.runners.core.ReduceFnRunner<K,InputT,java.lang.Iterable<InputT>,W> reduceFnRunner)
                                                                  throws java.lang.Exception

Throws:

java.lang.Exception