Modifier and Type | Method and Description |
---|---|
FlinkPod |
FlinkPod.Builder.build() |
FlinkPod |
FlinkPod.copy() |
Constructor and Description |
---|
Builder(FlinkPod flinkPod) |
Modifier and Type | Method and Description |
---|---|
FlinkPod |
CmdJobManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
InitJobManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
KerberosMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
HadoopConfMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
AbstractKubernetesStepDecorator.decorateFlinkPod(FlinkPod flinkPod)
Apply transformations on the given FlinkPod in accordance to this feature.
|
FlinkPod |
FlinkConfMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
KubernetesStepDecorator.decorateFlinkPod(FlinkPod flinkPod)
Apply transformations to the given FlinkPod in accordance with this feature.
|
FlinkPod |
MountSecretsDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
PodTemplateMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
InitTaskManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
EnvSecretsDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
CmdTaskManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
Modifier and Type | Method and Description |
---|---|
FlinkPod |
CmdJobManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
InitJobManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
KerberosMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
HadoopConfMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
AbstractKubernetesStepDecorator.decorateFlinkPod(FlinkPod flinkPod)
Apply transformations on the given FlinkPod in accordance to this feature.
|
FlinkPod |
FlinkConfMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
KubernetesStepDecorator.decorateFlinkPod(FlinkPod flinkPod)
Apply transformations to the given FlinkPod in accordance with this feature.
|
FlinkPod |
MountSecretsDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
PodTemplateMountDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
InitTaskManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
EnvSecretsDecorator.decorateFlinkPod(FlinkPod flinkPod) |
FlinkPod |
CmdTaskManagerDecorator.decorateFlinkPod(FlinkPod flinkPod) |
Modifier and Type | Method and Description |
---|---|
static KubernetesJobManagerSpecification |
KubernetesJobManagerFactory.buildKubernetesJobManagerSpecification(FlinkPod podTemplate,
KubernetesJobManagerParameters kubernetesJobManagerParameters) |
static KubernetesPod |
KubernetesTaskManagerFactory.buildTaskManagerKubernetesPod(FlinkPod podTemplate,
KubernetesTaskManagerParameters kubernetesTaskManagerParameters) |
Modifier and Type | Method and Description |
---|---|
static FlinkPod |
KubernetesUtils.loadPodFromTemplateFile(FlinkKubeClient kubeClient,
File podTemplateFile,
String mainContainerName) |
Modifier and Type | Method and Description |
---|---|
static String |
KubernetesUtils.getServiceAccount(FlinkPod flinkPod)
Get the service account from the input pod first, if not specified, the service account name
will be used.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.