You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by zi...@apache.org on 2023/01/31 03:10:15 UTC
[inlong] branch master updated (5413ab78a -> 479ff3ab9)
This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 5413ab78a [INLONG-7268][Sort] Support load node of Apache Kudu (#7269)
add 479ff3ab9 [INLONG-7060][Sort] Support write redis in sort-connector-redis (#7228)
No new revisions were added by this update.
Summary of changes:
.../src/main/assemblies/sort-connectors.xml | 8 +
inlong-sort/README.md | 2 +
inlong-sort/sort-connectors/redis/README.md | 245 ++++++++++++++
inlong-sort/sort-connectors/redis/pom.xml | 85 ++++-
.../sort/redis/common/config/RedisDataType.java | 52 +++
.../sort/redis/common/config/RedisOptions.java | 70 +++-
.../redis/common/config/SchemaMappingMode.java | 52 +++
.../container/InlongRedisClusterContainer.java | 14 +
.../container/InlongRedisCommandsContainer.java | 1 +
.../common/container/InlongRedisContainer.java | 17 +
.../sort/redis/common/schema/RedisSchema.java | 54 ++++
.../redis/common/schema/RedisSchemaFactory.java | 82 +++++
.../sort/redis/common/schema/StateEncoder.java} | 18 +-
.../common/schema/impl/AbstractRedisSchema.java | 107 +++++++
.../schema/impl/BitmapStaticKvPairSchema.java | 78 +++++
.../common/schema/impl/HashDynamicSchema.java | 77 +++++
.../common/schema/impl/HashStaticKvPairSchema.java | 72 +++++
.../schema/impl/HashStaticPrefixMatchSchema.java | 69 ++++
.../common/schema/impl/PlainPrefixMatchSchema.java | 64 ++++
.../sort/redis/sink/AbstractRedisSinkFunction.java | 292 +++++++++++++++++
.../sort/redis/sink/RedisBitmapSinkFunction.java | 80 +++++
.../sort/redis/sink/RedisDynamicTableSink.java | 188 +++++++++++
.../sort/redis/sink/RedisHashSinkFunction.java | 81 +++++
.../sort/redis/sink/RedisPlainSinkFunction.java | 77 +++++
.../inlong/sort/redis/sink/RedisSinkFunction.java | 77 +++++
.../sort/redis/table/RedisDynamicTableFactory.java | 120 +++++--
.../sort/redis/RedisDynamicTableFactoryTest.java | 145 +++++++++
.../apache/inlong/sort/redis/RedisTableTest.java | 355 +++++++++++++++++++++
28 files changed, 2541 insertions(+), 41 deletions(-)
create mode 100644 inlong-sort/sort-connectors/redis/README.md
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/config/RedisDataType.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/config/SchemaMappingMode.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/RedisSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/RedisSchemaFactory.java
copy inlong-sort/sort-connectors/{elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/StaticIndexGenerator.java => redis/src/main/java/org/apache/inlong/sort/redis/common/schema/StateEncoder.java} (70%)
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/AbstractRedisSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/BitmapStaticKvPairSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/HashDynamicSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/HashStaticKvPairSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/HashStaticPrefixMatchSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/PlainPrefixMatchSchema.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/AbstractRedisSinkFunction.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/RedisBitmapSinkFunction.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/RedisDynamicTableSink.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/RedisHashSinkFunction.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/RedisPlainSinkFunction.java
create mode 100644 inlong-sort/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/sink/RedisSinkFunction.java
create mode 100644 inlong-sort/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisDynamicTableFactoryTest.java
create mode 100644 inlong-sort/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java