tispark structured streaming可以跟flink一样把tidb里的表注册成动态维表跟实时流做聚合吗

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。

  • 【TiDB 版本】:3.0
  • 【问题描述】:tispark structured streaming可以跟flink一样把tidb里的表注册成动态维表跟实时流做聚合吗

可以的,可以参考下这个 https://github.com/pingcap/tispark-test/blob/master/tispark-examples/src/main/scala/com/pingcap/tispark/examples/StructuredStreamingReadTiDB.scala

spark structured streaming 分别读取两个tidb的表形成两个tidb流,两个流之间可以join吗

应该是可以的,自Spark 2.3版本起,加入了对Stream-Stream Joins的支持。https://www.jianshu.com/p/7a7c2aaa47e8