Uses of Class
org.apache.flink.api.common.time.Time

Packages that use Time

Package	Description
org.apache.flink.api.common.restartstrategy
org.apache.flink.api.common.state
org.apache.flink.api.common.time
org.apache.flink.configuration
org.apache.flink.kubernetes.configuration
org.apache.flink.runtime.concurrent
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.restart
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.metrics.dump
org.apache.flink.runtime.metrics.util
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.rest
org.apache.flink.runtime.rest.handler
org.apache.flink.runtime.rest.handler.async
org.apache.flink.runtime.rest.handler.cluster
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.job.checkpoints
org.apache.flink.runtime.rest.handler.job.metrics
org.apache.flink.runtime.rest.handler.job.rescaling
org.apache.flink.runtime.rest.handler.job.savepoints
org.apache.flink.runtime.rest.handler.legacy
org.apache.flink.runtime.rest.handler.legacy.files
org.apache.flink.runtime.rest.handler.legacy.metrics
org.apache.flink.runtime.rest.handler.taskmanager
org.apache.flink.runtime.rpc
org.apache.flink.runtime.rpc.akka
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskexecutor.slot
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.retriever
org.apache.flink.runtime.webmonitor.retriever.impl
org.apache.flink.streaming.connectors.kafka
org.apache.flink.table.api
org.apache.flink.test.util

Uses of Time in org.apache.flink.api.common.restartstrategy

Methods in org.apache.flink.api.common.restartstrategy that return Time

Modifier and Type	Method and Description
Time	RestartStrategies.FixedDelayRestartStrategyConfiguration.getDelayBetweenAttemptsInterval()
Time	RestartStrategies.FailureRateRestartStrategyConfiguration.getDelayBetweenAttemptsInterval()
Time	RestartStrategies.FailureRateRestartStrategyConfiguration.getFailureInterval()

Methods in org.apache.flink.api.common.restartstrategy with parameters of type Time

Modifier and Type	Method and Description
static RestartStrategies.FailureRateRestartStrategyConfiguration	RestartStrategies.failureRateRestart(int failureRate, Time failureInterval, Time delayInterval) Generates a FailureRateRestartStrategyConfiguration.
static RestartStrategies.RestartStrategyConfiguration	RestartStrategies.fixedDelayRestart(int restartAttempts, Time delayInterval) Generates a FixedDelayRestartStrategyConfiguration.

Constructors in org.apache.flink.api.common.restartstrategy with parameters of type Time

Constructor and Description
FailureRateRestartStrategyConfiguration(int maxFailureRate, Time failureInterval, Time delayBetweenAttemptsInterval)

Uses of Time in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return Time

Modifier and Type	Method and Description
Time	StateTtlConfig.getTtl()

Methods in org.apache.flink.api.common.state with parameters of type Time

Modifier and Type	Method and Description
static StateTtlConfig.Builder	StateTtlConfig.newBuilder(Time ttl)
StateTtlConfig.Builder	StateTtlConfig.Builder.setTtl(Time ttl) Sets the ttl time.

Constructors in org.apache.flink.api.common.state with parameters of type Time

Constructor and Description
Builder(Time ttl)

Uses of Time in org.apache.flink.api.common.time

Methods in org.apache.flink.api.common.time that return Time

Modifier and Type	Method and Description
static Time	Time.days(long days) Creates a new Time that represents the given number of days.
static Time	Time.hours(long hours) Creates a new Time that represents the given number of hours.
static Time	Time.milliseconds(long milliseconds) Creates a new Time that represents the given number of milliseconds.
static Time	Time.minutes(long minutes) Creates a new Time that represents the given number of minutes.
static Time	Time.of(long size, TimeUnit unit) Creates a new Time of the given duration and TimeUnit.
static Time	Time.seconds(long seconds) Creates a new Time that represents the given number of seconds.

Uses of Time in org.apache.flink.configuration

Methods in org.apache.flink.configuration that return Time

Modifier and Type	Method and Description
static Time	ConfigurationUtils.getStandaloneClusterStartupPeriodTime(Configuration configuration)

Methods in org.apache.flink.configuration that return types with arguments of type Time

Modifier and Type	Method and Description
static Optional<Time>	ConfigurationUtils.getSystemResourceMetricsProbingInterval(Configuration configuration)

Uses of Time in org.apache.flink.kubernetes.configuration

Methods in org.apache.flink.kubernetes.configuration that return Time

Modifier and Type	Method and Description
Time	KubernetesResourceManagerConfiguration.getPodCreationRetryInterval()

Constructors in org.apache.flink.kubernetes.configuration with parameters of type Time

Constructor and Description
KubernetesResourceManagerConfiguration(String clusterId, Time podCreationRetryInterval)

Uses of Time in org.apache.flink.runtime.concurrent

Methods in org.apache.flink.runtime.concurrent with parameters of type Time

Modifier and Type	Method and Description
static <T> CompletableFuture<T>	FutureUtils.retrySuccessfulWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, Time retryDelay, Deadline deadline, java.util.function.Predicate<T> acceptancePredicate, ScheduledExecutor scheduledExecutor) Retry the given operation with the given delay in between successful completions where the result does not match a given predicate.
static <T> CompletableFuture<T>	FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, int retries, Time retryDelay, java.util.function.Predicate<Throwable> retryPredicate, ScheduledExecutor scheduledExecutor) Retry the given operation with the given delay in between failures.
static <T> CompletableFuture<T>	FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, int retries, Time retryDelay, ScheduledExecutor scheduledExecutor) Retry the given operation with the given delay in between failures.
static CompletableFuture<Void>	FutureUtils.scheduleWithDelay(Runnable operation, Time delay, ScheduledExecutor scheduledExecutor) Schedule the operation with the given delay.
static <T> CompletableFuture<T>	FutureUtils.scheduleWithDelay(java.util.function.Supplier<T> operation, Time delay, ScheduledExecutor scheduledExecutor) Schedule the operation with the given delay.
static java.time.Duration	FutureUtils.toDuration(Time time) Converts Flink time into a Duration.

Uses of Time in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	Dispatcher.cancelJob(JobID jobId, Time timeout)
CompletableFuture<Acknowledge>	MiniDispatcher.cancelJob(JobID jobId, Time timeout)
CompletableFuture<Acknowledge>	Dispatcher.disposeSavepoint(String savepointPath, Time timeout)
CompletableFuture<Integer>	DispatcherGateway.getBlobServerPort(Time timeout) Returns the port of the blob server.
CompletableFuture<Integer>	Dispatcher.getBlobServerPort(Time timeout)
CompletableFuture<Collection<JobID>>	DispatcherGateway.listJobs(Time timeout) List the current set of submitted jobs.
CompletableFuture<Collection<JobID>>	Dispatcher.listJobs(Time timeout)
CompletableFuture<ClusterOverview>	Dispatcher.requestClusterOverview(Time timeout)
CompletableFuture<ArchivedExecutionGraph>	DispatcherGateway.requestJob(JobID jobId, Time timeout) Requests the ArchivedExecutionGraph for the given jobId.
CompletableFuture<ArchivedExecutionGraph>	Dispatcher.requestJob(JobID jobId, Time timeout)
CompletableFuture<JobResult>	Dispatcher.requestJobResult(JobID jobId, Time timeout)
CompletableFuture<JobResult>	MiniDispatcher.requestJobResult(JobID jobId, Time timeout)
CompletableFuture<JobStatus>	Dispatcher.requestJobStatus(JobID jobId, Time timeout)
CompletableFuture<Collection<String>>	Dispatcher.requestMetricQueryServiceAddresses(Time timeout)
CompletableFuture<MultipleJobsDetails>	Dispatcher.requestMultipleJobDetails(Time timeout)
CompletableFuture<Collection<Tuple2<ResourceID,String>>>	Dispatcher.requestTaskManagerMetricQueryServiceAddresses(Time timeout)
CompletableFuture<String>	Dispatcher.stopWithSavepoint(JobID jobId, String targetDirectory, boolean advanceToEndOfEventTime, Time timeout)
CompletableFuture<Acknowledge>	DispatcherGateway.submitJob(JobGraph jobGraph, Time timeout) Submit a job to the dispatcher.
CompletableFuture<Acknowledge>	Dispatcher.submitJob(JobGraph jobGraph, Time timeout)
CompletableFuture<Acknowledge>	MiniDispatcher.submitJob(JobGraph jobGraph, Time timeout)
CompletableFuture<String>	Dispatcher.triggerSavepoint(JobID jobId, String targetDirectory, boolean cancelJob, Time timeout)

Constructors in org.apache.flink.runtime.dispatcher with parameters of type Time

Constructor and Description
FileArchivedExecutionGraphStore(File rootDir, Time expirationTime, int maximumCapacity, long maximumCacheSizeBytes, ScheduledExecutor scheduledExecutor, org.apache.flink.shaded.guava18.com.google.common.base.Ticker ticker)

Uses of Time in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return Time

Modifier and Type	Method and Description
Time	ExecutionGraph.getAllocationTimeout()

Methods in org.apache.flink.runtime.executiongraph with parameters of type Time

Modifier and Type	Method and Description
static ExecutionGraph	ExecutionGraphBuilder.buildGraph(ExecutionGraph prior, JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, CheckpointRecoveryFactory recoveryFactory, Time rpcTimeout, RestartStrategy restartStrategy, MetricGroup metrics, BlobWriter blobWriter, Time allocationTimeout, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker) Builds the ExecutionGraph from the JobGraph.
static ExecutionGraph	ExecutionGraphBuilder.buildGraph(ExecutionGraph prior, JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, CheckpointRecoveryFactory recoveryFactory, Time rpcTimeout, RestartStrategy restartStrategy, MetricGroup metrics, BlobWriter blobWriter, Time allocationTimeout, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, FailoverStrategy.Factory failoverStrategyFactory)
static SlotProviderStrategy	SlotProviderStrategy.from(ScheduleMode scheduleMode, SlotProvider slotProvider, Time allocationTimeout)
CompletableFuture<TaskBackPressureResponse>	Execution.requestBackPressure(int requestId, Time timeout) Request the back pressure ratio from the task of this execution.

Constructors in org.apache.flink.runtime.executiongraph with parameters of type Time

Constructor and Description
Execution(Executor executor, ExecutionVertex vertex, int attemptNumber, long globalModVersion, long startTimestamp, Time rpcTimeout) Creates a new Execution attempt.
ExecutionGraph(JobInformation jobInformation, ScheduledExecutorService futureExecutor, Executor ioExecutor, Time rpcTimeout, RestartStrategy restartStrategy, int maxPriorAttemptsHistoryLength, FailoverStrategy.Factory failoverStrategyFactory, SlotProvider slotProvider, ClassLoader userClassLoader, BlobWriter blobWriter, Time allocationTimeout, PartitionReleaseStrategy.Factory partitionReleaseStrategyFactory, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ScheduleMode scheduleMode)
ExecutionJobVertex(ExecutionGraph graph, JobVertex jobVertex, int defaultParallelism, int maxPriorAttemptsHistoryLength, Time timeout, long initialGlobalModVersion, long createTimestamp)
ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, Time timeout, long initialGlobalModVersion, long createTimestamp, int maxPriorExecutionHistoryLength) Creates an ExecutionVertex.

Uses of Time in org.apache.flink.runtime.executiongraph.restart

Constructors in org.apache.flink.runtime.executiongraph.restart with parameters of type Time

Constructor and Description
FailureRateRestartStrategy(int maxFailuresPerInterval, Time failuresInterval, Time delayInterval)
FailureRateRestartStrategyFactory(int maxFailuresPerInterval, Time failuresInterval, Time delayInterval)

Uses of Time in org.apache.flink.runtime.jobmanager.slots

Methods in org.apache.flink.runtime.jobmanager.slots with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	TaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID, Time timeout) Cancel the given task.
CompletableFuture<Acknowledge>	TaskManagerGateway.freeSlot(AllocationID allocationId, Throwable cause, Time timeout) Frees the slot with the given allocation ID.
CompletableFuture<TaskBackPressureResponse>	TaskManagerGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptID, int requestId, Time timeout) Request the back pressure ratio for the given task.
CompletableFuture<Acknowledge>	TaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd, Time timeout) Submit a task to the task manager.
CompletableFuture<Acknowledge>	TaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout) Update the task where the given partitions can be found.

Uses of Time in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return Time

Modifier and Type	Method and Description
Time	JobMasterConfiguration.getRpcTimeout()
Time	JobMasterConfiguration.getSlotRequestTimeout()

Methods in org.apache.flink.runtime.jobmaster with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	JobMaster.cancel(Time timeout)
CompletableFuture<Acknowledge>	JobMasterGateway.cancel(Time timeout) Cancels the currently executed job.
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID, Time timeout)
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.freeSlot(AllocationID allocationId, Throwable cause, Time timeout)
CompletableFuture<Collection<SlotOffer>>	JobMaster.offerSlots(ResourceID taskManagerId, Collection<SlotOffer> slots, Time timeout)
CompletableFuture<Collection<SlotOffer>>	JobMasterGateway.offerSlots(ResourceID taskManagerId, Collection<SlotOffer> slots, Time timeout) Offers the given slots to the job manager.
CompletableFuture<RegistrationResponse>	JobMaster.registerTaskManager(String taskManagerRpcAddress, TaskManagerLocation taskManagerLocation, Time timeout)
CompletableFuture<RegistrationResponse>	JobMasterGateway.registerTaskManager(String taskManagerRpcAddress, TaskManagerLocation taskManagerLocation, Time timeout) Registers the task manager at the job manager.
CompletableFuture<ArchivedExecutionGraph>	JobMaster.requestJob(Time timeout)
CompletableFuture<ArchivedExecutionGraph>	JobMasterGateway.requestJob(Time timeout) Requests the ArchivedExecutionGraph of the executed job.
CompletableFuture<JobDetails>	JobMaster.requestJobDetails(Time timeout)
CompletableFuture<JobDetails>	JobMasterGateway.requestJobDetails(Time timeout) Request the details of the executed job.
CompletableFuture<JobStatus>	JobMaster.requestJobStatus(Time timeout)
CompletableFuture<JobStatus>	JobMasterGateway.requestJobStatus(Time timeout) Requests the current job status.
CompletableFuture<TaskBackPressureResponse>	RpcTaskManagerGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptID, int requestId, Time timeout)
CompletableFuture<Acknowledge>	JobMaster.scheduleOrUpdateConsumers(ResultPartitionID partitionID, Time timeout)
CompletableFuture<Acknowledge>	JobMasterGateway.scheduleOrUpdateConsumers(ResultPartitionID partitionID, Time timeout) Notifies the JobManager about available data for a produced partition.
CompletableFuture<String>	JobMaster.stopWithSavepoint(String targetDirectory, boolean advanceToEndOfEventTime, Time timeout)
CompletableFuture<String>	JobMasterGateway.stopWithSavepoint(String targetDirectory, boolean advanceToEndOfEventTime, Time timeout) Stops the job with a savepoint.
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd, Time timeout)
CompletableFuture<String>	JobMaster.triggerSavepoint(String targetDirectory, boolean cancelJob, Time timeout)
CompletableFuture<String>	JobMasterGateway.triggerSavepoint(String targetDirectory, boolean cancelJob, Time timeout) Triggers taking a savepoint of the executed job.
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout)

Constructors in org.apache.flink.runtime.jobmaster with parameters of type Time

Constructor and Description
JobMasterConfiguration(Time rpcTimeout, Time slotRequestTimeout, String tmpDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration, Configuration configuration)

Uses of Time in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type Time

Modifier and Type	Method and Description
default CompletableFuture<LogicalSlot>	SlotProvider.allocateSlot(ScheduledUnit scheduledUnit, SlotProfile slotProfile, Time allocationTimeout) Allocating slot with specific requirement.
CompletableFuture<LogicalSlot>	SlotProvider.allocateSlot(SlotRequestId slotRequestId, ScheduledUnit scheduledUnit, SlotProfile slotProfile, Time allocationTimeout) Allocating slot with specific requirement.
CompletableFuture<LogicalSlot>	SchedulerImpl.allocateSlot(SlotRequestId slotRequestId, ScheduledUnit scheduledUnit, SlotProfile slotProfile, Time allocationTimeout)
CompletableFuture<PhysicalSlot>	SlotPoolImpl.requestNewAllocatedSlot(SlotRequestId slotRequestId, ResourceProfile resourceProfile, Time timeout)
CompletableFuture<PhysicalSlot>	SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId, ResourceProfile resourceProfile, Time timeout) Request the allocation of a new slot from the resource manager.
protected void	SlotPoolImpl.scheduleRunAsync(Runnable runnable, Time delay) Execute the runnable in the main thread of the underlying RPC endpoint, with a delay of the given number of milliseconds.

Constructors in org.apache.flink.runtime.jobmaster.slotpool with parameters of type Time

Constructor and Description
DefaultSlotPoolFactory(Clock clock, Time rpcTimeout, Time slotIdleTimeout, Time batchSlotTimeout)
SlotPoolImpl(JobID jobId, Clock clock, Time rpcTimeout, Time idleSlotTimeout, Time batchSlotTimeout)

Uses of Time in org.apache.flink.runtime.metrics.dump

Methods in org.apache.flink.runtime.metrics.dump with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<MetricDumpSerialization.MetricSerializationResult>	MetricQueryService.queryMetrics(Time timeout)

Uses of Time in org.apache.flink.runtime.metrics.util

Methods in org.apache.flink.runtime.metrics.util with parameters of type Time

Modifier and Type	Method and Description
static void	SystemResourcesMetricsInitializer.instantiateSystemMetrics(MetricGroup metricGroup, Time probeInterval)

Method parameters in org.apache.flink.runtime.metrics.util with type arguments of type Time

Modifier and Type	Method and Description
static ProcessMetricGroup	MetricUtils.instantiateProcessMetricGroup(MetricRegistry metricRegistry, String hostname, Optional<Time> systemResourceProbeInterval)
static Tuple2<TaskManagerMetricGroup,MetricGroup>	MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry, String hostName, ResourceID resourceID, Optional<Time> systemResourceProbeInterval)

Constructors in org.apache.flink.runtime.metrics.util with parameters of type Time

Constructor and Description
SystemResourcesCounter(Time probeInterval)

Uses of Time in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return Time

Modifier and Type	Method and Description
Time	MiniClusterConfiguration.getRpcTimeout()

Uses of Time in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return Time

Modifier and Type	Method and Description
Time	ResourceManagerRuntimeServicesConfiguration.getJobTimeout()

Methods in org.apache.flink.runtime.resourcemanager with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<RegistrationResponse>	ResourceManagerGateway.registerJobManager(JobMasterId jobMasterId, ResourceID jobMasterResourceId, String jobMasterAddress, JobID jobId, Time timeout) Register a JobMaster at the resource manager.
CompletableFuture<RegistrationResponse>	ResourceManager.registerJobManager(JobMasterId jobMasterId, ResourceID jobManagerResourceId, String jobManagerAddress, JobID jobId, Time timeout)
CompletableFuture<RegistrationResponse>	ResourceManagerGateway.registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration, Time timeout) Register a TaskExecutor at the resource manager.
CompletableFuture<RegistrationResponse>	ResourceManager.registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration, Time timeout)
CompletableFuture<ResourceOverview>	ResourceManagerGateway.requestResourceOverview(Time timeout) Requests the resource overview.
CompletableFuture<ResourceOverview>	ResourceManager.requestResourceOverview(Time timeout)
CompletableFuture<Acknowledge>	ResourceManagerGateway.requestSlot(JobMasterId jobMasterId, SlotRequest slotRequest, Time timeout) Requests a slot from the resource manager.
CompletableFuture<Acknowledge>	ResourceManager.requestSlot(JobMasterId jobMasterId, SlotRequest slotRequest, Time timeout)
CompletableFuture<TransientBlobKey>	ResourceManagerGateway.requestTaskManagerFileUpload(ResourceID taskManagerId, FileType fileType, Time timeout) Request the file upload from the given TaskExecutor to the cluster's BlobServer.
CompletableFuture<TransientBlobKey>	ResourceManager.requestTaskManagerFileUpload(ResourceID taskManagerId, FileType fileType, Time timeout)
CompletableFuture<TaskManagerInfo>	ResourceManagerGateway.requestTaskManagerInfo(ResourceID taskManagerId, Time timeout) Requests information about the given TaskExecutor.
CompletableFuture<TaskManagerInfo>	ResourceManager.requestTaskManagerInfo(ResourceID resourceId, Time timeout)
CompletableFuture<Collection<TaskManagerInfo>>	ResourceManagerGateway.requestTaskManagerInfo(Time timeout) Requests information about the registered TaskExecutor.
CompletableFuture<Collection<TaskManagerInfo>>	ResourceManager.requestTaskManagerInfo(Time timeout)
CompletableFuture<Collection<Tuple2<ResourceID,String>>>	ResourceManagerGateway.requestTaskManagerMetricQueryServiceAddresses(Time timeout) Requests the paths for the TaskManager's MetricQueryService to query.
CompletableFuture<Collection<Tuple2<ResourceID,String>>>	ResourceManager.requestTaskManagerMetricQueryServiceAddresses(Time timeout)
CompletableFuture<Acknowledge>	ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId, InstanceID taskManagerRegistrationId, SlotReport slotReport, Time timeout) Sends the given SlotReport to the ResourceManager.
CompletableFuture<Acknowledge>	ResourceManager.sendSlotReport(ResourceID taskManagerResourceId, InstanceID taskManagerRegistrationId, SlotReport slotReport, Time timeout)

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type Time

Constructor and Description
JobLeaderIdService(HighAvailabilityServices highAvailabilityServices, ScheduledExecutor scheduledExecutor, Time jobTimeout)
ResourceManagerRuntimeServicesConfiguration(Time jobTimeout, SlotManagerConfiguration slotManagerConfiguration)
StandaloneResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time startupPeriodTime)

Uses of Time in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return Time

Modifier and Type	Method and Description
Time	SlotManagerConfiguration.getSlotRequestTimeout()
Time	SlotManagerConfiguration.getTaskManagerRequestTimeout()
Time	SlotManagerConfiguration.getTaskManagerTimeout()

Constructors in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type Time

Constructor and Description
SlotManagerConfiguration(Time taskManagerRequestTimeout, Time slotRequestTimeout, Time taskManagerTimeout, boolean waitResultConsumedBeforeRelease, boolean evenlySpreadOutSlots)
SlotManagerImpl(SlotMatchingStrategy slotMatchingStrategy, ScheduledExecutor scheduledExecutor, Time taskManagerRequestTimeout, Time slotRequestTimeout, Time taskManagerTimeout, boolean waitResultConsumedBeforeRelease)

Uses of Time in org.apache.flink.runtime.rest

Methods in org.apache.flink.runtime.rest with parameters of type Time

Modifier and Type	Method and Description
void	RestClient.shutdown(Time timeout)

Uses of Time in org.apache.flink.runtime.rest.handler

Fields in org.apache.flink.runtime.rest.handler declared as Time

Modifier and Type	Field and Description
protected Time	LeaderRetrievalHandler.timeout

Methods in org.apache.flink.runtime.rest.handler that return Time

Modifier and Type	Method and Description
Time	RestHandlerConfiguration.getTimeout()

Constructors in org.apache.flink.runtime.rest.handler with parameters of type Time

Constructor and Description
AbstractHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<R,M> untypedResponseMessageHeaders)
AbstractRestHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders)
LeaderRetrievalHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
RestHandlerConfiguration(long refreshInterval, int maxCheckpointStatisticCacheEntries, Time timeout, File webUiDir, boolean webSubmitEnabled)

Uses of Time in org.apache.flink.runtime.rest.handler.async

Constructors in org.apache.flink.runtime.rest.handler.async with parameters of type Time

Constructor and Description
StatusHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,AsynchronousOperationResult<V>,M> messageHeaders)
TriggerHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<B,TriggerResponse,M> messageHeaders)

Uses of Time in org.apache.flink.runtime.rest.handler.cluster

Constructors in org.apache.flink.runtime.rest.handler.cluster with parameters of type Time

Constructor and Description
ClusterConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ClusterConfigurationInfo,EmptyMessageParameters> messageHeaders, Configuration configuration)
ClusterOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ClusterOverviewWithVersion,EmptyMessageParameters> messageHeaders)
DashboardConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,DashboardConfiguration,EmptyMessageParameters> messageHeaders, long refreshInterval, boolean webSubmitEnabled)
ShutdownHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)

Uses of Time in org.apache.flink.runtime.rest.handler.job

Constructors in org.apache.flink.runtime.rest.handler.job with parameters of type Time

Constructor and Description
AbstractExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
AbstractSubtaskAttemptHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
AbstractSubtaskHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
JobAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobCancellationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobCancellationMessageParameters> messageHeaders, TerminationModeQueryParameter.TerminationMode defaultTerminationMode)
JobConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobConfigInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobDetailsInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobExceptionsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobExceptionsInfo,JobExceptionsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobExecutionResultHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
JobIdsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobIdsWithStatusOverview,EmptyMessageParameters> messageHeaders)
JobPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,JobPlanInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobsOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,MultipleJobsDetails,EmptyMessageParameters> messageHeaders)
JobSubmitHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> headers, Executor executor, Configuration configuration)
JobVertexAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobVertexBackPressureHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexBackPressureInfo,JobVertexMessageParameters> messageHeaders)
JobVertexDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexDetailsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobVertexTaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexTaskManagersInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
SubtaskExecutionAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher) Instantiates a new subtask execution attempt details handler.
SubtasksAllAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
SubtasksTimesHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksTimesInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)

Uses of Time in org.apache.flink.runtime.rest.handler.job.checkpoints

Constructors in org.apache.flink.runtime.rest.handler.job.checkpoints with parameters of type Time

Constructor and Description
AbstractCheckpointHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
CheckpointConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointConfigInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
CheckpointingStatisticsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointingStatistics,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
CheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointStatistics,CheckpointMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
TaskCheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)

Uses of Time in org.apache.flink.runtime.rest.handler.job.metrics

Constructors in org.apache.flink.runtime.rest.handler.job.metrics with parameters of type Time

Constructor and Description
AbstractAggregatingMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, AbstractAggregatedMetricsHeaders<P> messageHeaders, Executor executor, MetricFetcher fetcher)
AbstractMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,MetricCollectionResponseBody,M> messageHeaders, MetricFetcher metricFetcher)
AggregatingJobsMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, Executor executor, MetricFetcher fetcher)
AggregatingSubtasksMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, Executor executor, MetricFetcher fetcher)
AggregatingTaskManagersMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, Executor executor, MetricFetcher fetcher)
JobManagerMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)
JobMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)
JobVertexMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher) Deprecated.
JobVertexWatermarksHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MetricFetcher metricFetcher, ExecutionGraphCache executionGraphCache, Executor executor)
SubtaskMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)
TaskManagerMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)

Uses of Time in org.apache.flink.runtime.rest.handler.job.rescaling

Constructors in org.apache.flink.runtime.rest.handler.job.rescaling with parameters of type Time

Constructor and Description
RescalingStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
RescalingTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)

Uses of Time in org.apache.flink.runtime.rest.handler.job.savepoints

Constructors in org.apache.flink.runtime.rest.handler.job.savepoints with parameters of type Time

Constructor and Description
SavepointDisposalStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
SavepointDisposalTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
SavepointStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
SavepointTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
StopWithSavepointHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)

Uses of Time in org.apache.flink.runtime.rest.handler.legacy

Constructors in org.apache.flink.runtime.rest.handler.legacy with parameters of type Time

Constructor and Description
DefaultExecutionGraphCache(Time timeout, Time timeToLive)

Uses of Time in org.apache.flink.runtime.rest.handler.legacy.files

Constructors in org.apache.flink.runtime.rest.handler.legacy.files with parameters of type Time

Constructor and Description
StaticFileServerHandler(GatewayRetriever<? extends T> retriever, Time timeout, File rootPath)

Uses of Time in org.apache.flink.runtime.rest.handler.legacy.metrics

Constructors in org.apache.flink.runtime.rest.handler.legacy.metrics with parameters of type Time

Constructor and Description
MetricFetcherImpl(GatewayRetriever<T> retriever, MetricQueryServiceRetriever queryServiceRetriever, Executor executor, Time timeout, long updateInterval)

Uses of Time in org.apache.flink.runtime.rest.handler.taskmanager

Constructors in org.apache.flink.runtime.rest.handler.taskmanager with parameters of type Time

Constructor and Description
AbstractTaskManagerFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,M> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagerDetailsInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, MetricFetcher metricFetcher)
TaskManagerLogFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagersInfo,EmptyMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagerStdoutFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)

Uses of Time in org.apache.flink.runtime.rpc

Fields in org.apache.flink.runtime.rpc declared as Time

Modifier and Type	Field and Description
static Time	RpcUtils.INF_TIMEOUT HACK: Set to 21474835 seconds, Akka's maximum delay (Akka 2.4.20).

Methods in org.apache.flink.runtime.rpc with parameters of type Time

Modifier and Type	Method and Description
protected <V> CompletableFuture<V>	RpcEndpoint.callAsync(Callable<V> callable, Time timeout) Execute the callable in the main thread of the underlying RPC service, returning a future for the result of the callable.
<V> CompletableFuture<V>	MainThreadExecutable.callAsync(Callable<V> callable, Time callTimeout) Execute the callable in the main thread of the underlying RPC endpoint and return a future for the callable result.
<V> CompletableFuture<V>	FencedMainThreadExecutable.callAsyncWithoutFencing(Callable<V> callable, Time timeout) Run the given callable in the main thread without attaching a fencing token.
protected <V> CompletableFuture<V>	FencedRpcEndpoint.callAsyncWithoutFencing(Callable<V> callable, Time timeout) Run the given callable in the main thread of the RpcEndpoint without checking the fencing token.
protected void	RpcEndpoint.scheduleRunAsync(Runnable runnable, Time delay) Execute the runnable in the main thread of the underlying RPC endpoint, with a delay of the given number of milliseconds.
static void	RpcUtils.terminateRpcEndpoint(RpcEndpoint rpcEndpoint, Time timeout) Shuts the given RpcEndpoint down and awaits its termination.
static void	RpcUtils.terminateRpcService(RpcService rpcService, Time timeout) Shuts the given rpc service down and waits for its termination.
static void	RpcUtils.terminateRpcServices(Time timeout, RpcService... rpcServices) Shuts the given rpc services down and waits for their termination.

Uses of Time in org.apache.flink.runtime.rpc.akka

Methods in org.apache.flink.runtime.rpc.akka that return Time

Modifier and Type	Method and Description
Time	AkkaRpcServiceConfiguration.getTimeout()

Methods in org.apache.flink.runtime.rpc.akka with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<?>	FencedAkkaInvocationHandler.ask(Object message, Time timeout)
<V> CompletableFuture<V>	FencedAkkaInvocationHandler.callAsyncWithoutFencing(Callable<V> callable, Time timeout)

Constructors in org.apache.flink.runtime.rpc.akka with parameters of type Time

Constructor and Description
AkkaRpcServiceConfiguration(Configuration configuration, Time timeout, long maximumFramesize)
FencedAkkaInvocationHandler(String address, String hostname, akka.actor.ActorRef rpcEndpoint, Time timeout, long maximumFramesize, CompletableFuture<Void> terminationFuture, java.util.function.Supplier<F> fencingTokenSupplier)

Uses of Time in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type Time

Modifier and Type	Method and Description
SchedulerNG	DefaultSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker)
SchedulerNG	SchedulerNGFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker)
SchedulerNG	LegacySchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker)

Constructors in org.apache.flink.runtime.scheduler with parameters of type Time

Constructor and Description
DefaultScheduler(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, org.apache.flink.runtime.scheduler.ExecutionVertexOperations executionVertexOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory)
LegacyScheduler(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, RestartStrategyFactory restartStrategyFactory, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker)
SchedulerBase(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, RestartStrategyFactory restartStrategyFactory, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionVertexVersioner executionVertexVersioner, boolean legacyScheduling)

Uses of Time in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return Time

Modifier and Type	Method and Description
Time	TaskManagerConfiguration.getInitialRegistrationPause()
Time	TaskManagerConfiguration.getMaxRegistrationDuration()
Time	TaskManagerConfiguration.getMaxRegistrationPause()
Time	TaskManagerConfiguration.getRefusedRegistrationPause()
Time	TaskManagerConfiguration.getTimeout()

Methods in org.apache.flink.runtime.taskexecutor that return types with arguments of type Time

Modifier and Type	Method and Description
Optional<Time>	TaskManagerServicesConfiguration.getSystemResourceMetricsProbingInterval()

Methods in org.apache.flink.runtime.taskexecutor with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID, Time timeout) Cancel the given task.
CompletableFuture<Acknowledge>	TaskExecutor.cancelTask(ExecutionAttemptID executionAttemptID, Time timeout)
CompletableFuture<Acknowledge>	TaskExecutorGateway.freeSlot(AllocationID allocationId, Throwable cause, Time timeout) Frees the slot with the given allocation ID.
CompletableFuture<Acknowledge>	TaskExecutor.freeSlot(AllocationID allocationId, Throwable cause, Time timeout)
CompletableFuture<TransientBlobKey>	TaskExecutorGateway.requestFileUpload(FileType fileType, Time timeout) Requests the file upload of the specified type to the cluster's BlobServer.
CompletableFuture<TransientBlobKey>	TaskExecutor.requestFileUpload(FileType fileType, Time timeout)
CompletableFuture<SerializableOptional<String>>	TaskExecutorGateway.requestMetricQueryServiceAddress(Time timeout) Returns the gateway of Metric Query Service on the TaskManager.
CompletableFuture<SerializableOptional<String>>	TaskExecutor.requestMetricQueryServiceAddress(Time timeout)
CompletableFuture<Acknowledge>	TaskExecutorGateway.requestSlot(SlotID slotId, JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, String targetAddress, ResourceManagerId resourceManagerId, Time timeout) Requests a slot from the TaskManager.
CompletableFuture<Acknowledge>	TaskExecutor.requestSlot(SlotID slotId, JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, String targetAddress, ResourceManagerId resourceManagerId, Time timeout)
CompletableFuture<TaskBackPressureResponse>	TaskExecutorGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptId, int requestId, Time timeout)
CompletableFuture<TaskBackPressureResponse>	TaskExecutor.requestTaskBackPressure(ExecutionAttemptID executionAttemptId, int requestId, Time timeout)
CompletableFuture<Acknowledge>	TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd, JobMasterId jobMasterId, Time timeout) Submit a Task to the TaskExecutor.
CompletableFuture<Acknowledge>	TaskExecutor.submitTask(TaskDeploymentDescriptor tdd, JobMasterId jobMasterId, Time timeout)
CompletableFuture<Acknowledge>	TaskExecutorGateway.updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout) Update the task where the given partitions can be found.
CompletableFuture<Acknowledge>	TaskExecutor.updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout)

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type Time

Constructor and Description

TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, Time timeout, Time maxRegistrationDuration, Time initialRegistrationPause, Time maxRegistrationPause, Time refusedRegistrationPause, Configuration configuration, boolean exitJvmOnOutOfMemory, FlinkUserCodeClassLoaders.ResolveOrder classLoaderResolveOrder, String[] alwaysParentFirstLoaderPatterns, String taskManagerLogPath, String taskManagerStdoutPath, RetryingRegistrationConfiguration retryingRegistrationConfiguration)

Constructor parameters in org.apache.flink.runtime.taskexecutor with type arguments of type Time

Constructor and Description

TaskManagerServicesConfiguration(Configuration configuration, ResourceID resourceID, InetAddress taskManagerAddress, boolean localCommunicationOnly, String[] tmpDirPaths, String[] localRecoveryStateRootDirectories, boolean localRecoveryEnabled, QueryableStateConfiguration queryableStateConfig, int numberOfSlots, int pageSize, TaskExecutorResourceSpec taskExecutorResourceSpec, long timerServiceShutdownTimeout, RetryingRegistrationConfiguration retryingRegistrationConfiguration, Optional<Time> systemResourceMetricsProbingInterval, int numIoThreads)

Uses of Time in org.apache.flink.runtime.taskexecutor.rpc

Constructors in org.apache.flink.runtime.taskexecutor.rpc with parameters of type Time

Constructor and Description
RpcInputSplitProvider(JobMasterGateway jobMasterGateway, JobVertexID jobVertexID, ExecutionAttemptID executionAttemptID, Time timeout)
RpcResultPartitionConsumableNotifier(JobMasterGateway jobMasterGateway, Executor executor, Time timeout)

Uses of Time in org.apache.flink.runtime.taskexecutor.slot

Methods in org.apache.flink.runtime.taskexecutor.slot with parameters of type Time

Modifier and Type	Method and Description
boolean	TaskSlotTableImpl.allocateSlot(int index, JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, Time slotTimeout)
boolean	TaskSlotTable.allocateSlot(int index, JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, Time slotTimeout) Allocate the slot with the given index for the given job and allocation id.
boolean	TaskSlotTableImpl.allocateSlot(int index, JobID jobId, AllocationID allocationId, Time slotTimeout)
boolean	TaskSlotTable.allocateSlot(int index, JobID jobId, AllocationID allocationId, Time slotTimeout) Allocate the slot with the given index for the given job and allocation id.
boolean	TaskSlotTableImpl.markSlotInactive(AllocationID allocationId, Time slotTimeout)
boolean	TaskSlotTable.markSlotInactive(AllocationID allocationId, Time slotTimeout) Marks the slot under the given allocation id as inactive.

Uses of Time in org.apache.flink.runtime.webmonitor

Methods in org.apache.flink.runtime.webmonitor with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	RestfulGateway.cancelJob(JobID jobId, Time timeout) Cancel the given job.
default CompletableFuture<Acknowledge>	RestfulGateway.disposeSavepoint(String savepointPath, Time timeout) Dispose the given savepoint.
static WebMonitorExtension	WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path uploadDir, Executor executor, Configuration configuration) Loads the WebMonitorExtension which enables web submission.
CompletableFuture<ClusterOverview>	RestfulGateway.requestClusterOverview(Time timeout) Requests the cluster status overview.
CompletableFuture<ArchivedExecutionGraph>	RestfulGateway.requestJob(JobID jobId, Time timeout) Requests the ArchivedExecutionGraph for the given jobId.
CompletableFuture<JobResult>	RestfulGateway.requestJobResult(JobID jobId, Time timeout) Requests the JobResult of a job specified by the given jobId.
default CompletableFuture<JobStatus>	RestfulGateway.requestJobStatus(JobID jobId, Time timeout) Request the JobStatus of the given job.
CompletableFuture<Collection<String>>	RestfulGateway.requestMetricQueryServiceAddresses(Time timeout) Requests the addresses of the MetricQueryService to query.
CompletableFuture<MultipleJobsDetails>	RestfulGateway.requestMultipleJobDetails(Time timeout) Requests job details currently being executed on the Flink cluster.
CompletableFuture<Collection<Tuple2<ResourceID,String>>>	RestfulGateway.requestTaskManagerMetricQueryServiceAddresses(Time timeout) Requests the addresses for the TaskManagers' MetricQueryService to query.
default CompletableFuture<String>	RestfulGateway.stopWithSavepoint(JobID jobId, String targetDirectory, boolean advanceToEndOfEventTime, Time timeout) Stops the job with a savepoint.
default CompletableFuture<String>	RestfulGateway.triggerSavepoint(JobID jobId, String targetDirectory, boolean cancelJob, Time timeout) Triggers a savepoint with the given savepoint directory as a target.
static <T extends RestfulGateway> Optional<StaticFileServerHandler<T>>	WebMonitorUtils.tryLoadWebContent(GatewayRetriever<? extends T> leaderRetriever, Time timeout, File tmpDir) Checks whether the flink-runtime-web dependency is available and if so returns a StaticFileServerHandler which can serve the static file contents.

Constructors in org.apache.flink.runtime.webmonitor with parameters of type Time

Constructor and Description
WebSubmissionExtension(Configuration configuration, GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path jarDir, Executor executor, Time timeout)

Uses of Time in org.apache.flink.runtime.webmonitor.handlers

Constructors in org.apache.flink.runtime.webmonitor.handlers with parameters of type Time

Constructor and Description
JarDeleteHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JarDeleteMessageParameters> messageHeaders, Path jarDir, Executor executor)
JarListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarListInfo,EmptyMessageParameters> messageHeaders, CompletableFuture<String> localAddressFuture, File jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, java.util.function.Function<JobGraph,JobPlanInfo> planGenerator)
JarRunHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarRunRequestBody,JarRunResponseBody,JarRunMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor)
JarUploadHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarUploadResponseBody,EmptyMessageParameters> messageHeaders, Path jarDir, Executor executor)

Uses of Time in org.apache.flink.runtime.webmonitor.retriever

Methods in org.apache.flink.runtime.webmonitor.retriever with parameters of type Time

Modifier and Type	Method and Description
CompletableFuture<MetricDumpSerialization.MetricSerializationResult>	MetricQueryServiceGateway.queryMetrics(Time timeout)

Uses of Time in org.apache.flink.runtime.webmonitor.retriever.impl

Constructors in org.apache.flink.runtime.webmonitor.retriever.impl with parameters of type Time

Constructor and Description
RpcGatewayRetriever(RpcService rpcService, Class<T> gatewayType, java.util.function.Function<UUID,F> fencingTokenMapper, int retries, Time retryDelay)

Uses of Time in org.apache.flink.streaming.connectors.kafka

Fields in org.apache.flink.streaming.connectors.kafka declared as Time

Modifier and Type	Field and Description
static Time	FlinkKafkaProducer.DEFAULT_KAFKA_TRANSACTION_TIMEOUT Default value for kafka transaction timeout.
static Time	FlinkKafkaProducer011.DEFAULT_KAFKA_TRANSACTION_TIMEOUT Default value for kafka transaction timeout.

Uses of Time in org.apache.flink.table.api

Methods in org.apache.flink.table.api with parameters of type Time

Modifier and Type	Method and Description
void	TableConfig.setIdleStateRetentionTime(Time minTime, Time maxTime) Specifies a minimum and a maximum time interval for how long idle state, i.e., state which was not updated, will be retained.
StreamQueryConfig	StreamQueryConfig.withIdleStateRetentionTime(Time minTime, Time maxTime) Deprecated. Specifies a minimum and a maximum time interval for how long idle state, i.e., state which was not updated, will be retained.

Uses of Time in org.apache.flink.test.util

Fields in org.apache.flink.test.util declared as Time

Modifier and Type	Field and Description
static Time	TestBaseUtils.DEFAULT_HTTP_TIMEOUT

Methods in org.apache.flink.test.util with parameters of type Time

Modifier and Type	Method and Description
static String	TestBaseUtils.getFromHTTP(String url, Time timeout)
MiniClusterResourceConfiguration.Builder	MiniClusterResourceConfiguration.Builder.setShutdownTimeout(Time shutdownTimeout)