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

Class TranslatorUtils

java.lang.Object

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

public class TranslatorUtils
extends java.lang.Object

Utility methods for translators.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TranslatorUtils.FromRawUnionValue<OutputT> Converts @link{RawUnionValue} to @link{WindowedValue}.
static class	TranslatorUtils.RawUnionValue This is copied from org.apache.beam.sdk.transforms.join.RawUnionValue.

Constructor Summary

Constructors

Constructor and Description
TranslatorUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.gearpump.streaming.dsl.window.impl.Window	boundedWindowToGearpumpWindow(BoundedWindow window)
static java.util.Map<java.lang.String,PCollectionView<?>>	getTagsToSideInputs(java.util.Collection<PCollectionView<?>> sideInputs)
static Instant	java8TimeToJodaTime(java.time.Instant time)
static java.time.Instant	jodaTimeToJava8Time(Instant time)
static org.apache.gearpump.streaming.dsl.javaapi.JavaStream<java.util.List<TranslatorUtils.RawUnionValue>>	toList(org.apache.gearpump.streaming.dsl.javaapi.JavaStream<TranslatorUtils.RawUnionValue> stream)
static <InputT> org.apache.gearpump.streaming.dsl.javaapi.JavaStream<TranslatorUtils.RawUnionValue>	withSideInputStream(TranslationContext context, org.apache.gearpump.streaming.dsl.javaapi.JavaStream<org.apache.beam.sdk.util.WindowedValue<InputT>> inputStream, java.util.Map<java.lang.String,PCollectionView<?>> tagsToSideInputs)

Methods inherited from class java.lang.Object

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

Constructor Detail

TranslatorUtils

public TranslatorUtils()

Method Detail

jodaTimeToJava8Time

public static java.time.Instant jodaTimeToJava8Time(Instant time)

java8TimeToJodaTime

public static Instant java8TimeToJodaTime(java.time.Instant time)

boundedWindowToGearpumpWindow

public static org.apache.gearpump.streaming.dsl.window.impl.Window boundedWindowToGearpumpWindow(BoundedWindow window)

withSideInputStream

public static <InputT> org.apache.gearpump.streaming.dsl.javaapi.JavaStream<TranslatorUtils.RawUnionValue> withSideInputStream(TranslationContext context,
                                                                                                                               org.apache.gearpump.streaming.dsl.javaapi.JavaStream<org.apache.beam.sdk.util.WindowedValue<InputT>> inputStream,
                                                                                                                               java.util.Map<java.lang.String,PCollectionView<?>> tagsToSideInputs)

getTagsToSideInputs

public static java.util.Map<java.lang.String,PCollectionView<?>> getTagsToSideInputs(java.util.Collection<PCollectionView<?>> sideInputs)

toList

public static org.apache.gearpump.streaming.dsl.javaapi.JavaStream<java.util.List<TranslatorUtils.RawUnionValue>> toList(org.apache.gearpump.streaming.dsl.javaapi.JavaStream<TranslatorUtils.RawUnionValue> stream)