FileScanTask[] tasks
int[] fromProjectionPos
InputFile file
java.lang.String manifestPath
java.lang.Long length
int specId
ManifestContent content
long sequenceNumber
long minSequenceNumber
java.lang.Long snapshotId
java.lang.Integer addedFilesCount
java.lang.Integer existingFilesCount
java.lang.Integer deletedFilesCount
java.lang.Long addedRowsCount
java.lang.Long existingRowsCount
java.lang.Long deletedRowsCount
java.util.List<E> partitions
int[] fromProjectionPos
boolean containsNull
byte[] lowerBound
byte[] upperBound
java.lang.String partition
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
- On serialization errorjava.lang.ClassNotFoundException
- If the class is not foundprivate void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
java.io.IOException
- On serialization errorjava.lang.Long rowCount
java.util.Map<K,V> columnSizes
java.util.Map<K,V> valueCounts
java.util.Map<K,V> nullValueCounts
java.util.Map<K,V> lowerBounds
java.util.Map<K,V> upperBounds
java.util.Map<K,V> columnModes
MetricsModes.MetricsMode defaultMode
int length
Schema schema
int specId
PartitionField[] fields
int lastAssignedFieldId
Types.StructType struct
Transform<S,T> transform
int sourceId
SortDirection direction
NullOrder nullOrder
java.lang.String metadataFileLocation
int formatVersion
java.lang.String uuid
java.lang.String location
long lastSequenceNumber
long lastUpdatedMillis
int lastColumnId
Schema schema
int defaultSpecId
java.util.List<E> specs
int defaultSortOrderId
java.util.List<E> sortOrders
java.util.Map<K,V> properties
long currentSnapshotId
java.util.List<E> snapshots
java.util.Map<K,V> snapshotsById
java.util.Map<K,V> specsById
java.util.Map<K,V> sortOrdersById
java.util.List<E> snapshotLog
java.util.List<E> previousFiles
long timestampMillis
long snapshotId
Expression left
Expression right
Types.NestedField field
Accessor<T> accessor
java.util.Set<E> literalSet
BoundReference<T> ref
Transform<S,T> transform
Expression expr
java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
java.lang.String name
Expression child
Expression left
Expression right
Expression.Operation op
Term term
PartitionSpec spec
Expression expr
boolean caseSensitive
java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
java.util.List<E> literals
NamedReference<T> ref
Transform<S,T> transform
java.lang.String catalogName
SerializableConfiguration hadoopConf
java.lang.String warehouseLocation
java.lang.String catalogName
SerializableConfiguration hadoopConf
java.lang.String uri
java.lang.String warehouse
int clientPoolSize
CatalogLoader catalogLoader
java.lang.String identifier
java.lang.String location
SerializableConfiguration hadoopConf
Schema schema
org.apache.flink.table.types.logical.RowType flinkSchema
PartitionSpec spec
LocationProvider locations
FileIO io
EncryptionManager encryptionManager
long targetFileSizeBytes
FileFormat format
FileAppenderFactory<T> appenderFactory
Schema schema
org.apache.flink.table.types.logical.RowType flinkSchema
java.util.Map<K,V> props
TableLoader tableLoader
Schema tableSchema
FileIO io
EncryptionManager encryption
org.apache.iceberg.flink.source.ScanContext context
int splitNumber
CombinedScanTask task
SerializableSupplier<T> hadoopConf
private void readObject(java.io.ObjectInputStream in) throws java.lang.ClassNotFoundException, java.io.IOException
java.lang.ClassNotFoundException
java.io.IOException
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
java.io.IOException
java.util.Set<E> names
java.lang.Integer id
MappedFields nestedMapping
java.util.List<E> fields
MappedFields mapping
java.util.Map<K,V> values
java.lang.String uri
java.lang.String format
Schema schema
PartitionSpec spec
java.util.Map<K,V> properties
FileFormat format
org.apache.spark.broadcast.Broadcast<T> io
org.apache.spark.broadcast.Broadcast<T> encryptionManager
LocationProvider locations
java.lang.String nameMapping
boolean caseSensitive
DataFile[] taskFiles
Type sourceType
java.lang.String transform
java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
int scale
int precision
int length
Types.NestedField elementField
Types.NestedField keyField
Types.NestedField valueField
boolean isOptional
int id
java.lang.String name
Type type
java.lang.String doc
Types.NestedField[] fields
boolean adjustToUTC
java.util.Set<E> wrapperSet
java.lang.CharSequence wrapped
org.apache.avro.Schema schema
java.lang.Object first
java.lang.Object second