Uses of Interface
org.apache.flink.runtime.blob.TaskExecutorBlobService
-
Packages that use TaskExecutorBlobService Package Description org.apache.flink.runtime.blob org.apache.flink.runtime.taskexecutor -
-
Uses of TaskExecutorBlobService in org.apache.flink.runtime.blob
Classes in org.apache.flink.runtime.blob that implement TaskExecutorBlobService Modifier and Type Class Description class
BlobCacheService
The BLOB cache provides access to BLOB services for permanent and transient BLOBs. -
Uses of TaskExecutorBlobService in org.apache.flink.runtime.taskexecutor
Methods in org.apache.flink.runtime.taskexecutor with parameters of type TaskExecutorBlobService Modifier and Type Method Description static TaskExecutor
TaskManagerRunner. startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, TaskExecutorBlobService taskExecutorBlobService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler, DelegationTokenReceiverRepository delegationTokenReceiverRepository)
Constructors in org.apache.flink.runtime.taskexecutor with parameters of type TaskExecutorBlobService Constructor Description TaskExecutor(RpcService rpcService, TaskManagerConfiguration taskManagerConfiguration, HighAvailabilityServices haServices, TaskManagerServices taskExecutorServices, ExternalResourceInfoProvider externalResourceInfoProvider, HeartbeatServices heartbeatServices, TaskManagerMetricGroup taskManagerMetricGroup, String metricQueryServiceAddress, TaskExecutorBlobService taskExecutorBlobService, FatalErrorHandler fatalErrorHandler, TaskExecutorPartitionTracker partitionTracker, DelegationTokenReceiverRepository delegationTokenReceiverRepository)
-