Class CdcAsFlussMap

  • All Implemented Interfaces:
    org.apache.fluss.row.InternalMap

    public class CdcAsFlussMap
    extends Object
    implements org.apache.fluss.row.InternalMap
    Wraps a Cdc MapData as a Fluss InternalMap.
    • Constructor Detail

      • CdcAsFlussMap

        public CdcAsFlussMap​(MapData cdcMap)
    • Method Detail

      • size

        public int size()
        Specified by:
        size in interface org.apache.fluss.row.InternalMap
      • keyArray

        public org.apache.fluss.row.InternalArray keyArray()
        Specified by:
        keyArray in interface org.apache.fluss.row.InternalMap
      • valueArray

        public org.apache.fluss.row.InternalArray valueArray()
        Specified by:
        valueArray in interface org.apache.fluss.row.InternalMap