以上代码提示以下错误 AttributeError: type object 'DeltaTable' has no attribute 'stream'

在 PySpark 中，DeltaTable 类没有 `stream` 方法。如果要使用 Delta Lake 的流式处理功能，需要使用 `DeltaLakeTable` 类，该类提供了 `toDF()` 和 `writeStream()` 方法来读取和处理流数据。因此，你需要将代码中的 `DeltaTable.stream()` 修改为 `DeltaLakeTable.toDF()`，并在 `writeStream()` 方法中指定输出格式和输出选项，如下所示：

from delta.tables import *
from pyspark.sql.functions import count

deltaTable = DeltaTable.forPath(spark, "dbfs:/mnt/odp01/sbd/trade_all")
liveTable = DeltaLakeTable.forPath(spark, "dbfs:/mnt/odp01/sbd/trade_all") \
    .toDF() \
    .filter("operation = 'MERGE'") \
    .groupBy("channelCode") \
    .agg(count("*").alias("js_num"))
    .writeStream \
    .format("console") \
    .option("truncate", "false") \
    .start()

这个代码将 DeltaLakeTable 类用于流式数据的处理，使用 `toDF()` 方法将 Delta Lake 表转换为 DataFrame，然后使用 DataFrame API 进行数据处理，最后使用 `writeStream()` 方法将结果输出到控制台。