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 8723e6b Remove @author tag based on Apache recommendation
8723e6b is described below
commit 8723e6b01dd5568f318204abdf7f7a07b32ff70d
Author: Luciano Resende <[email protected]>
AuthorDate: Tue May 26 23:22:22 2020 -0700
Remove @author tag based on Apache recommendation
---
.../java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java | 1 -
.../apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java | 1 -
.../redis/common/config/handler/FlinkJedisClusterConfigHandler.java | 1 -
.../connectors/redis/common/hanlder/FlinkJedisConfigHandler.java | 1 -
.../flink/streaming/connectors/redis/common/hanlder/RedisHandler.java | 1 -
.../streaming/connectors/redis/common/hanlder/RedisHandlerServices.java | 1 -
.../streaming/connectors/redis/common/hanlder/RedisMapperHandler.java | 1 -
.../streaming/connectors/redis/common/mapper/row/DecrByExMapper.java | 1 -
.../streaming/connectors/redis/common/mapper/row/HIncrByMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java | 1 -
.../streaming/connectors/redis/common/mapper/row/IncrByExMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/IncrByMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/LPushMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/PfAddMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/RPushMapper.java | 1 -
.../streaming/connectors/redis/common/mapper/row/RowRedisMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/SAddMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/SetExMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/SetMapper.java | 1 -
.../flink/streaming/connectors/redis/common/mapper/row/ZAddMapper.java | 1 -
.../org/apache/flink/streaming/connectors/redis/descriptor/Redis.java | 1 -
.../flink/streaming/connectors/redis/descriptor/RedisValidator.java | 1 -
22 files changed, 22 deletions(-)
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java
index 48556b4..8f1571b 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java
@@ -39,7 +39,6 @@ import java.util.Map;
import static org.apache.flink.table.descriptors.Schema.SCHEMA;
/**
- * @author Ameng .
* redis table sink to use redis in sql env.
*/
public class RedisTableSink implements UpsertStreamTableSink<Row> {
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 1031aec..b454fee 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
@@ -34,7 +34,6 @@ import static
org.apache.flink.table.descriptors.FormatDescriptorValidator.FORMA
import static org.apache.flink.table.descriptors.Schema.*;
/**
- * @author Ameng .
* redis table sink factory for creare redis table sink.
*/
public class RedisTableSinkFactory implements
StreamTableSinkFactory<Tuple2<Boolean, Row>> {
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 832b709..6ac0c0a 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
@@ -32,7 +32,6 @@ import
org.apache.flink.streaming.connectors.redis.common.hanlder.FlinkJedisConf
import org.apache.flink.util.Preconditions;
/**
- * @author Ameng .
* jedis cluster config handler to find and create jedis cluster config use
meta.
*/
public class FlinkJedisClusterConfigHandler implements FlinkJedisConfigHandler
{
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java
index d1969f3..226eda3 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java
@@ -21,7 +21,6 @@ import java.util.Map;
import
org.apache.flink.streaming.connectors.redis.common.config.FlinkJedisConfigBase;
/**
- * @author Ameng .
* handler to create flink jedis config.
*/
public interface FlinkJedisConfigHandler extends RedisHandler {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandler.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandler.java
index eb33782..db86451 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandler.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandler.java
@@ -23,7 +23,6 @@ import java.util.List;
import java.util.Map;
/***
- * @author Ameng.
* redis handler to create redis mapper and flink jedis config.
*/
public interface RedisHandler extends Serializable {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java
index ba8ff71..3fc3af6 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java
@@ -31,7 +31,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * @author Ameng.
* Unified class to search for a {@link RedisHandler} of provided type and
properties.
* for find correct redis handler.
* @param <T> redis handler type.
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 2cb3c77..e398f61 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
@@ -27,7 +27,6 @@ import java.util.Map;
import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_KEY_TTL;
/**
- * @author Ameng .
* handler for create redis mapper.
*/
public interface RedisMapperHandler extends RedisHandler {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/DecrByExMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/DecrByExMapper.java
index 0844079..2129076 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/DecrByExMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/DecrByExMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* decrease with expire operation redis mapper.
*/
public class DecrByExMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HIncrByMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HIncrByMapper.java
index 509f8ea..46d8387 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HIncrByMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HIncrByMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* HSET operation redis mapper.
*/
public class HIncrByMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java
index 1cea53f..ce37362 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* HSET operation redis mapper.
*/
public class HSetMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByExMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByExMapper.java
index 0621334..f2ff140 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByExMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByExMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* Delta plus with expire key operation redis mapper.
*/
public class IncrByExMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByMapper.java
index b0bd567..5ee7d5b 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/IncrByMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* Delta plus operation
*/
public class IncrByMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/LPushMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/LPushMapper.java
index 0f5e39c..25cb06c 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/LPushMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/LPushMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* LPUSH operation redis mapper.
*/
public class LPushMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/PfAddMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/PfAddMapper.java
index 7596520..a85c2ac 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/PfAddMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/PfAddMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* PFADD operation redis mapper.
*/
public class PfAddMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RPushMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RPushMapper.java
index b0d1a6d..fd47ec1 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RPushMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RPushMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* RPUSH operation redis mapper.
*/
public class RPushMapper extends RowRedisMapper {
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 a1f1388..bdaf9be 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
@@ -33,7 +33,6 @@ import java.util.Optional;
import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.REDIS_COMMAND;
/**
- * @author Ameng .
* base row redis mapper implement.
*/
public abstract class RowRedisMapper implements RedisMapper<Tuple2<Boolean,
Row>>, RedisMapperHandler {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SAddMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SAddMapper.java
index cee1347..9cd09bc 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SAddMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SAddMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* SADD operation redis mapper.
*/
public class SAddMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetExMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetExMapper.java
index a0f8bbb..4c2b31a 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetExMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetExMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng.
* SET with expire key operation redis mapper.
*/
public class SetExMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetMapper.java
index 9e768c1..bce2a3d 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/SetMapper.java
@@ -20,7 +20,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* SET operation redis mapper.
*/
public class SetMapper extends RowRedisMapper {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/ZAddMapper.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/ZAddMapper.java
index 3e5b7ed..3507b65 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/ZAddMapper.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/ZAddMapper.java
@@ -21,7 +21,6 @@ package
org.apache.flink.streaming.connectors.redis.common.mapper.row;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
/**
- * @author Ameng .
* ZADD operation redis mapper.
*/
public class ZAddMapper extends RowRedisMapper {
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 b9b2e1f..86fcd29 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
@@ -26,7 +26,6 @@ import java.util.Map;
import static
org.apache.flink.streaming.connectors.redis.descriptor.RedisValidator.*;
/**
- * @author Ameng .
* redis descriptor for create redis connector.
*/
public class Redis extends ConnectorDescriptor {
diff --git
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
index b459d3b..ac97722 100644
---
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
+++
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java
@@ -18,7 +18,6 @@
package org.apache.flink.streaming.connectors.redis.descriptor;
/**
- * @author Ameng .
* redis validator for validate redis descriptor.
*/
public class RedisValidator {
