com.google.cloud.dataflow.sdk.util

Interface WindowingInternals<InputT,OutputT>

Type Parameters:

InputT - input type

OutputT - output type

public interface WindowingInternals<InputT,OutputT>

Interface that may be required by some (internal) DoFns to implement windowing. It should not be necessary for general user code to interact with this at all.

This interface should be provided by runner implementors to support windowing on their runner.

Method Summary

Modifier and Type	Method and Description
void	outputWindowedValue(OutputT output, org.joda.time.Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo pane) Output the value at the specified timestamp in the listed windows.
PaneInfo	pane() Access the pane of the current window(s).
StateInternals	stateInternals()
TimerInternals	timerInternals() Return the timer manager provided by the underlying system, or null if Timers need to be emulated.
Collection<? extends BoundedWindow>	windows() Access the windows the element is being processed in without "exploding" it.
<T> void	writePCollectionViewData(TupleTag<?> tag, Iterable<WindowedValue<T>> data, Coder<T> elemCoder) Write the given PCollectionView data to a location accessible by other workers.

Method Detail

stateInternals

StateInternals stateInternals()

outputWindowedValue

void outputWindowedValue(OutputT output,
                         org.joda.time.Instant timestamp,
                         Collection<? extends BoundedWindow> windows,
                         PaneInfo pane)

Output the value at the specified timestamp in the listed windows.

timerInternals

TimerInternals timerInternals()

Return the timer manager provided by the underlying system, or null if Timers need to be emulated.

windows

Collection<? extends BoundedWindow> windows()

Access the windows the element is being processed in without "exploding" it.

pane

PaneInfo pane()

Access the pane of the current window(s).

writePCollectionViewData

<T> void writePCollectionViewData(TupleTag<?> tag,
                                  Iterable<WindowedValue<T>> data,
                                  Coder<T> elemCoder)
                           throws IOException

Write the given PCollectionView data to a location accessible by other workers.

Throws:

IOException