Interface StateBackend.KeyedStateBackendParameters<K>

    • Method Detail

      • getEnv

        Environment getEnv()
        Returns:
        The runtime environment of the executing task.
      • getJobID

        JobID getJobID()
      • getOperatorIdentifier

        String getOperatorIdentifier()
      • getNumberOfKeyGroups

        int getNumberOfKeyGroups()
      • getKeyGroupRange

        KeyGroupRange getKeyGroupRange()
        Returns:
        Range of key-groups for which the to-be-created backend is responsible.
      • getTtlTimeProvider

        TtlTimeProvider getTtlTimeProvider()
        Returns:
        Provider for TTL logic to judge about state expiration.
      • getCancelStreamRegistry

        CloseableRegistry getCancelStreamRegistry()
        Returns:
        The registry to which created closeable objects will be * registered during restore.
      • getManagedMemoryFraction

        double getManagedMemoryFraction()