Package org.apache.iceberg.flink.maintenance.operator

package org.apache.iceberg.flink.maintenance.operator

Classes

Class	Description
MonitorSource	Monitors an Iceberg table for changes
SingleThreadedIteratorSource<T>	Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.