T
- Type of the derived statistics to return.public class JobVertexThreadInfoTrackerBuilder<T extends Statistics> extends Object
JobVertexThreadInfoTracker
.public JobVertexThreadInfoTrackerBuilder<T> setCoordinator(ThreadInfoRequestCoordinator coordinator)
cleanUpInterval
.coordinator
- Coordinator for thread info stats request.public JobVertexThreadInfoTrackerBuilder<T> setCleanUpInterval(java.time.Duration cleanUpInterval)
cleanUpInterval
.cleanUpInterval
- Clean up interval for completed stats.public JobVertexThreadInfoTrackerBuilder<T> setNumSamples(int numSamples)
numSamples
.numSamples
- Number of thread info samples to collect for each subtask.public JobVertexThreadInfoTrackerBuilder<T> setStatsRefreshInterval(java.time.Duration statsRefreshInterval)
statsRefreshInterval
.statsRefreshInterval
- Time interval after which the available thread info stats are
deprecated and need to be refreshed.public JobVertexThreadInfoTrackerBuilder<T> setDelayBetweenSamples(java.time.Duration delayBetweenSamples)
delayBetweenSamples
.delayBetweenSamples
- Delay between individual samples per task.public JobVertexThreadInfoTrackerBuilder<T> setMaxThreadInfoDepth(int maxThreadInfoDepth)
delayBetweenSamples
.maxThreadInfoDepth
- Limit for the depth of the stack traces included when sampling
threads.public JobVertexThreadInfoTracker<T> build()
JobVertexThreadInfoTracker
.JobVertexThreadInfoTracker
instance.public static <T extends Statistics> JobVertexThreadInfoTrackerBuilder<T> newBuilder(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, java.util.function.Function<VertexThreadInfoStats,T> createStatsFn, ScheduledExecutorService executor, Time restTimeout)
JobVertexThreadInfoTrackerBuilder
.T
- Type of the derived statistics to return.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.