Uses of Class
org.apache.flink.configuration.JobManagerOptions.HybridPartitionDataConsumeConstraint

Packages that use JobManagerOptions.HybridPartitionDataConsumeConstraint

Package	Description
org.apache.flink.configuration
org.apache.flink.runtime.scheduler.adaptivebatch

Uses of JobManagerOptions.HybridPartitionDataConsumeConstraint in org.apache.flink.configuration

Fields in org.apache.flink.configuration with type parameters of type JobManagerOptions.HybridPartitionDataConsumeConstraint

Modifier and Type	Field and Description
static ConfigOption<JobManagerOptions.HybridPartitionDataConsumeConstraint>	JobManagerOptions.HYBRID_PARTITION_DATA_CONSUME_CONSTRAINT

Methods in org.apache.flink.configuration that return JobManagerOptions.HybridPartitionDataConsumeConstraint

Modifier and Type	Method and Description
static JobManagerOptions.HybridPartitionDataConsumeConstraint	JobManagerOptions.HybridPartitionDataConsumeConstraint.valueOf(String name) Returns the enum constant of this type with the specified name.
static JobManagerOptions.HybridPartitionDataConsumeConstraint[]	JobManagerOptions.HybridPartitionDataConsumeConstraint.values() Returns an array containing the constants of this enum type, in the order they are declared.

Uses of JobManagerOptions.HybridPartitionDataConsumeConstraint in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch that return JobManagerOptions.HybridPartitionDataConsumeConstraint

Modifier and Type	Method and Description
static JobManagerOptions.HybridPartitionDataConsumeConstraint	AdaptiveBatchSchedulerFactory.getOrDecideHybridPartitionDataConsumeConstraint(Configuration configuration, boolean enableSpeculativeExecution)

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type JobManagerOptions.HybridPartitionDataConsumeConstraint

Modifier and Type	Method and Description
static InputConsumableDecider.Factory	AdaptiveBatchSchedulerFactory.loadInputConsumableDeciderFactory(JobManagerOptions.HybridPartitionDataConsumeConstraint hybridPartitionDataConsumeConstraint)

Constructors in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type JobManagerOptions.HybridPartitionDataConsumeConstraint

Constructor and Description

AdaptiveBatchScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Time rpcTimeout, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, int defaultMaxParallelism, BlocklistOperations blocklistOperations, JobManagerOptions.HybridPartitionDataConsumeConstraint hybridPartitionDataConsumeConstraint, Map<JobVertexID,ForwardGroup> forwardGroupsByJobVertexId, BatchJobRecoveryHandler jobRecoveryHandler)