Package cz.o2.proxima.beam.util.state

Class ExpandContext

java.lang.Object

cz.o2.proxima.beam.util.state.ExpandContext

@Internal
public class ExpandContext
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ExpandContext.DoFnExpandContext<K,V>
static interface	ExpandContext.DoFnProvider
static class	ExpandContext.FlushTimerInterceptor<K,V>
static class	ExpandContext.OnWindowExpirationInterceptor<K,V>
static class	ExpandContext.ProcessElementInterceptor<K,V>

Constructor Summary

Constructors

Constructor

Description

ExpandContext(org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,StateValue>>> inputs, org.joda.time.Instant stateWriteInstant, UnaryFunction<org.joda.time.Instant,org.joda.time.Instant> nextFlushInstantFn, org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,StateValue>>,org.apache.beam.sdk.values.PDone> stateSink)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpandContext

public ExpandContext(org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,StateValue>>> inputs,
                     org.joda.time.Instant stateWriteInstant,
                     UnaryFunction<org.joda.time.Instant,org.joda.time.Instant> nextFlushInstantFn,
                     org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,StateValue>>,org.apache.beam.sdk.values.PDone> stateSink)