pyspark.sql.streaming.DataStreamWriter.foreachBatch???
-
DataStreamWriter.分页批量高山市 趣味:可调用[dataFrame, int )数据StreamWriter ??? -
设置流查询输出使用提供函数处理仅支持微批执行模式(即触发非连续式)。在每个微批量中,提供函数时会调用每个微批量并带 (i)输出行DataFrame和(ii)批量标识符批量Id可用解析并事务写输出(即提供数据集)外部系统DataFrame对同批量Id保证完全相同(假设所有运算在查询中确定性)。
注解
API正在演化
实例
>>>def趣味高山市批量df,批量i:.批量df.集合(b).>>>写作者=sdf.写Stream.分页批量高山市趣味)