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