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

Class ExpandContext.OnWindowExpirationInterceptor<K,​V>

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

    • Constructor Summary

      Constructors 
      Constructor Description
      OnWindowExpirationInterceptor​(cz.o2.proxima.beam.util.state.MethodCallUtils.VoidMethodInvoker<? super org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,​V>,​?>> processElementInvoker, @Nullable cz.o2.proxima.beam.util.state.MethodCallUtils.VoidMethodInvoker<? super org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,​V>,​?>> onWindowExpirationInvoker, cz.o2.proxima.beam.util.state.OnWindowParameterExpander expander)  

    • 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>>,​?> proxy, java.lang.Object[] allArgs)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • OnWindowExpirationInterceptor

        public OnWindowExpirationInterceptor​(cz.o2.proxima.beam.util.state.MethodCallUtils.VoidMethodInvoker<? super org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,​V>,​?>> processElementInvoker,
                                     @Nullable cz.o2.proxima.beam.util.state.MethodCallUtils.VoidMethodInvoker<? super org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<K,​V>,​?>> onWindowExpirationInvoker,
                                     cz.o2.proxima.beam.util.state.OnWindowParameterExpander expander)

    • Method Detail

      • intercept

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