结构化流

回到术语表
结构化流是一个用于流处理的高级API,在Spark 2.2中已经可以用于生产。结构化流允许您使用Spark的结构化api在批处理模式下执行相同的操作,并以流方式运行它们。这可以减少延迟并允许增量处理。结构化流最好的一点是,它允许您快速地从流系统中获得价值,几乎不需要更改代码。它也使推理变得容易,因为你可以将批处理作业作为一种原型,然后将其转换为流作业。所有这些工作的方式都是通过增量处理数据。结构化流处理模型

额外的资源


回到术语表