【发布时间】:2020-08-01 13:17:19
【问题描述】:
我正在为我的后端服务开发一个轻量级框架,以支持类似管道的处理。
- 在管道中,每个阶段本质上是一个
Function<IN, OUT>,其中IN是前一个阶段的OUT。 - 每个阶段都可以将其结果设置为数据模型(我们称之为
Record) - 虽然输入是
IN(前一阶段的输出),但每个阶段都可以查看到目前所有的结果。
我的问题:
因此,从本质上讲,每个阶段都可以将其结果设置为数据模型,并且可以获得迄今为止的所有其他结果。这使得模型在管道中的所有组件之间共享和可变。
它会被视为反模式吗?如果是这样,您将对我的架构做出哪些改变?
谢谢
【问题讨论】:
-
每个阶段仍然可以创建一个新的Record对象
-
有点像
List实现 -
@emotionlessbananas,你能详细说明一下吗?
标签: java design-patterns etl backend stream-processing