org.apache.beam.runners.gearpump.translators.utils

Class TranslatorUtils.FromRawUnionValue<OutputT>

java.lang.Object

org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction

org.apache.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>>

org.apache.beam.runners.gearpump.translators.utils.TranslatorUtils.FromRawUnionValue<OutputT>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

TranslatorUtils

public static class TranslatorUtils.FromRawUnionValue<OutputT>
extends org.apache.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>>

Converts @link{RawUnionValue} to @link{WindowedValue}.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FromRawUnionValue()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.util.WindowedValue<OutputT>	map(TranslatorUtils.RawUnionValue value)

Methods inherited from class org.apache.gearpump.streaming.dsl.api.functions.MapFunction

apply

Methods inherited from class org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction

setup, teardown

Methods inherited from class java.lang.Object

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

Constructor Detail

FromRawUnionValue

public FromRawUnionValue()

Method Detail

map

public org.apache.beam.sdk.util.WindowedValue<OutputT> map(TranslatorUtils.RawUnionValue value)

Specified by:

map in class org.apache.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>>