Package org.apache.iceberg.flink.source
package org.apache.iceberg.flink.source
-
ClassDescriptionDataIterator<T>Flink data iterator that reads
CombinedScanTaskinto aCloseableIteratorRead aFileScanTaskinto aCloseableIteratorFlinkInputFormatfor Iceberg.Source builder to buildDataStream.Flink Iceberg table source.This is not serializable because AvroSchemais not actually serializable, even though it implementsSerializableinterface.Context object with optional arguments for a Flink Scan.This is the single (non-parallel) monitoring task which takes aFlinkInputFormat, it is responsible for: Monitoring snapshots of the Iceberg table.The operator that reads thesplitsreceived from the precedingStreamingMonitorFunction.Starting strategy for streaming execution.