Package org.apache.flink.table.runtime.operators.window.tvf.common

Interface WindowProcessor.Context<W>

  • Enclosing interface:
    WindowProcessor<W>
    public static interface WindowProcessor.Context<W>
    Information available in an invocation of methods of WindowProcessor.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> getKeyedStateBackend()
      Returns the current KeyedStateBackend.
      org.apache.flink.runtime.memory.MemoryManager getMemoryManager()
      Returns the current MemoryManager.
      long getMemorySize()
      Returns the managed memory size can be used by this operator.
      Object getOperatorOwner()
      Returns the object instance of this operator which is used for tracking managed memories used by this operator.
      org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()
      Returns the current RuntimeContext.
      org.apache.flink.streaming.api.operators.InternalTimerService<W> getTimerService()
      Returns the current InternalTimerService.
      void output​(org.apache.flink.table.data.RowData result)
      Outputs results to downstream operators.

    • Method Detail

      • getOperatorOwner

        Object getOperatorOwner()
        Returns the object instance of this operator which is used for tracking managed memories used by this operator.

      • getMemoryManager

        org.apache.flink.runtime.memory.MemoryManager getMemoryManager()
        Returns the current MemoryManager.

      • getMemorySize

        long getMemorySize()
        Returns the managed memory size can be used by this operator.

      • getKeyedStateBackend

        org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> getKeyedStateBackend()
        Returns the current KeyedStateBackend.

      • getTimerService

        org.apache.flink.streaming.api.operators.InternalTimerService<W> getTimerService()
        Returns the current InternalTimerService.

      • getRuntimeContext

        org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()
        Returns the current RuntimeContext.

      • output

        void output​(org.apache.flink.table.data.RowData result)
        Outputs results to downstream operators.