实时拿到数据后如何真正进行实时跑批？

肯定要用类似streaming或flink这样的流处理组件而不是跑批。具体可以两种实现方案，一是cdc的目标不要设置为数据库而是设置为kafka，然后对接kafka或者flink，这种比较容易；二是目标为数据库，然后自己写程序实现轮训，这种比较复杂但对大数据组件没要求，适合小数据量处理。

如果必须实时跑批，也就是让后续的表能够实时变化。那么能想到的方案也就是用视图了。
但这样就限制了实时数仓的规模。