Package org.apache.flink.table.runtime.sequencedmultisetstate

Interface TimeSelector

  • All Superinterfaces:
    Serializable
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @Internal
@FunctionalInterface
public interface TimeSelector
extends Serializable

    • Method Detail

      • getTimestamp

        long getTimestamp​(long elementTimestamp)

      • getTimeDomain

        static TimeSelector getTimeDomain​(org.apache.flink.streaming.api.TimeDomain timeDomain)