flink-deployer
所属分类：微服务
开发工具：Java
文件大小：33KB
下载次数：0
上传日期：2023-06-13 08:36:03
上 传 者：
sh-1993
说明： flink部署器,支持flink on yarn k8s,基于Flink自带ClusterDescriptor的不同实现进行通用封装
(Flink deployer, which supports Flink on yarn k8s, is generally encapsulated based on different implementations of Flink s own ClusterDescriptor)
文件列表:
infrastructure (0, 2023-06-13)
infrastructure\pom.xml (2906, 2023-06-13)
infrastructure\src (0, 2023-06-13)
infrastructure\src\main (0, 2023-06-13)
infrastructure\src\main\java (0, 2023-06-13)
infrastructure\src\main\java\com (0, 2023-06-13)
infrastructure\src\main\java\com\flink (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\CheckpointConfig.java (2210, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\CoreConfig.java (2163, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\DeploymentConfig.java (1591, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\FlinkConfig.java (621, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\JobManagerConfig.java (3577, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\PipelineConfig.java (2300, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\RuntimeConfig.java (873, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\TaskManagerConfig.java (6116, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\kubernetes (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\kubernetes\KubernetesConfig.java (12332, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\yarn (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\config\yarn\YarnConfig.java (1440, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\constants (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\constants\DeployerTypeEnums.java (418, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\constants\KubernetesUseCaseEnums.java (502, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\constants\TargetTypeEnums.java (621, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\deployer (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\deployer\ClusterDeployer.java (540, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\deployer\ClusterDeployerFactory.java (3054, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\deployer\KubernetesClusterDeployer.java (1775, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\deployer\YarnClusterDeployer.java (2320, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\exception (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\exception\BaseException.java (564, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\exception\ConfigurationException.java (430, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\exception\ExceptionEnums.java (506, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\utils (0, 2023-06-13)
infrastructure\src\main\java\com\flink\plugins\inf\utils\ConfigValidateUtils.java (2932, 2023-06-13)
... ...
近期下载者：
相关文件：
收藏者：