You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/09/22 06:41:52 UTC
[rocketmq-streams] branch main updated: fix(common) remove dipper
This is an automated email from the ASF dual-hosted git repository.
karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
The following commit(s) were added to refs/heads/main by this push:
new 7b099cfd fix(common) remove dipper
new 240861d9 Merge pull request #219 from ni-ze/supportRsqldb
7b099cfd is described below
commit 7b099cfd4f88bda918be01bd19f495507a037643
Author: 维章 <un...@gmail.com>
AuthorDate: Thu Sep 22 14:38:00 2022 +0800
fix(common) remove dipper
---
.../streams/client/windows/SingleSplitTest.java | 2 +-
.../streams/common/configure/ConfigureFileKey.java | 42 +++++++++++-----------
2 files changed, 22 insertions(+), 22 deletions(-)
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/SingleSplitTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/SingleSplitTest.java
index 88909b6d..70a07bd4 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/SingleSplitTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/SingleSplitTest.java
@@ -62,7 +62,7 @@ public class SingleSplitTest extends AbstractWindowTest {
@Test
public void testFireMode0() throws InterruptedException {
// ComponentCreator.getProperties().setProperty("window.fire.isTest","true");
- ComponentCreator.getProperties().setProperty("dipper.configurable.polling.time", "-1");
+ ComponentCreator.getProperties().setProperty("configurable.polling.time", "-1");
super.executeWindowStream(true, 5, IWindow.DEFAULTFIRE_MODE, 0, 200l);
}
diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
index ec65c70e..6b1d937b 100644
--- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
+++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
@@ -33,67 +33,67 @@ public interface ConfigureFileKey {
String JDBC_PASSWORD = "jdbc.password";
String JDBC_DRIVER = "jdbc.driver";
String JDBC_TABLE_NAME = "table.name";
- String SECRECY = "dipper.configure.sec.key";
+ String SECRECY = "configure.sec.key";
String SECRECY_DEFAULT = "";
- String DIPPER_REGEX_ENGINE = "dipper.regex.engine.option";
+ String DIPPER_REGEX_ENGINE = "regex.engine.option";
/**
* whether to start engine when loading configurable operator, true(default) or false
*/
- String DIPPER_RUNNING_STATUS = "dipper.running.status";
+ String DIPPER_RUNNING_STATUS = "running.status";
String DIPPER_RUNNING_STATUS_DEFAULT = "true";
- String POLLING_TIME = "dipper.configurable.polling.time";
+ String POLLING_TIME = "configurable.polling.time";
/**
* 默认的文件存储transport的name
*/
- String FILE_TRANSPORT_NAME = "dipper.file.transport.name";
- String FILE_TRANSPORT_AK = "dipper.file.transport.ak";
- String FILE_TRANSPORT_SK = "dipper.file.transport.sk";
- String FILE_TRANSPORT_ENDPOINT = "dipper.file.transport.endpoint";
- String FILE_TRANSPORT_DIPPER_DIR = "dipper.file.transport.dipper.dir";
+ String FILE_TRANSPORT_NAME = "file.transport.name";
+ String FILE_TRANSPORT_AK = "file.transport.ak";
+ String FILE_TRANSPORT_SK = "file.transport.sk";
+ String FILE_TRANSPORT_ENDPOINT = "file.transport.endpoint";
+ String FILE_TRANSPORT_DIPPER_DIR = "file.transport.dir";
/**
* 监控相关的配置，监控输入的级别，有三种：INFO,SLOW,ERROR
*/
- String MONITOR_OUTPUT_LEVEL = "dipper.monitor.output.level";
+ String MONITOR_OUTPUT_LEVEL = "monitor.output.level";
/**
* 超过多长时间，输出慢查询
*/
- String MONITOR_SLOW_TIMEOUT = "dipper.monitor.slow.timeout";
+ String MONITOR_SLOW_TIMEOUT = "monitor.slow.timeout";
/**
* 如果是日志输出，需要指定默认的目录
*/
- String MONTIOR_LOGGER_DIR = "dipper.monitor.loger.dir";
+ String MONTIOR_LOGGER_DIR = "monitor.loger.dir";
/**
* 是否把原始日志备份下来，以备做效果测试
*/
- String INNER_MESSAGE_SWITCH = "dipper.inner.message.save.switch";
+ String INNER_MESSAGE_SWITCH = "inner.message.save.switch";
/**
* 是否在做数据回放，如果再做数据回放，自动判读结果是否符合预期
*/
- String DIPPER_ORIG_MESSAGE_PLAYBACK = "dipper.orimessage.playback";
+ String DIPPER_ORIG_MESSAGE_PLAYBACK = "orimessage.playback";
//dipper自己实现的延迟队列
- String DIPPER_WINDOW_DELAY_CHANNEL_TOPIC = "dipper.window.delay.channel.topic";
+ String DIPPER_WINDOW_DELAY_CHANNEL_TOPIC = "window.delay.channel.topic";
//join的默认窗口大小
- String DIPPER_WINDOW_JOIN_DEFAULT_ITERVA_SIZE = "dipper.window.join.default.iterval.size.time";
+ String DIPPER_WINDOW_JOIN_DEFAULT_ITERVA_SIZE = "window.join.default.iterval.size.time";
// //join需要保留几个窗口，3个窗口意味着join的范围是上下15分钟多
- String DIPPER_WINDOW_JOIN_RETAIN_WINDOW_COUNT = "dipper.window.join.default.retain.window.count";
+ String DIPPER_WINDOW_JOIN_RETAIN_WINDOW_COUNT = "window.join.default.retain.window.count";
//窗口多长延迟多长时间触发，确保多台机器的数据写入存储
- String DIPPER_WINDOW_DEFAULT_FIRE_DELAY_SECOND = "dipper.window.default.fire.delay.second";
+ String DIPPER_WINDOW_DEFAULT_FIRE_DELAY_SECOND = "window.default.fire.delay.second";
//统计默认的窗口大小，单位是分钟。默认是滚动窗口，大小是1个小时
- String DIPPER_WINDOW_DEFAULT_INERVAL_SIZE = "dipper.window.default.iterval.size.time";
+ String DIPPER_WINDOW_DEFAULT_INERVAL_SIZE = "window.default.iterval.size.time";
//统计默认的窗口大小，单位是分钟。默认是滚动窗口，大小是1个小时
- String DIPPER_WINDOW_DEFAULT_TIME_UNIT_ADJUST = "dipper.window.default.time.unit.adjust";
+ String DIPPER_WINDOW_DEFAULT_TIME_UNIT_ADJUST = "window.default.time.unit.adjust";
//over partition窗口的默认时间
- String DIPPER_WINDOW_OVER_DEFAULT_ITERVA_SIZE = "dipper.window.over.default.iterval.size.time";
+ String DIPPER_WINDOW_OVER_DEFAULT_ITERVA_SIZE = "window.over.default.iterval.size.time";
static String getDipperJdbcUrl() {
return ComponentCreator.getProperties().getProperty(JDBC_URL);