Interface | Description |
---|---|
KubernetesStepDecorator |
A set of functions that together represent a feature in pods that are deployed for the
JobManager(s) or the TaskManager(s), which provides an extension to the way the given Flink
application works.
|
Class | Description |
---|---|
AbstractKubernetesStepDecorator |
An abstract
KubernetesStepDecorator contains common implementations for different plug-in
features. |
EnvSecretsDecorator |
Support setting environment variables via Secrets.
|
ExternalServiceDecorator |
Creates an external Service to expose the rest port of the Flink JobManager(s).
|
FlinkConfMountDecorator |
Mounts the log4j.properties, logback.xml, and flink-conf.yaml configuration on the JobManager or
TaskManager pod.
|
HadoopConfMountDecorator |
Mount the custom Hadoop Configuration to the JobManager(s)/TaskManagers.
|
InitJobManagerDecorator |
An initializer for the JobManager
FlinkPod . |
InitTaskManagerDecorator |
An initializer for the TaskManager
FlinkPod . |
InternalServiceDecorator |
Creates an internal Service which forwards the requests from the TaskManager(s) to the active
JobManager.
|
JavaCmdJobManagerDecorator |
Attach the jvm command and args to the main container for running the JobManager code.
|
JavaCmdTaskManagerDecorator |
Attach the jvm command and args to the main container for running the TaskManager code.
|
KerberosMountDecorator |
Mount the custom Kerberos Configuration and Credential to the JobManager(s)/TaskManagers.
|
MountSecretsDecorator |
Support mounting Secrets on the JobManager or TaskManager pod..
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.