org.apache.beam.runners.gearpump.translators

Class WindowAssignTranslator.AssignWindows<T>

java.lang.Object

io.gearpump.streaming.dsl.api.functions.SerializableFunction

io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<org.apache.beam.sdk.util.WindowedValue<T>,org.apache.beam.sdk.util.WindowedValue<T>>

org.apache.beam.runners.gearpump.translators.WindowAssignTranslator.AssignWindows<T>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

WindowAssignTranslator<T>

protected static class WindowAssignTranslator.AssignWindows<T>
extends io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<org.apache.beam.sdk.util.WindowedValue<T>,org.apache.beam.sdk.util.WindowedValue<T>>

A Function used internally by Gearpump to wrap the actual Beam's WindowFn.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<T>>	flatMap(org.apache.beam.sdk.util.WindowedValue<T> value)

Methods inherited from class io.gearpump.streaming.dsl.api.functions.SerializableFunction

setup, teardown

Methods inherited from class java.lang.Object

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

Method Detail

flatMap

public java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<T>> flatMap(org.apache.beam.sdk.util.WindowedValue<T> value)

Specified by:

flatMap in class io.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<org.apache.beam.sdk.util.WindowedValue<T>,org.apache.beam.sdk.util.WindowedValue<T>>