Package | Description |
---|---|
org.apache.flink.runtime.entrypoint |
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.
|
static <T> DeterminismEnvelope<T> |
DeterminismEnvelope.deterministicValue(T value) |
<V,E extends Exception> |
DeterminismEnvelope.map(FunctionWithException<? super T,? extends V,E> mapper) |
static <T> DeterminismEnvelope<T> |
DeterminismEnvelope.nondeterministicValue(T value) |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.