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

Class ExpandContext.DoFnExpandContext<K,V>

java.lang.Object

cz.o2.proxima.beam.util.state.ExpandContext.DoFnExpandContext<K,V>

Enclosing class:

ExpandContext

public class ExpandContext.DoFnExpandContext<K,V>
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
org.apache.beam.sdk.state.StateSpec<org.apache.beam.sdk.state.BagState<org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<K,V>>>>	getBufState()
org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,V>,?>	getDoFn()
java.lang.Class<? extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,V>,?>>	getDoFnClass()
net.bytebuddy.description.type.TypeDescription.Generic	getDoFnGeneric()
cz.o2.proxima.beam.util.state.FlushTimerParameterExpander	getFlushExpander()
org.apache.beam.sdk.state.StateSpec<org.apache.beam.sdk.state.ValueState<org.joda.time.Instant>>	getFlushState()
org.apache.beam.sdk.state.TimerSpec	getFlushTimer()
ExpandContext.FlushTimerInterceptor<K,V>	getFlushTimerInterceptor()
org.apache.beam.sdk.coders.KvCoder<K,V>	getInputCoder()
java.lang.reflect.ParameterizedType	getInputType()
org.apache.beam.sdk.coders.Coder<K>	getKeyCoder()
org.apache.beam.sdk.values.TupleTag<java.lang.Object>	getMainTag()
cz.o2.proxima.beam.util.state.OnWindowParameterExpander	getOnWindowExpander()
ExpandContext.OnWindowExpirationInterceptor<K,V>	getOnWindowExpirationInterceptor()
@Nullable java.lang.reflect.Method	getOnWindowMethod()
java.lang.reflect.Type	getOutputType()
java.lang.reflect.Method	getProcessElement()
cz.o2.proxima.beam.util.state.ProcessElementParameterExpander	getProcessElementExpander()
ExpandContext.ProcessElementInterceptor<K,V>	getProcessElementInterceptor()

Methods inherited from class java.lang.Object

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

Method Detail

getDoFn

public org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,V>,?> getDoFn()

getMainTag

public org.apache.beam.sdk.values.TupleTag<java.lang.Object> getMainTag()

getInputCoder

public org.apache.beam.sdk.coders.KvCoder<K,V> getInputCoder()

getKeyCoder

public org.apache.beam.sdk.coders.Coder<K> getKeyCoder()

getDoFnClass

public java.lang.Class<? extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,V>,?>> getDoFnClass()

getInputType

public java.lang.reflect.ParameterizedType getInputType()

getOutputType

public java.lang.reflect.Type getOutputType()

getDoFnGeneric

public net.bytebuddy.description.type.TypeDescription.Generic getDoFnGeneric()

getProcessElement

public java.lang.reflect.Method getProcessElement()

getOnWindowMethod

public @Nullable java.lang.reflect.Method getOnWindowMethod()

getFlushExpander

public cz.o2.proxima.beam.util.state.FlushTimerParameterExpander getFlushExpander()

getOnWindowExpander

public cz.o2.proxima.beam.util.state.OnWindowParameterExpander getOnWindowExpander()

getProcessElementExpander

public cz.o2.proxima.beam.util.state.ProcessElementParameterExpander getProcessElementExpander()

getFlushTimerInterceptor

public ExpandContext.FlushTimerInterceptor<K,V> getFlushTimerInterceptor()

getOnWindowExpirationInterceptor

public ExpandContext.OnWindowExpirationInterceptor<K,V> getOnWindowExpirationInterceptor()

getProcessElementInterceptor

public ExpandContext.ProcessElementInterceptor<K,V> getProcessElementInterceptor()

getBufState

public org.apache.beam.sdk.state.StateSpec<org.apache.beam.sdk.state.BagState<org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<K,V>>>> getBufState()

getFlushState

public org.apache.beam.sdk.state.StateSpec<org.apache.beam.sdk.state.ValueState<org.joda.time.Instant>> getFlushState()

getFlushTimer

public org.apache.beam.sdk.state.TimerSpec getFlushTimer()