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

Class ExpandContext.FlushTimerInterceptor<K,​V>

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    ExpandContext
    public static class ExpandContext.FlushTimerInterceptor<K,​V>
extends java.lang.Object
implements java.io.Serializable
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void intercept​(org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<V,​StateOrInput<V>>,​?> doFn, java.lang.Object[] args)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • intercept

        @RuntimeType
public void intercept​(@This
                      org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<V,​StateOrInput<V>>,​?> doFn,
                      @AllArguments
                      java.lang.Object[] args)