首页
学习
活动
专区
工具
TVP
发布
您找到你想要的搜索结果了吗?
是的
没有找到

ClickHouse和他的朋友们(4)Pipeline处理器和调度器

connect(Source.OutPort, FilterTransform.InPort) connect(FilterTransform.OutPort, SortingTransform.InPort...) connect(SortingTransform.OutPort, LimitByTransform.InPort) connect(LimitByTransform.OutPort, Sinker.InPort...) 这样就实现了数据的流向关系,一个 transformer 的 OutPort 对接另外一个的 InPort,就像我们现实中的水管管道一样,接口有 3 通甚至多通。...ExpandPipeline, // Pipeline 需要裂变 }; 当 source 生成数据后,它的状态会设置为 PortFull,意思是等着流入其他 transformer 的 InPort...ClickHouse 的 transformer 数据单元是 Chunk,transformer 对上游 OutPort 流过来的 Chunk 进行加工,然后输出给下游的 InPort,图连通式的流水线并行工作

1.5K20

扫码

添加站长 进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

    运营活动

    活动名称
    广告关闭
    领券