public static class TranslatorUtils.FromRawUnionValue<OutputT> extends io.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>>
Constructor and Description |
---|
FromRawUnionValue() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.util.WindowedValue<OutputT> |
map(TranslatorUtils.RawUnionValue value) |
public org.apache.beam.sdk.util.WindowedValue<OutputT> map(TranslatorUtils.RawUnionValue value)
map
in class io.gearpump.streaming.dsl.api.functions.MapFunction<TranslatorUtils.RawUnionValue,org.apache.beam.sdk.util.WindowedValue<OutputT>>