From 68e51485d74a261cec0b58857d0bbb6ed2117b22 Mon Sep 17 00:00:00 2001
From: jiangw <39796328+b6688c@users.noreply.github.com>
Date: Sun, 22 Oct 2023 00:28:11 +0800
Subject: [PATCH] =?UTF-8?q?feat=201.=E5=8D=87=E7=BA=A7springboot=E8=87=B33?=
=?UTF-8?q?.1.5=E7=89=88=E6=9C=AC=EF=BC=8C=E5=90=8C=E6=AD=A5=E5=8D=87?=
=?UTF-8?q?=E7=BA=A7=E7=9B=B8=E5=85=B3=E7=9A=84=E5=8C=85=EF=BC=8Cmybatis-p?=
=?UTF-8?q?lus=E3=80=81elasticsearch=E4=BB=A5=E5=8F=8A=E7=9B=B8=E5=85=B3?=
=?UTF-8?q?=E7=9A=84=E4=BE=9D=E8=B5=96=E7=9A=84=E5=8C=85=EF=BC=8C=E5=8D=87?=
=?UTF-8?q?=E7=BA=A7jdk=E4=B8=BA21.=202.=E7=A7=BB=E9=99=A4flink=E6=A8=A1?=
=?UTF-8?q?=E5=9D=97=EF=BC=8C=E7=A7=BB=E9=99=A4cache=203.=E4=BC=98?=
=?UTF-8?q?=E5=8C=96=E5=8D=87=E7=BA=A7=E5=90=8E=E7=9A=84=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 44 +--
uno-auto/pom.xml | 2 +-
uno-bom/pom.xml | 107 +----
uno-components/pom.xml | 3 +-
uno-components/uno-component-flink/pom.xml | 45 ---
.../cc/allio/uno/component/flink/Input.java | 19 -
.../cc/allio/uno/component/flink/Output.java | 19 -
.../component/flink/UnoFlinkProperties.java | 78 ----
.../flink/concurrent/JobRichContext.java | 127 ------
.../BaseCountDownRichMapFunction.java | 49 ---
.../BaseCountDownRichSinkFunction.java | 49 ---
.../BaseCountDownRichSourceFunction.java | 50 ---
.../flink/function/CountDownFunction.java | 21 -
.../datasource/FluxSinkQueueDataSource.java | 106 -----
.../sink/FluxSinkRichSinkFunction.java | 55 ---
.../flink/task/AbstractFlinkTask.java | 121 ------
.../flink/task/AccumulatedCountTask.java | 56 ---
.../flink/task/AccumulatedEventTimeTask.java | 107 -----
.../uno/component/flink/task/Builder.java | 18 -
.../CompositionAccumulateEventTimeTask.java | 61 ---
.../component/flink/task/FlinkEnvBuilder.java | 103 -----
.../flink/task/FlinkTaskBuilder.java | 371 ------------------
.../flink/task/OrdinaryFlinkTask.java | 24 --
.../task/FlinkAccumulatedCountTaskTest.java | 67 ----
.../FlinkAccumulatedEventTimeTaskTest.java | 57 ---
.../src/test/resources/log4j2.xml | 14 -
uno-components/uno-component-http/pom.xml | 2 +-
.../http/metadata/ClientResponseWrapper.java | 8 +-
.../http/metadata/HttpResponseMetadata.java | 6 +-
.../interceptor/TokenInterceptor.java | 7 +-
uno-components/uno-component-kafka/pom.xml | 2 +-
uno-components/uno-component-netty/pom.xml | 2 +-
.../cc/allio/uno/component/netty/Invoker.java | 2 +-
.../uno-component-sequential/pom.xml | 2 +-
.../sequential/washer/WashMachine.java | 4 +-
.../uno-component-websocket/pom.xml | 2 +-
.../websocket/BaseWebsocketEndpoint.java | 2 +-
.../websocket/ConnectionAuthenticator.java | 3 +-
.../websocket/ConnectionContext.java | 3 +-
.../websocket/EndpointAuthenticator.java | 9 +-
.../MessagePublishAuthenticator.java | 3 +-
.../MessageReceiveAuthenticator.java | 3 +-
.../UnicastMessageAuthenticator.java | 2 +-
.../websocket/UnicastWebSocketEndpoint.java | 3 +-
.../websocket/WebSocketEndpoint.java | 6 +-
uno-core/pom.xml | 27 +-
.../uno/core/annotation/AnnotatedField.java | 2 +-
.../allio/uno/core/aop/JoinPointDelegate.java | 9 +-
.../java/cc/allio/uno/core/cache/Cache.java | 1 -
.../cc/allio/uno/core/cache/RedisCache.java | 203 ----------
.../ConfigurationPropertiesRefresh.java | 109 -----
.../uno/core/config/SpringValueRefresh.java | 129 ------
.../allio/uno/core/config/ValueRefresh.java | 29 --
.../core/proxy/ByteBuddyProxyInvocation.java | 2 +-
.../ComposableInvocationInterceptor.java | 2 +-
.../uno/core/task/CacheableCalculateTask.java | 105 -----
.../cc/allio/uno/core/util/ClassUtils.java | 33 --
.../uno/core/util/calculate/Calculator.java | 36 --
uno-data/pom.xml | 4 +-
.../elasticsearch/EsSQLCommandExecutor.java | 3 +-
.../uno/data/orm/jpa/model/BaseEntity.java | 2 +-
.../orm/jpa/repository/JpaRepositoryImpl.java | 3 +-
.../orm/repository/ApplicationRepository.java | 23 --
.../data/orm/repository/LocalRepository.java | 111 ------
.../repository/ReactiveLocalRepository.java | 148 -------
.../allio/uno/data/orm/sql/FromStatement.java | 5 +-
.../allio/uno/data/orm/sql/PojoWrapper.java | 6 +-
.../allio/uno/data/orm/sql/SQLColumnDef.java | 4 +-
.../orm/sql/dml/druid/DruidSelectFrom.java | 2 +-
.../uno/data/query/mybatis/HigherQuery.java | 2 -
.../UnoDataMybatisAutoConfiguration.java | 17 -
.../data/query/mybatis/UnoSqlInjector.java | 35 --
.../query/mybatis/injector/QueryList.java | 82 ----
.../mybatis/injector/QuerySqlInjector.java | 31 --
.../mybatis/injector/QuerySqlScriptUtil.java | 46 ---
.../allio/uno/data/query/stream/Sampling.java | 2 +-
uno-demo/pom.xml | 2 +-
uno-demo/uno-liquibase-demo/pom.xml | 2 +-
uno-demo/uno-websocket-demo/pom.xml | 2 +-
.../websocket/demo/DemoWebSocketEndpoint.java | 4 +-
uno-gis/pom.xml | 2 +-
uno-plugins/pom.xml | 2 +-
uno-plugins/uno-plugins-manager/pom.xml | 2 +-
uno-plugins/uno-plugins-platform/pom.xml | 2 +-
uno-rule/pom.xml | 6 +-
uno-starters/pom.xml | 3 +-
uno-starters/uno-starter-core/pom.xml | 2 +-
uno-starters/uno-starter-flink/pom.xml | 20 -
.../flink/UnoFlinkAutoConfiguration.java | 28 --
uno-starters/uno-starter-kafka/pom.xml | 2 +-
uno-starters/uno-starter-liquibase/README.md | 2 +-
uno-starters/uno-starter-liquibase/pom.xml | 2 +-
uno-starters/uno-starter-redis/pom.xml | 2 +-
uno-starters/uno-starter-sequential/pom.xml | 2 +-
uno-starters/uno-starter-websocket/pom.xml | 2 +-
uno-test/pom.xml | 38 +-
.../cc/allio/uno/test/BaseSpringTest.java | 29 +-
.../main/java/cc/allio/uno/test/RunTest.java | 2 -
.../java/cc/allio/uno/test/TestManager.java | 3 -
.../java/cc/allio/uno/test/WebListener.java | 3 +-
.../uno/test/env/DataSourceEnvironment.java | 2 +-
.../allio/uno/test/env/EasyEsEnvironment.java | 31 --
.../allio/uno/test/env/FeignEnvironment.java | 47 ---
.../uno/test/env/MybatisEnvironment.java | 2 +-
.../uno/test/env/MybatisPlusEnvironment.java | 2 +-
.../test/env/ReactiveFeignEnvironment.java | 33 --
.../test/env/annotation/FeignConfigure.java | 28 --
.../uno/test/env/annotation/FeignEnv.java | 84 ----
.../properties/DataSourceProperties.java | 7 -
.../annotation/properties/EsProperties.java | 3 -
.../properties/FeignHttpClientProperties.java | 62 ---
.../cc/allio/uno/test/feign/FeignRunner.java | 224 -----------
.../feign/ReactiveFeignClientFactoryBean.java | 287 --------------
.../ReactiveFeignClientSpecification.java | 78 ----
.../feign/ReactiveFeignClientsRegistrar.java | 237 -----------
.../test/feign/ReactiveFeignConfigurator.java | 29 --
.../cc/allio/uno/test/feign/RunFeignTest.java | 59 ---
.../allio/uno/test/runner/InjectRunner.java | 2 +-
uno-web/pom.xml | 4 +-
119 files changed, 134 insertions(+), 4308 deletions(-)
delete mode 100644 uno-components/uno-component-flink/pom.xml
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Input.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Output.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/UnoFlinkProperties.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/concurrent/JobRichContext.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/BaseCountDownRichMapFunction.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/BaseCountDownRichSinkFunction.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/BaseCountDownRichSourceFunction.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/CountDownFunction.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/datasource/FluxSinkQueueDataSource.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/function/sink/FluxSinkRichSinkFunction.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/AbstractFlinkTask.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/AccumulatedCountTask.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/AccumulatedEventTimeTask.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/Builder.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/CompositionAccumulateEventTimeTask.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/FlinkEnvBuilder.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/FlinkTaskBuilder.java
delete mode 100644 uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/task/OrdinaryFlinkTask.java
delete mode 100644 uno-components/uno-component-flink/src/test/java/cc/allio/uno/component/flink/task/FlinkAccumulatedCountTaskTest.java
delete mode 100644 uno-components/uno-component-flink/src/test/java/cc/allio/uno/component/flink/task/FlinkAccumulatedEventTimeTaskTest.java
delete mode 100644 uno-components/uno-component-flink/src/test/resources/log4j2.xml
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/cache/RedisCache.java
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/config/ConfigurationPropertiesRefresh.java
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/config/SpringValueRefresh.java
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/config/ValueRefresh.java
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/task/CacheableCalculateTask.java
delete mode 100644 uno-core/src/main/java/cc/allio/uno/core/util/calculate/Calculator.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/orm/repository/ApplicationRepository.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/orm/repository/LocalRepository.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/orm/repository/ReactiveLocalRepository.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/query/mybatis/UnoSqlInjector.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/query/mybatis/injector/QueryList.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/query/mybatis/injector/QuerySqlInjector.java
delete mode 100644 uno-data/src/main/java/cc/allio/uno/data/query/mybatis/injector/QuerySqlScriptUtil.java
delete mode 100644 uno-starters/uno-starter-flink/pom.xml
delete mode 100644 uno-starters/uno-starter-flink/src/main/java/cc/allio/uno/starter/flink/UnoFlinkAutoConfiguration.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/EasyEsEnvironment.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/FeignEnvironment.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/ReactiveFeignEnvironment.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/annotation/FeignConfigure.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/annotation/FeignEnv.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/env/annotation/properties/FeignHttpClientProperties.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/FeignRunner.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/ReactiveFeignClientFactoryBean.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/ReactiveFeignClientSpecification.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/ReactiveFeignClientsRegistrar.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/ReactiveFeignConfigurator.java
delete mode 100644 uno-test/src/main/java/cc/allio/uno/test/feign/RunFeignTest.java
diff --git a/pom.xml b/pom.xml
index 70d5e691..7d1dff02 100644
--- a/pom.xml
+++ b/pom.xml
@@ -7,16 +7,15 @@
cc.allio
uno
pom
- 1.1.4.RELEASE
+ 1.1.5.RELEASE
构建大型应用需要的基本能力 --- all in one
-
+ https://github.com/b6688c/uno
- jiangwei
+ j.x
jiangw1027@gmail.com
-
uno-bom
uno-core
@@ -33,10 +32,9 @@
- 1.8
+ 21
2020.0.12
- 2.3.12.RELEASE
- Cairo-SR8
+ 3.1.5
3.2.1
3.8.1
3.1.0
@@ -46,10 +44,6 @@
-
- org.springframework.boot
- spring-boot-starter-aop
-
org.projectlombok
lombok
@@ -63,6 +57,13 @@
+
+ org.springframework.boot
+ spring-boot-dependencies
+ ${spring.boot.version}
+ pom
+ import
+
org.testcontainers
testcontainers-bom
@@ -84,27 +85,6 @@
pom
import
-
- org.springframework.boot
- spring-boot-dependencies
- ${spring.boot.version}
- pom
- import
-
-
- io.spring.platform
- platform-bom
- ${spring.platform.version}
- pom
- import
-
-
- org.springframework.cloud
- spring-cloud-dependencies
- ${spring.cloud.version}
- pom
- import
-
org.drools
drools-bom
diff --git a/uno-auto/pom.xml b/uno-auto/pom.xml
index 644c1e3a..c0c40516 100644
--- a/uno-auto/pom.xml
+++ b/uno-auto/pom.xml
@@ -5,7 +5,7 @@
uno
cc.allio
- 1.1.4.RELEASE
+ 1.1.5.RELEASE
4.0.0
diff --git a/uno-bom/pom.xml b/uno-bom/pom.xml
index a234a08a..77e51d0e 100644
--- a/uno-bom/pom.xml
+++ b/uno-bom/pom.xml
@@ -12,12 +12,12 @@
4.0.0
cc.allio
uno-bom
- 1.1.4.RELEASE
+ 1.1.5.RELEASE
pom
- 1.1.4.RELEASE
+ 1.1.5.RELEASE
1.5.9
@@ -28,20 +28,17 @@
1.12.2
3.3.0
- 5.2.15.RELEASE
1.18.22
5.6.2
4.0.0
30.1.1-jre
- 2.1.11
+ 2.2.17
1.6.2
3.2.0
- 2.2.1
- 3.4.2
- 1.14.3
- 1.2
+ 3.0.2
+ 3.5.3
4.0.11
@@ -53,19 +50,13 @@
3.3.6
0.31.0
-
- 0.9.40
-
- 2.0.15
- 2.2.10
- 2.10.5
+ 3.0.0
27.0
2.5.1
- 5.3.2
4.4.0
1.8
- 7.17.7
+ 8.7.1
6.7.0
5.3.1
@@ -73,8 +64,7 @@
3.2.4
- 4.1.0
- 2.2.0.RELEASE
+ 3.2.1
2.0.1
0.4.6
@@ -104,11 +94,6 @@
uno-component-http
${uno.version}
-
- cc.allio
- uno-component-flink
- ${uno.version}
-
cc.allio
uno-component-websocket
@@ -130,11 +115,6 @@
uno-starter-core
${uno.version}
-
- cc.allio
- uno-starter-flink
- ${uno.version}
-
cc.allio
uno-starter-kafka
@@ -192,12 +172,6 @@
spring-statemachine-core
${spring-statemachine.version}
-
- org.springframework
- spring-webflux
- ${spring-webflux.version}
- provided
-
cglib
@@ -308,31 +282,6 @@
${mybatis-plus-boot.version}
provided
-
- org.apache.flink
- flink-streaming-java_2.12
- ${flink.version}
-
-
- org.apache.flink
- flink-clients_2.12
- ${flink.version}
-
-
- org.apache.flink
- flink-connector-kafka_2.12
- ${flink.version}
-
-
- org.apache.flink
- flink-connector-jdbc_2.12
- ${flink.version}
-
-
- com.esotericsoftware.minlog
- minlog
- ${flink-minlog.version}
-
@@ -394,11 +343,6 @@
opentracing-util
${oepntracing.version}
-
- cn.easy-es
- easy-es-boot-starter
- 2.0.0-beta1
-
com.playtika.reactivefeign
feign-reactor-cloud
@@ -414,11 +358,6 @@
feign-reactor-spring-configuration
${feign-reactor.version}
-
- com.alibaba
- easyexcel
- ${easyexcel.version}
-
io.springfox
springfox-swagger2
@@ -444,11 +383,6 @@
postgis-jdbc
${postgis-jdbc.version}
-
- com.googlecode.aviator
- aviator
- ${aviator.version}
-
cn.afterturn
easypoi-annotation
@@ -469,26 +403,6 @@
commons-csv
${appache-commons-csv.version}
-
- co.elastic.clients
- elasticsearch-java
- ${elasticsearch-client.version}
-
-
- org.elasticsearch.client
- elasticsearch-rest-high-level-client
- ${elasticsearch-client.version}
-
-
- org.elasticsearch.client
- elasticsearch-rest-client
- ${elasticsearch-client.version}
-
-
- org.elasticsearch
- elasticsearch
- ${elasticsearch-client.version}
-
com.influxdb
influxdb-client-java
@@ -520,11 +434,6 @@
shardingsphere-sql-parser-oracle
${shardingsphere.version}
-
- org.jeasy
- easy-rules-core
- ${easy-rules.version}
-
jakarta.json
jakarta.json-api
diff --git a/uno-components/pom.xml b/uno-components/pom.xml
index 54cb16df..84f65179 100644
--- a/uno-components/pom.xml
+++ b/uno-components/pom.xml
@@ -5,7 +5,7 @@
uno
cc.allio
- 1.1.4.RELEASE
+ 1.1.5.RELEASE
4.0.0
@@ -14,7 +14,6 @@
uno-component-http
- uno-component-flink
uno-component-websocket
uno-component-sequential
uno-component-kafka
diff --git a/uno-components/uno-component-flink/pom.xml b/uno-components/uno-component-flink/pom.xml
deleted file mode 100644
index 75210a35..00000000
--- a/uno-components/uno-component-flink/pom.xml
+++ /dev/null
@@ -1,45 +0,0 @@
-
-
-
- uno-components
- cc.allio
- 1.1.4.RELEASE
-
- 4.0.0
-
- uno-component-flink
-
-
-
- cc.allio
- uno-core
-
-
- org.apache.flink
- flink-streaming-java_2.12
-
-
- org.apache.flink
- flink-clients_2.12
-
-
- org.apache.flink
- flink-connector-kafka_2.12
-
-
- org.apache.flink
- flink-connector-jdbc_2.12
-
-
- com.esotericsoftware.minlog
- minlog
-
-
- cc.allio
- uno-test
- test
-
-
-
\ No newline at end of file
diff --git a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Input.java b/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Input.java
deleted file mode 100644
index 6fd8c8e0..00000000
--- a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Input.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package cc.allio.uno.component.flink;
-
-/**
- * 输入
- *
- * @param 输入数据类型
- * @author jiangwei
- * @date 2022/2/23 14:20
- * @since 1.0
- */
-public interface Input {
-
- /**
- * 向数据源中输入数据
- *
- * @param data 数据
- */
- void input(T data);
-}
diff --git a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Output.java b/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Output.java
deleted file mode 100644
index b6e1c8f6..00000000
--- a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/Output.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package cc.allio.uno.component.flink;
-
-/**
- * 数据
- *
- * @author jiangwei
- * @date 2022/2/23 14:22
- * @since 1.0
- */
-public interface Output {
-
- /**
- * 输出数据
- *
- * @return 数据输出
- * @throws Exception 输出产生异常时抛出
- */
- C output() throws Exception;
-}
diff --git a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/UnoFlinkProperties.java b/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/UnoFlinkProperties.java
deleted file mode 100644
index 346cc479..00000000
--- a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/UnoFlinkProperties.java
+++ /dev/null
@@ -1,78 +0,0 @@
-package cc.allio.uno.component.flink;
-
-import lombok.Data;
-import org.apache.flink.streaming.api.CheckpointingMode;
-import org.apache.flink.streaming.api.environment.CheckpointConfig;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-
-@Data
-@ConfigurationProperties("allio.uno.flink")
-public class UnoFlinkProperties {
-
- /**
- * 并行度
- *
- * @see StreamExecutionEnvironment#setParallelism(int)
- */
- private Integer parallelism = 5;
-
- private final Checkpoint checkpoint = new Checkpoint();
-
- @Data
- public static class Checkpoint {
-
- /**
- * 是否开启checkpoint
- */
- private boolean enable = true;
-
- /**
- * checkpoint周期
- *
- * @see StreamExecutionEnvironment#enableCheckpointing(long)
- */
- private Long checkpointPeriod = 60000L;
-
- /**
- * 是否强制进行checkpoint
- */
- private boolean forceCheckpointing = true;
-
- /**
- * checkpoint模式
- *
- * @see CheckpointingMode
- */
- private CheckpointingMode checkpointMode = CheckpointingMode.EXACTLY_ONCE;
-
- /**
- * checkpoint最小间隔
- */
- private Long minPauseBetweenCheckpoints = 60000L;
-
- /**
- * checkpoint超时时间
- */
- private Long checkPointTimeout = 180000L;
-
- /**
- * 允许的并发检查点
- */
- private Integer maxConcurrentCheckpoints = 1;
-
- /**
- * 表示一旦Flink处理程序被cancel后,会保留Checkpoint数据,以便根据实际需要恢复到指定的Checkpoint【详细解释见备注】
- * ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION:表示一旦Flink处理程序被cancel后,会保留Checkpoint数据,以便根据实际需要恢复到指定的Checkpoint
- * ExternalizedCheckpointCleanup.DELETE_ON_CANCELLATION: 表示一旦Flink处理程序被cancel后,会删除Checkpoint数据,只有job执行失败的时候才会保存checkpoint
- *
- * @see CheckpointConfig.ExternalizedCheckpointCleanup
- */
- private CheckpointConfig.ExternalizedCheckpointCleanup externalizedCheckpointCleanup = CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION;
-
- /**
- * checkpoint路径
- */
- private String checkpointPath = "file:///Users/jiangwei/Miscellaneous/flink";
- }
-}
diff --git a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/concurrent/JobRichContext.java b/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/concurrent/JobRichContext.java
deleted file mode 100644
index fe10bf91..00000000
--- a/uno-components/uno-component-flink/src/main/java/cc/allio/uno/component/flink/concurrent/JobRichContext.java
+++ /dev/null
@@ -1,127 +0,0 @@
-package cc.allio.uno.component.flink.concurrent;
-
-import cc.allio.uno.component.flink.Input;
-import cc.allio.uno.component.flink.Output;
-import org.apache.flink.api.common.JobID;
-import org.apache.flink.api.common.functions.RichFunction;
-import org.apache.flink.api.common.time.Time;
-import org.apache.flink.configuration.Configuration;
-import org.apache.flink.runtime.deployment.TaskDeploymentDescriptor;
-import org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway;
-import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import org.springframework.util.CollectionUtils;
-
-import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.CountDownLatch;
-import java.util.stream.Collectors;
-
-/**
- * 基于JobId创建的计数器,它的目的是为了解决flink function序列化的问题所产生的
- *
- * - 在Flink序列化中,无法维护没有实现序列化的对象,导致function中使用那些外部对象一定为null。解决这个问题是实现{@link RichFunction#open(Configuration)}来解决这个问题
- * - 但又引出另外一个问题,触发{@link RichFunction#open(Configuration)}方法,是因为{@link TaskManagerGateway#submitTask(TaskDeploymentDescriptor, Time)}提交任务之后触发
- * - 而提交任务是因为JobManager通过rpc进行触发,这个一个异步的过程。实现中,使用{@link StreamExecutionEnvironment#execute()}同步提交等待触发,
- * 但我需要的不是同步提交,而是异步提交,而且自定义function是一个同步阻塞的过程。不能满足
- * - 为了解决这一个问题,引入这个类,这个类的目的是在提交数据后,等待任务是否已经提交完毕。它的实现原理是利用计数锁存器,当某一个function初始化完毕后计数减1,直到所有的计数完成,结束阻塞
- *
- * 因为存在function的序列化,所以即使本地保存的function对象是没有被纳入Task中,这个类的另外一个目的就是为了获取这些对象而做的上下文存储器
- *
- * @author jiangwei
- * @date 2022/2/24 00:29
- * @since 1.0
- */
-@Deprecated
-public class JobRichContext {
-
- private JobRichContext() {
-
- }
-
- /**
- * 维护当前flink job的阻塞器
- */
- private static final Map JOB_ID_BLOCKING = new ConcurrentHashMap<>();
-
- /**
- * 维护当前任务所使用的rich function
- */
- private static final Map> currentRich = new ConcurrentHashMap<>();
-
- /**
- * 向阻塞器缓存中存入job
- *
- * @param jobID jobId
- * @param count function数量
- * @return 锁存器对象实例
- */
- public static synchronized CountDownLatch registerCountDown(JobID jobID, Integer count) {
- CountDownLatch blocking = new CountDownLatch(count);
- JOB_ID_BLOCKING.put(jobID, blocking);
- return blocking;
- }
-
- /**
- * 减去当前Job的锁存器的计数值
- *
- * @param jobID jobID对象
- * @throws NullPointerException 不存在当前锁存器的Job
- */
- public static synchronized void subtraction(JobID jobID) {
- CountDownLatch blocking = JOB_ID_BLOCKING.get(jobID);
- if (blocking == null) {
- throw new NullPointerException(String.format("JobID %s countdown latch does not exist", jobID));
- }
- blocking.countDown();
- }
-
- /**
- * 向缓存中注册RichFunction
- *
- * @param jobID jobID对象
- * @param rich RichFunction对象
- * @throws NullPointerException rich对象为空抛出
- */
- public static synchronized void registerRich(JobID jobID, RichFunction rich) {
- Set richSet = currentRich.get(jobID);
- if (CollectionUtils.isEmpty(richSet)) {
- richSet = new HashSet<>();
- currentRich.put(jobID, richSet);
- }
- richSet.add(rich);
- }
-
- /**
- * 向Rich中获取Input
- *
- * @param jobID jobId对象
- * @return 空或者找到的Input对象
- */
- public static synchronized List getInputs(JobID jobID) {
- Set richSet = currentRich.get(jobID);
- if (CollectionUtils.isEmpty(richSet)) {
- return Collections.emptyList();
- }
- return richSet.stream()
- .filter(v -> Input.class.isAssignableFrom(v.getClass()))
- .map(Input.class::cast)
- .collect(Collectors.toList());
- }
-
- /**
- * 向Rich中获取Output
- *
- * @param jobID jobID对象
- * @return 空或者找到的Output对象
- */
- public static synchronized List