You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@geaflow.apache.org by "Leomrlin (via GitHub)" <gi...@apache.org> on 2026/06/18 03:43:24 UTC
[I] Add a Redis connector (source + sink) [geaflow]
Leomrlin opened a new issue, #799:
URL: https://github.com/apache/geaflow/issues/799
### What & why
The project already has a Redis **store** (a state backend) but no Redis
**connector** (treating Redis as a data source/sink). They serve different roles:
the store backs the engine's internal state, while a connector backs DSL table
reads/writes. Redis as a dimension table or result cache is very common.
项目已有 Redis **store**(状态后端),但没有 Redis **connector**(把 Redis 当数据源/汇)。
两者职责不同:store 服务于引擎内部状态,connector 服务于 DSL 建表读写。Redis 作维表/结果缓存很常见。
### The task
Create `geaflow-dsl-connector-redis`: the sink supports writing string/hash, the
source supports scanning by key pattern.
新建 `geaflow-dsl-connector-redis`,sink 支持写 string/hash,source 支持按 key 模式扫描读取。
### Where to look / 怎么做
1. References: the minimal `geaflow-dsl-connector-console` (sink only) and the
connection-managing `geaflow-dsl-connector-elasticsearch`.
2. **Reuse the Redis client already in the project** — check which client
`geaflow-store-redis` uses and stick with it to avoid pulling in a new dependency.
3. Implement connector / source / sink + SPI registration + pom + docs + tests.
### Done when
- [ ] Both source and sink work, supporting string and hash (at least one, with explanation)
- [ ] Reuses the existing Redis client dependency, no duplicate dependency introduced
- [ ] Testcontainers integration test
- [ ] CN + EN docs + examples
- [ ] checkstyle / RAT pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org
For additional commands, e-mail: issues-help@geaflow.apache.org
Re: [I] Add a Redis connector (source + sink) [geaflow]
Posted by "tjx-outlook (via GitHub)" <gi...@apache.org>.
tjx-outlook commented on issue #799:
URL: https://github.com/apache/geaflow/issues/799#issuecomment-5015146729
Hi, I'm a first-time contributor and I'd like to work on this Redis connector issue. Could you please assign it to me? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org
For additional commands, e-mail: issues-help@geaflow.apache.org
Re: [I] Add a Redis connector (source + sink) [geaflow]
Posted by "huangguasky (via GitHub)" <gi...@apache.org>.
huangguasky commented on issue #799:
URL: https://github.com/apache/geaflow/issues/799#issuecomment-4762018585
Hi, I would like to work on this issue. Could you please assign it to me?
I plan to add a geaflow-dsl-connector-redis module, reuse the existing Jedis dependency, implement Redis string/hash source and sink support, and add docs plus tests.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@geaflow.apache.org
For additional commands, e-mail: issues-help@geaflow.apache.org