изменения (DataStreamReader)

Возвращает изменения на уровне строк (запись измененных данных) из указанной таблицы в виде потокового кадра данных. В настоящее время поддерживается только для таблиц источника данных версии 2, каталог которых реализуется TableCatalog.loadChangelog(). Используется option() для указания начальной версии или метки времени и параметров обработки.

Синтаксис

changes(tableName)

Параметры

Параметр	Тип	Описание
tableName	str	Название таблицы.

Возвраты

DataFrame

Примеры

spark.readStream.option("startingVersion", "10").changes("my_table")