public class WindowAssignTranslator<T> extends java.lang.Object implements TransformTranslator<Window.Assign<T>>
Window.Assign
is translated to Gearpump flatMap function.Modifier and Type | Class and Description |
---|---|
protected static class |
WindowAssignTranslator.AssignWindows<T>
A Function used internally by Gearpump to wrap the actual Beam's WindowFn.
|
Constructor and Description |
---|
WindowAssignTranslator() |
Modifier and Type | Method and Description |
---|---|
void |
translate(Window.Assign<T> transform,
TranslationContext context) |
public void translate(Window.Assign<T> transform, TranslationContext context)
translate
in interface TransformTranslator<Window.Assign<T>>