Package org.apache.flink.table.runtime.operators.join.stream.state

Interface MultiJoinStateView

  • public interface MultiJoinStateView
    Interface for state view handling records under a specific map key within the main join key's context.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void addRecord​(org.apache.flink.table.data.RowData joinKey, org.apache.flink.table.data.RowData record)
      Adds the record to the state view under the given join key.
      Iterable<org.apache.flink.table.data.RowData> getRecords​(org.apache.flink.table.data.RowData joinKey)
      Gets all the records under the given join key.
      void retractRecord​(org.apache.flink.table.data.RowData joinKey, org.apache.flink.table.data.RowData record)
      Retract the record from the state view under the given join key.

    • Method Detail

      • addRecord

        void addRecord​(org.apache.flink.table.data.RowData joinKey,
               org.apache.flink.table.data.RowData record)
        throws Exception
        Adds the record to the state view under the given join key.
        Throws:
        Exception

      • retractRecord

        void retractRecord​(org.apache.flink.table.data.RowData joinKey,
                   org.apache.flink.table.data.RowData record)
            throws Exception
        Retract the record from the state view under the given join key.
        Throws:
        Exception

      • getRecords

        Iterable<org.apache.flink.table.data.RowData> getRecords​(org.apache.flink.table.data.RowData joinKey)
                                                  throws Exception
        Gets all the records under the given join key.
        Throws:
        Exception