Package io.github.flink.gcp.connector.base.sink

package io.github.flink.gcp.connector.base.sink
  • Classes
    Class
    Description
    PerKeyWriteSequencer<K,W>
    Admits one write per key at a time and holds the rest of that key's writes in arrival order.