Package org.apache.flink.api.common.operators

Class SlotSharingGroup.Builder

    • Method Detail

      • setCpuCores

        public SlotSharingGroup.Builder setCpuCores​(double cpuCores)
        Set the CPU cores for this SlotSharingGroup.

      • setTaskHeapMemory

        public SlotSharingGroup.Builder setTaskHeapMemory​(org.apache.flink.configuration.MemorySize taskHeapMemory)
        Set the task heap memory for this SlotSharingGroup.

      • setTaskHeapMemoryMB

        public SlotSharingGroup.Builder setTaskHeapMemoryMB​(int taskHeapMemoryMB)
        Set the task heap memory for this SlotSharingGroup in MB.

      • setTaskOffHeapMemory

        public SlotSharingGroup.Builder setTaskOffHeapMemory​(org.apache.flink.configuration.MemorySize taskOffHeapMemory)
        Set the task off-heap memory for this SlotSharingGroup.

      • setTaskOffHeapMemoryMB

        public SlotSharingGroup.Builder setTaskOffHeapMemoryMB​(int taskOffHeapMemoryMB)
        Set the task off-heap memory for this SlotSharingGroup in MB.

      • setManagedMemory

        public SlotSharingGroup.Builder setManagedMemory​(org.apache.flink.configuration.MemorySize managedMemory)
        Set the task managed memory for this SlotSharingGroup.

      • setManagedMemoryMB

        public SlotSharingGroup.Builder setManagedMemoryMB​(int managedMemoryMB)
        Set the task managed memory for this SlotSharingGroup in MB.

      • setExternalResource

        public SlotSharingGroup.Builder setExternalResource​(String name,
                                                    double value)
        Add the given external resource. The old value with the same resource name will be replaced if present.