Package org.apache.flink.table.runtime.context

Interface ExecutionContext

  • All Known Implementing Classes:
    ExecutionContextImpl
    public interface ExecutionContext
    A ExecutionContext contains information about the context in which functions are executed and the APIs to create state.

    • Method Detail

      • currentKey

        org.apache.flink.table.data.RowData currentKey()
        Returns:
        key of the current processed element.

      • setCurrentKey

        void setCurrentKey​(org.apache.flink.table.data.RowData key)
        Sets current key.

      • getRuntimeContext

        org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()