This is an automated email from the ASF dual-hosted git repository.
lresende pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
The following commit(s) were added to refs/heads/master by this push:
new 8b6bbf9 Fix typo RedisVadidator -> RedisValidator (#80)
8b6bbf9 is described below
commit 8b6bbf9622faee62c3a440430aef750b85b9b904
Author: Ahoo Wang <[email protected]>
AuthorDate: Fri May 8 01:23:41 2020 +0800
Fix typo RedisVadidator -> RedisValidator (#80)
---
.../connectors/redis/RedisTableSinkFactory.java | 14 +++++++-------
.../config/handler/FlinkJedisClusterConfigHandler.java | 6 +++---
.../config/handler/FlinkJedisSentinelConfigHandler.java | 10 +++++-----
.../redis/common/hanlder/RedisMapperHandler.java | 2 +-
.../redis/common/mapper/row/RowRedisMapper.java | 2 +-
.../streaming/connectors/redis/descriptor/Redis.java | 16 ++++++++--------
.../{RedisVadidator.java => RedisValidator.java} | 2 +-
.../streaming/connectors/redis/RedisDescriptorTest.java | 6 +++---
.../connectors/redis/common/RedisHandlerTest.java | 10 +++++-----
9 files changed, 34 insertions(+), 34 deletions(-)
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
index 2ad5ed3..b081d3c 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
@@ -17,13 +17,13 @@
package org.apache.flink.streaming.connectors.redis;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_COMMAND;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_KEY_TTL;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MASTER_NAME;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MODE;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_NODES;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_SENTINEL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_COMMAND;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_KEY_TTL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MASTER_NAME;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MODE;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_NODES;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_SENTINEL;
import static
org.apache.flink.table.descriptors.ConnectorDescriptorValidator.CONNECTOR;
import static
org.apache.flink.table.descriptors.ConnectorDescriptorValidator.CONNECTOR_TYPE;
import static
org.apache.flink.table.descriptors.FormatDescriptorValidator.FORMAT;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
index b48db1b..832b709 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
@@ -16,9 +16,9 @@
*/
package org.apache.flink.streaming.connectors.redis.common.config.handler;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_CLUSTER;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MODE;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_NODES;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_CLUSTER;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MODE;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_NODES;
import java.net.InetSocketAddress;
import java.util.Arrays;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
index fb852de..72065d5 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
@@ -17,11 +17,11 @@
package org.apache.flink.streaming.connectors.redis.common.config.handler;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MASTER_NAME;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MODE;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_SENTINEL;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.SENTINELS_INFO;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.SENTINELS_PASSWORD;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MASTER_NAME;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MODE;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_SENTINEL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.SENTINELS_INFO;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.SENTINELS_PASSWORD;
import java.util.Arrays;
import java.util.HashMap;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java
index a0b087c..6e19295 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java
@@ -17,7 +17,7 @@
package org.apache.flink.streaming.connectors.redis.common.hanlder;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_KEY_TTL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_KEY_TTL;
import java.lang.reflect.Constructor;
import java.util.Map;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
index c62e1d6..6e9bc90 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
@@ -17,7 +17,7 @@
package org.apache.flink.streaming.connectors.redis.common.mapper.row;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_COMMAND;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_COMMAND;
import java.util.HashMap;
import java.util.Map;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java
index af21163..086114b 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java
@@ -17,14 +17,14 @@
package org.apache.flink.streaming.connectors.redis.descriptor;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_CLUSTER;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_COMMAND;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_KEY_TTL;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MASTER_NAME;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MODE;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_NODES;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_SENTINEL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_CLUSTER;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_COMMAND;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_KEY_TTL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MASTER_NAME;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MODE;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_NODES;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_SENTINEL;
import java.util.HashMap;
import java.util.Map;
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisVadidator.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
similarity index 98%
rename from
flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisVadidator.java
rename to
flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
index f9b604d..b459d3b 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisVadidator.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
@@ -21,7 +21,7 @@ package
org.apache.flink.streaming.connectors.redis.descriptor;
* @author Ameng .
* redis validator for validate redis descriptor.
*/
-public class RedisVadidator {
+public class RedisValidator {
public static final String REDIS = "redis";
public static final String REDIS_MODE = "redis-mode";
public static final String REDIS_NODES = "cluster-nodes";
diff --git
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
index 2caf8f3..97293d0 100644
---
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
+++
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
@@ -24,7 +24,7 @@ import
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
import org.apache.flink.streaming.connectors.redis.descriptor.Redis;
-import org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator;
+import org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.Schema;
@@ -57,10 +57,10 @@ public class RedisDescriptorTest extends RedisITCaseBase{
tableEnvironment.registerDataStream("t1", source, "k, v");
Redis redis = new Redis()
- .mode(RedisVadidator.REDIS_CLUSTER)
+ .mode(RedisValidator.REDIS_CLUSTER)
.command(RedisCommand.INCRBY_EX.name())
.ttl(100000)
- .property(RedisVadidator.REDIS_NODES, REDIS_HOST+ ":" +
REDIS_PORT);
+ .property(RedisValidator.REDIS_NODES, REDIS_HOST+ ":" +
REDIS_PORT);
tableEnvironment
.connect(redis).withSchema(new Schema()
diff --git
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/common/RedisHandlerTest.java
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/common/RedisHandlerTest.java
index 54a7fd9..ee1e789 100644
---
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/common/RedisHandlerTest.java
+++
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/common/RedisHandlerTest.java
@@ -17,11 +17,11 @@
package org.apache.flink.streaming.connectors.redis.common;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_CLUSTER;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_COMMAND;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_KEY_TTL;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_MODE;
-import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisVadidator.REDIS_NODES;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_CLUSTER;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_COMMAND;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_KEY_TTL;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_MODE;
+import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_NODES;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
