Class ForStMemoryConfiguration

    • Constructor Detail

      • ForStMemoryConfiguration

        public ForStMemoryConfiguration()
    • Method Detail

      • setUseManagedMemory

        public void setUseManagedMemory​(boolean useManagedMemory)
        Configures ForSt to use the managed memory of a slot. See ForStOptions.USE_MANAGED_MEMORY for details.
      • setFixedMemoryPerSlot

        public void setFixedMemoryPerSlot​(org.apache.flink.configuration.MemorySize fixedMemoryPerSlot)
        Configures ForSt to use a fixed amount of memory shared between all instances (operators) in a slot. See ForStOptions.FIX_PER_SLOT_MEMORY_SIZE for details.
      • setFixedMemoryPerSlot

        public void setFixedMemoryPerSlot​(String totalMemoryPerSlotStr)
        Configures ForSt to use a fixed amount of memory shared between all instances (operators) in a slot. See setFixedMemoryPerSlot(MemorySize) for details.
      • isUsingManagedMemory

        public boolean isUsingManagedMemory()
        Gets whether the state backend is configured to use the managed memory of a slot for ForSt. See ForStOptions.USE_MANAGED_MEMORY for details.
      • isUsingFixedMemoryPerSlot

        public boolean isUsingFixedMemoryPerSlot()
        Gets whether the state backend is configured to use a fixed amount of memory shared between all ForSt instances (in all tasks and operators) of a slot. See ForStOptions.FIX_PER_SLOT_MEMORY_SIZE for details.
      • getFixedMemoryPerSlot

        @Nullable
        public org.apache.flink.configuration.MemorySize getFixedMemoryPerSlot()
        Gets the fixed amount of memory to be shared between all RocksDB instances (in all tasks and operators) of a slot. Null is not configured. See ForStOptions.USE_MANAGED_MEMORY for details.
      • validate

        public void validate()
        Validates if the configured options are valid with respect to one another.
      • fromOtherAndConfiguration

        public static ForStMemoryConfiguration fromOtherAndConfiguration​(ForStMemoryConfiguration other,
                                                                         org.apache.flink.configuration.ReadableConfig config)
        Derives a ForStMemoryConfiguration from another object and a configuration. The values set on the other object take precedence, and the values from the configuration are used if no values are set on the other config object.
      • fromConfiguration

        public static ForStMemoryConfiguration fromConfiguration​(org.apache.flink.configuration.Configuration configuration)