类库 › streampark
apache

apache/streampark

StreamPark是一个开源流处理应用开发框架和云原生实时计算平台,旨在简化流应用的开发与管理。

4,183 1,037 4,183 275
在 GitHub 上查看

技术栈

根目录 java

查看全部依赖 (40)

依赖

ch.qos.logback:logback-classic com.beachape:enumeratum_${scala.binary.version} com.fasterxml.jackson.core:jackson-core com.fasterxml.jackson.core:jackson-databind com.fasterxml.jackson.module:jackson-module-scala_${scala.binary.version} com.github.ben-manes.caffeine:caffeine com.google.guava:guava com.puppycrawl.tools:checkstyle com.typesafe:config com.zaxxer:HikariCP commons-cli:commons-cli commons-net:commons-net mysql:mysql-connector-java org.apache.commons:commons-collections4 org.apache.commons:commons-lang3 org.apache.flink:force-shading org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.hbase:hbase-client org.apache.httpcomponents.client5:httpclient5 org.apache.httpcomponents.client5:httpclient5-fluent org.apache.streampark:streampark-common_${scala.binary.version} org.apache.zookeeper:zookeeper org.assertj:assertj-core org.json4s:json4s-jackson_${scala.binary.version} org.junit.jupiter:junit-jupiter-api org.junit.jupiter:junit-jupiter-engine org.junit.jupiter:junit-jupiter-params org.projectlombok:lombok org.scala-lang.modules:scala-xml_${scala.binary.version} org.scala-lang:scala-compiler org.scala-lang:scala-library org.scala-lang:scala-reflect org.slf4j:log4j-over-slf4j org.slf4j:slf4j-api org.testcontainers:mysql org.testcontainers:postgresql org.testcontainers:testcontainers org.yaml:snakeyaml redis.clients:jedis

streampark-common java

查看全部依赖 (17)

依赖

com.beachape:enumeratum_${scala.binary.version} com.typesafe:config com.zaxxer:HikariCP io.netty:netty-resolver org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.hbase:hbase-client org.apache.httpcomponents.client5:httpclient5 org.apache.streampark:streampark-shaded-jackson org.apache.streampark:streampark-shaded-slf4j org.junit.jupiter:junit-jupiter-engine org.junit.jupiter:junit-jupiter-params org.mockito:mockito-scala_${scala.binary.version} org.mongodb:mongo-java-driver org.scalatest:scalatest_${scala.binary.version} org.yaml:snakeyaml redis.clients:jedis

streampark-console/streampark-console-service java

框架

Spring Boot Web
查看全部依赖 (65)

依赖

ch.qos.logback:logback-classic com.auth0:java-jwt com.baomidou:mybatis-plus-boot-starter com.fasterxml.jackson.module:jackson-module-scala_${scala.binary.version} com.github.ben-manes.caffeine:caffeine com.github.mwiede:jsch com.google.guava:guava com.h2database:h2 io.buji:buji-pac4j javax.mail:mail mysql:mysql-connector-java org.apache.commons:commons-compress org.apache.commons:commons-email org.apache.commons:commons-lang3 org.apache.flink:flink-kubernetes org.apache.flink:flink-table-api-java org.apache.flink:flink-table-common org.apache.flink:force-shading org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.shiro:shiro-spring org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-client-api_${scala.binary.version} org.apache.streampark:streampark-flink-client-core_${scala.binary.version} org.apache.streampark:streampark-flink-kubernetes_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.12_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.13_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.14_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.15_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.16_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.17_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.18_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.19_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.20_${scala.binary.version} org.apache.streampark:streampark-flink-sqlclient_${scala.binary.version} org.apache.streampark:streampark-spark-client-api_${scala.binary.version} org.apache.streampark:streampark-spark-client-core_${scala.binary.version} org.apache.streampark:streampark-spark-sqlclient_${scala.binary.version} org.apache.tika:tika-core org.assertj:assertj-core org.eclipse.jgit:org.eclipse.jgit.ssh.jsch org.freemarker:freemarker org.junit.jupiter:junit-jupiter-api org.junit.jupiter:junit-jupiter-engine org.pac4j:pac4j-springboot org.postgresql:postgresql org.projectlombok:lombok org.scala-lang.modules:scala-xml_${scala.binary.version} org.scala-lang:scala-compiler org.scala-lang:scala-library org.scala-lang:scala-reflect org.slf4j:log4j-over-slf4j org.slf4j:slf4j-api org.springframework.boot:spring-boot-dependencies org.springframework.boot:spring-boot-starter-aop org.springframework.boot:spring-boot-starter-quartz org.springframework.boot:spring-boot-starter-test org.springframework.boot:spring-boot-starter-undertow org.springframework.boot:spring-boot-starter-websocket org.springframework.ldap:spring-ldap-core org.testcontainers:mysql org.yaml:snakeyaml p6spy:p6spy xml-apis:xml-apis

streampark-console/streampark-console-webapp javascript

框架

Vue Router ^4.2.4 Vue.js ^3.5.0

状态管理

Pinia 2.1.4

构建工具

Vite ^4.4.9

网络

Axios ^1.4.0

CSS 预处理器

Less ^4.1.3

代码规范

ESLint ^8.44.0 Prettier ^3.0.0 Stylelint ^15.10.1
查看全部依赖 (69)

依赖

@ant-design/colors ^7.0.0 @ant-design/icons-vue ^6.1.0 @iconify/iconify ^3.1.1 @vue/runtime-core ^3.5.0 @vue/shared ^3.5.0 @vueuse/core ^10.2.1 @vueuse/shared ^10.2.1 ant-design-vue ^3.2.20 crypto-js ^4.1.1 dayjs ^1.11.9 lodash-es ^4.17.21 monaco-editor ^0.40.0 nprogress ^0.2.0 path-to-regexp ^6.2.1 qs ^6.11.2 resize-observer-polyfill ^1.5.1 sortablejs ^1.15.0 sql-formatter ^4.0.2 sweetalert2 ^11.7.16 terser ^5.19.0 vue-i18n ^9.2.2 vue-types ^5.1.0

开发依赖

@iconify/json ^2.2.89 @purge-icons/generated ^0.9.0 @types/fs-extra ^11.0.1 @types/lodash-es ^4.17.7 @types/node ^20.4.1 @types/nprogress ^0.2.0 @types/qs ^6.9.7 @types/showdown ^2.0.1 @types/sortablejs ^1.15.1 @typescript-eslint/eslint-plugin ^6.0.0 @typescript-eslint/parser ^6.0.0 @vitejs/plugin-legacy ^4.1.0 @vitejs/plugin-vue ^4.2.3 @vitejs/plugin-vue-jsx ^3.0.1 @vue/compiler-sfc ^3.5.0 autoprefixer ^10.4.14 cross-env ^7.0.3 dotenv ^16.3.1 eslint-config-prettier ^8.8.0 eslint-plugin-prettier ^5.0.0 eslint-plugin-vue ^9.15.1 esno ^0.17.0 fs-extra ^11.1.1 js-yaml ^4.1.0 lint-staged 13.2.3 picocolors ^1.0.0 postcss ^8.4.25 postcss-html ^1.5.0 postcss-less ^6.0.0 rimraf ^5.0.1 rollup-plugin-visualizer ^5.9.2 stylelint-config-recommended ^13.0.0 stylelint-config-recommended-vue ^1.5.0 stylelint-config-standard ^34.0.0 stylelint-order ^6.0.3 ts-node ^10.9.1 typescript ^5.1.6 vite-plugin-compression ^0.5.1 vite-plugin-html-transform ^1.0.0 vite-plugin-imagemin ^0.6.1 vite-plugin-purge-icons ^0.9.2 vite-plugin-style-import ^2.0.0 vite-plugin-svg-icons ^2.0.1 vite-plugin-theme ^0.8.6 vite-plugin-windicss ^1.9.1 vue-eslint-parser ^9.3.1 vue-tsc ^1.8.4

streampark-e2e java

查看全部依赖 (13)

依赖

com.google.guava:guava org.apache.logging.log4j:log4j-slf4j-impl org.assertj:assertj-core org.junit.jupiter:junit-jupiter org.junit:junit-bom org.projectlombok:lombok org.seleniumhq.selenium:selenium-chrome-driver org.seleniumhq.selenium:selenium-support org.slf4j:slf4j-api org.testcontainers:junit-jupiter org.testcontainers:selenium org.testcontainers:testcontainers org.testcontainers:testcontainers-bom

streampark-e2e/streampark-e2e-case java

查看全部依赖 (1)

依赖

org.apache.streampark:streampark-e2e-core

streampark-flink java

查看全部依赖 (5)

依赖

org.apache.flink:flink-table-api-java-uber org.assertj:assertj-core org.junit.jupiter:junit-jupiter-engine org.junit.jupiter:junit-jupiter-params org.scalatest:scalatest_${scala.binary.version}

streampark-flink/streampark-flink-client/streampark-flink-client-api java

查看全部依赖 (7)

依赖

org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-kubernetes_${scala.binary.version} org.apache.streampark:streampark-flink-packer_${scala.binary.version} org.apache.streampark:streampark-flink-proxy_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-client/streampark-flink-client-core java

查看全部依赖 (9)

依赖

com.google.guava:guava org.apache.flink:flink-python org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-client-api_${scala.binary.version} org.apache.streampark:streampark-flink-kubernetes_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.json4s:json4s-jackson_${scala.binary.version}

streampark-flink/streampark-flink-connector java

查看全部依赖 (2)

依赖

org.apache.httpcomponents:httpclient org.asynchttpclient:async-http-client

streampark-flink/streampark-flink-connector/streampark-flink-connector-base java

查看全部依赖 (10)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.kafka:kafka-clients org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-core_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse java

查看全部依赖 (9)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.asynchttpclient:async-http-client ru.yandex.clickhouse:clickhouse-jdbc

streampark-flink/streampark-flink-connector/streampark-flink-connector-doris java

查看全部依赖 (8)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.httpcomponents:httpclient org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch java

查看全部依赖 (2)

依赖

org.apache.httpcomponents:httpclient org.apache.streampark:streampark-flink-connector-base_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5 java

查看全部依赖 (7)

依赖

org.apache.flink:flink-connector-elasticsearch5_${scala.binary.version} org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6 java

查看全部依赖 (7)

依赖

org.apache.flink:flink-connector-elasticsearch6 org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7 java

查看全部依赖 (7)

依赖

org.apache.flink:flink-connector-elasticsearch7 org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase java

查看全部依赖 (10)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.hbase:hbase-client org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-http java

查看全部依赖 (9)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.httpcomponents:httpclient org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.asynchttpclient:async-http-client

streampark-flink/streampark-flink-connector/streampark-flink-connector-influx java

查看全部依赖 (8)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.influxdb:influxdb-java

streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc java

查看全部依赖 (7)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka java

查看全部依赖 (8)

依赖

org.apache.flink:flink-connector-kafka org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo java

查看全部依赖 (8)

依赖

org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.mongodb:mongo-java-driver

streampark-flink/streampark-flink-connector/streampark-flink-connector-redis java

查看全部依赖 (9)

依赖

org.apache.bahir:flink-connector-redis_${scala.binary.version} org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-java${scala.binary.flink.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-connector-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-core java

查看全部依赖 (11)

依赖

org.apache.flink:flink-connector-jdbc org.apache.flink:flink-core org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-common org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-kubernetes java

查看全部依赖 (13)

依赖

com.github.ben-manes.caffeine:caffeine com.google.guava:guava org.apache.flink:flink-clients org.apache.flink:flink-kubernetes org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.httpcomponents.client5:httpclient5 org.apache.httpcomponents.client5:httpclient5-fluent org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version} org.json4s:json4s-jackson_${scala.binary.version} org.projectlombok:lombok org.yaml:snakeyaml

streampark-flink/streampark-flink-packer java

查看全部依赖 (12)

依赖

com.fasterxml.jackson.core:jackson-annotations com.github.docker-java:docker-java-core com.github.docker-java:docker-java-transport-httpclient5 com.google.guava:guava org.apache.maven.plugins:maven-shade-plugin org.apache.maven:maven-aether-provider org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-kubernetes_${scala.binary.version} org.eclipse.aether:aether-connector-basic org.eclipse.aether:aether-impl org.eclipse.aether:aether-transport-file org.eclipse.aether:aether-transport-http

streampark-flink/streampark-flink-proxy java

查看全部依赖 (1)

依赖

org.apache.streampark:streampark-common_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims-base java

查看全部依赖 (11)

依赖

org.apache.flink:flink-clients org.apache.flink:flink-core org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-common_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims-test java

查看全部依赖 (11)

依赖

org.apache.flink:flink-clients org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.streampark:streampark-flink-core_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-1.14_${scala.binary.version} org.scalatest:scalatest_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12 java

查看全部依赖 (8)

依赖

org.apache.flink:flink-kubernetes_${scala.binary.version} org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-uber-blink_${scala.binary.version} org.apache.flink:flink-yarn_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13 java

查看全部依赖 (8)

依赖

org.apache.flink:flink-kubernetes_${scala.binary.version} org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-uber-blink_${scala.binary.version} org.apache.flink:flink-yarn_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14 java

查看全部依赖 (8)

依赖

org.apache.flink:flink-kubernetes_${scala.binary.version} org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-uber_${scala.binary.version} org.apache.flink:flink-yarn_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15 java

查看全部依赖 (10)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16 java

查看全部依赖 (12)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17 java

查看全部依赖 (12)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18 java

查看全部依赖 (12)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19 java

查看全部依赖 (12)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.20 java

查看全部依赖 (12)

依赖

org.apache.flink:flink-kubernetes org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-statebackend-rocksdb org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-java-uber org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.flink:flink-table-planner_${scala.binary.version} org.apache.flink:flink-yarn org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-shims-base_${scala.binary.version}

streampark-flink/streampark-flink-sqlclient java

查看全部依赖 (8)

依赖

com.beachape:enumeratum_${scala.binary.version} org.apache.flink:flink-scala_${scala.binary.version} org.apache.flink:flink-streaming-scala_${scala.binary.version} org.apache.flink:flink-table-api-scala-bridge_${scala.binary.version} org.apache.flink:flink-table-api-scala_${scala.binary.version} org.apache.streampark:streampark-flink-core_${scala.binary.version} org.apache.streampark:streampark-flink-shims-base_${scala.binary.version} org.apache.streampark:streampark-flink-shims_flink-${streampark.flink.shims.version}_${scala.binary.version}

streampark-flink/streampark-flink-udf java

查看全部依赖 (2)

依赖

org.apache.flink:flink-table-common org.apache.streampark:streampark-common_${scala.binary.version}

streampark-shaded java

查看全部依赖 (5)

依赖

ch.qos.logback:logback-classic com.fasterxml.jackson.core:jackson-core com.fasterxml.jackson.core:jackson-databind org.slf4j:log4j-over-slf4j org.slf4j:slf4j-api

streampark-shaded/streampark-shaded-jackson java

查看全部依赖 (2)

依赖

com.fasterxml.jackson.core:jackson-core com.fasterxml.jackson.core:jackson-databind

streampark-shaded/streampark-shaded-slf4j java

查看全部依赖 (3)

依赖

ch.qos.logback:logback-classic org.slf4j:log4j-over-slf4j org.slf4j:slf4j-api

streampark-spark java

查看全部依赖 (10)

依赖

com.esotericsoftware:kryo-shaded org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.hbase:hbase-hadoop2-compat org.apache.spark:spark-sql_2.12 org.apache.spark:spark-streaming-kafka-0-10_2.12 org.apache.spark:spark-streaming_2.12 org.apache.streampark:streampark-common_2.12 org.json4s:json4s-ast_2.12 org.json4s:json4s-core_2.12

streampark-spark/streampark-spark-client/streampark-spark-client-api java

查看全部依赖 (4)

依赖

org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-common_${scala.binary.version} org.apache.streampark:streampark-flink-packer_${scala.binary.version}

streampark-spark/streampark-spark-client/streampark-spark-client-core java

查看全部依赖 (6)

依赖

com.google.guava:guava org.apache.hadoop:hadoop-client-api org.apache.hadoop:hadoop-client-runtime org.apache.streampark:streampark-flink-packer_${scala.binary.version} org.apache.streampark:streampark-spark-client-api_${scala.binary.version} org.json4s:json4s-jackson_${scala.binary.version}

streampark-spark/streampark-spark-connector/streampark-spark-connector-base java

查看全部依赖 (1)

依赖

org.apache.streampark:streampark-spark-core_2.12

streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka java

查看全部依赖 (7)

依赖

org.apache.hbase:hbase-client org.apache.hbase:hbase-common org.apache.hbase:hbase-server org.apache.kafka:kafka_2.12 org.apache.streampark:streampark-spark-connector-base_2.12 org.scalikejdbc:scalikejdbc_2.12 redis.clients:jedis

streampark-spark/streampark-spark-sqlclient java

查看全部依赖 (2)

依赖

com.beachape:enumeratum_${scala.binary.version} org.apache.streampark:streampark-spark-core_${scala.binary.version}

评论

Home - Wiki
Copyright © 2011-2026 iteam. Current version is 2.155.2. UTC+08:00, 2026-05-01 19:41
浙ICP备14020137号-1 $Map of visitor$