Uses of Class
org.apache.flink.runtime.entrypoint.WorkingDirectory

Packages that use WorkingDirectory

Package	Description
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.taskexecutor

Uses of WorkingDirectory in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint that return WorkingDirectory

Modifier and Type	Method and Description
static WorkingDirectory	WorkingDirectory.create(File workingDirectory)
static WorkingDirectory	WorkingDirectory.createIn(File parentDirectory, String directoryName)
WorkingDirectory	WorkingDirectory.createSubWorkingDirectory(String directoryName)

Methods in org.apache.flink.runtime.entrypoint that return types with arguments of type WorkingDirectory

Modifier and Type	Method and Description
static DeterminismEnvelope<WorkingDirectory>	ClusterEntrypointUtils.createJobManagerWorkingDirectory(Configuration configuration, DeterminismEnvelope<ResourceID> envelopedResourceId) Creates the working directory for the JobManager process.
static DeterminismEnvelope<WorkingDirectory>	ClusterEntrypointUtils.createTaskManagerWorkingDirectory(Configuration configuration, DeterminismEnvelope<ResourceID> envelopedResourceId) Creates the working directory for the TaskManager process.

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

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

Modifier and Type	Method and Description
TaskManagerRunner.TaskExecutorService	TaskManagerRunner.TaskExecutorServiceFactory.createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
static TaskManagerRunner.TaskExecutorService	TaskManagerRunner.createTaskExecutorService(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
static TaskManagerServicesConfiguration	TaskManagerServicesConfiguration.fromConfiguration(Configuration configuration, ResourceID resourceID, String externalAddress, boolean localCommunicationOnly, TaskExecutorResourceSpec taskExecutorResourceSpec, WorkingDirectory workingDirectory) Utility method to extract TaskManager config parameters from the configuration and to sanity check them.
static TaskManagerServices	TaskManagerServices.fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration, PermanentBlobService permanentBlobService, MetricGroup taskManagerMetricGroup, ExecutorService ioExecutor, FatalErrorHandler fatalErrorHandler, WorkingDirectory workingDirectory) Creates and returns the task manager services.
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)