A B C D E F G H I J K L M N O P Q R S T U V W Y _ 
All Classes All Packages

A

abort() - Method in class org.apache.iceberg.io.BaseTaskWriter
 
abort() - Method in interface org.apache.iceberg.io.TaskWriter
Close the writer and delete the completed files if possible when aborting.
abortFileGroup(RewriteFileGroup) - Method in class org.apache.iceberg.actions.RewriteDataFilesCommitManager
Clean up a specified file set by removing any files created for that operation, should not throw any exceptions
abortJob(JobContext, int) - Method in class org.apache.iceberg.mr.hive.HiveIcebergOutputCommitter
Removes the generated data files if there is a commit file already generated for them.
abortStagedChanges() - Method in class org.apache.iceberg.spark.RollbackStagedTable
 
abortStagedChanges() - Method in class org.apache.iceberg.spark.source.StagedSparkTable
 
abortTask(TaskAttemptContext) - Method in class org.apache.iceberg.mr.hive.HiveIcebergOutputCommitter
Removes files generated by this task.
abortWith(Tasks.Task<I, ?>) - Method in class org.apache.iceberg.util.Tasks.Builder
 
AbstractMapredIcebergRecordReader<T> - Class in org.apache.iceberg.mr.mapred
 
AbstractMapredIcebergRecordReader(IcebergInputFormat<?>, IcebergSplit, JobConf, Reporter) - Constructor for class org.apache.iceberg.mr.mapred.AbstractMapredIcebergRecordReader
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ApplyTransformContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigDecimalLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigIntLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanValueContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DecimalLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DoubleLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExponentLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FieldListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FloatLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IdentityTransformContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IntegerLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.MultipartIdentifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NamedArgumentContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NumericLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.PositionalArgumentContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SingleStatementContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SmallIntLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringMapContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TinyIntLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TransformArgumentContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TypeConstructorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.UnquotedIdentifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteDistributionSpecContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteOrderingSpecContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteSpecContext
 
accept(Path) - Method in class org.apache.iceberg.hadoop.HiddenPathFilter
 
accessKeyId() - Method in class org.apache.iceberg.aliyun.AliyunProperties
 
accessKeySecret() - Method in class org.apache.iceberg.aliyun.AliyunProperties
 
accessor() - Method in class org.apache.iceberg.expressions.BoundReference
 
accessor() - Method in class org.apache.iceberg.spark.data.vectorized.IcebergArrowColumnVector
 
Accessor<T> - Interface in org.apache.iceberg
 
accessorForField(int) - Method in class org.apache.iceberg.Schema
Returns an accessor for retrieving the data from StructLike.
Accessors - Class in org.apache.iceberg
Position2Accessor and Position3Accessor here is an optimization.
acquire(String, String) - Method in interface org.apache.iceberg.LockManager
Try to acquire a lock
acquireIntervalMs() - Method in class org.apache.iceberg.util.LockManagers.BaseLockManager
 
acquireTimeoutMs() - Method in class org.apache.iceberg.util.LockManagers.BaseLockManager
 
Action<ThisT,​R> - Interface in org.apache.iceberg.actions
An action performed on a table.
Actions - Class in org.apache.iceberg.flink.actions
 
ActionsProvider - Interface in org.apache.iceberg.actions
An API that should be implemented by query engine integrations for providing actions.
add(int, StructLike) - Method in class org.apache.iceberg.util.PartitionSet
 
add(D) - Method in interface org.apache.iceberg.io.FileAppender
 
add(D) - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter
Deprecated.
 
add(F) - Method in class org.apache.iceberg.ManifestWriter
Add an added entry for a file.
add(F, long) - Method in class org.apache.iceberg.ManifestWriter
Add an added entry for a file with a specific sequence number.
add(CharSequence) - Method in class org.apache.iceberg.util.CharSequenceSet
 
add(WriteResult) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
add(StructLike) - Method in class org.apache.iceberg.util.StructLikeSet
 
add(Pair<Integer, StructLike>) - Method in class org.apache.iceberg.util.PartitionSet
 
add(T) - Method in class org.apache.iceberg.io.DataWriter
Deprecated.
since 0.13.0, will be removed in 0.14.0; use DataWriter.write(Object) instead.
add(T[], T) - Static method in class org.apache.iceberg.util.ArrayUtil
Copies the given array and adds the given element at the end of the new array.
ADD - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
ADD - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
ADD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
ADD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
addAll(Iterable<D>) - Method in interface org.apache.iceberg.io.FileAppender
 
addAll(Iterable<WriteResult>) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addAll(Collection<? extends CharSequence>) - Method in class org.apache.iceberg.util.CharSequenceSet
 
addAll(Collection<? extends StructLike>) - Method in class org.apache.iceberg.util.StructLikeSet
 
addAll(Collection<? extends Pair<Integer, StructLike>>) - Method in class org.apache.iceberg.util.PartitionSet
 
addAll(Iterator<D>) - Method in interface org.apache.iceberg.io.FileAppender
 
addCloseable(Closeable) - Method in class org.apache.iceberg.io.CloseableGroup
Register a closeable to be managed by this class.
addCloseable(AutoCloseable) - Method in class org.apache.iceberg.io.CloseableGroup
Register an autocloseables to be managed by this class.
addColumn(String, String, Type) - Method in interface org.apache.iceberg.UpdateSchema
Add a new column to a nested struct.
addColumn(String, String, Type, String) - Method in interface org.apache.iceberg.UpdateSchema
Add a new column to a nested struct.
addColumn(String, Type) - Method in interface org.apache.iceberg.UpdateSchema
Add a new top-level column.
addColumn(String, Type, String) - Method in interface org.apache.iceberg.UpdateSchema
Add a new top-level column.
addDataFiles(Iterable<DataFile>) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addDataFiles(DataFile...) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addDeleteFiles(Iterable<DeleteFile>) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addDeleteFiles(DeleteFile...) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addDeletes(DeleteFile) - Method in interface org.apache.iceberg.RowDelta
Add a DeleteFile to the table.
ADDED_DELETE_FILES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_EQ_DELETES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_FILE_SIZE_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_FILES_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
ADDED_FILES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_POS_DELETES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_RECORDS_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
ADDED_ROWS_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
addedDataFiles() - Method in class org.apache.iceberg.actions.RewriteDataFilesActionResult
 
addedDataFilesCount() - Method in class org.apache.iceberg.actions.BaseFileGroupRewriteResult
 
addedDataFilesCount() - Method in interface org.apache.iceberg.actions.RewriteDataFiles.FileGroupRewriteResult
 
addedDataFilesCount() - Method in interface org.apache.iceberg.actions.RewriteDataFiles.Result
 
addedDeleteFilesCount() - Method in interface org.apache.iceberg.actions.RewritePositionDeleteFiles.Result
Returns the count of the added delete files.
addedFile(PartitionSpec, DataFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
addedFile(PartitionSpec, DeleteFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
addedFiles() - Method in class org.apache.iceberg.actions.RewriteFileGroup
 
addedFiles() - Method in interface org.apache.iceberg.Snapshot
Return all files added to the table in this snapshot.
addedFilesCount() - Method in class org.apache.iceberg.GenericManifestFile
 
addedFilesCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the number of data files with status ADDED in the manifest file.
addedFilesCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
addedManifest(ManifestFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
addedManifests() - Method in class org.apache.iceberg.actions.BaseRewriteManifestsActionResult
 
addedManifests() - Method in interface org.apache.iceberg.actions.RewriteManifests.Result
Returns added manifests.
addedPositionDeleteFilesCount() - Method in interface org.apache.iceberg.actions.ConvertEqualityDeleteFiles.Result
Returns the count of the added position delete files.
addedRowsCount() - Method in class org.apache.iceberg.GenericManifestFile
 
addedRowsCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the total number of rows in all data files with status ADDED in the manifest file.
addedRowsCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
addElement(I, E) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader
 
addElement(List<E>, E) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader
 
addExtension(String) - Method in enum org.apache.iceberg.FileFormat
Returns filename with this format's extension added, if necessary.
addFallbackIds(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil
 
addField(String) - Method in interface org.apache.iceberg.UpdatePartitionSpec
Add a new partition field from a source column.
addField(String, Term) - Method in interface org.apache.iceberg.UpdatePartitionSpec
Add a new partition field from an expression term, with the given partition field name.
addField(Term) - Method in interface org.apache.iceberg.UpdatePartitionSpec
Add a new partition field from an expression term.
addFile(DataFile) - Method in class org.apache.iceberg.BaseOverwriteFiles
 
addFile(DataFile) - Method in class org.apache.iceberg.BaseReplacePartitions
 
addFile(DataFile) - Method in interface org.apache.iceberg.OverwriteFiles
Add a DataFile to the table.
addFile(DataFile) - Method in interface org.apache.iceberg.ReplacePartitions
Add a DataFile to the table.
addManifest(ManifestFile) - Method in class org.apache.iceberg.BaseRewriteManifests
 
addManifest(ManifestFile) - Method in interface org.apache.iceberg.RewriteManifests
Adds a manifest file to the table.
addPair(I, K, V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader
 
addPair(Map<K, V>, K, V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader
 
AddPartitionFieldContext(IcebergSqlExtensionsParser.StatementContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
addPartitionSpec(PartitionSpec) - Method in class org.apache.iceberg.TableMetadata.Builder
 
AddPartitionSpec(PartitionSpec) - Constructor for class org.apache.iceberg.MetadataUpdate.AddPartitionSpec
 
addReferencedDataFiles(CharSequence...) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addReferencedDataFiles(Iterable<CharSequence>) - Method in class org.apache.iceberg.io.WriteResult.Builder
 
addRequiredColumn(String, String, Type) - Method in interface org.apache.iceberg.UpdateSchema
Add a new required top-level column.
addRequiredColumn(String, String, Type, String) - Method in interface org.apache.iceberg.UpdateSchema
Add a new required top-level column.
addRequiredColumn(String, Type) - Method in interface org.apache.iceberg.UpdateSchema
Add a new required top-level column.
addRequiredColumn(String, Type, String) - Method in interface org.apache.iceberg.UpdateSchema
Add a new required top-level column.
addResult(DataWriteResult) - Method in class org.apache.iceberg.io.ClusteredDataWriter
 
addResult(DataWriteResult) - Method in class org.apache.iceberg.io.FanoutDataWriter
 
addResult(DataWriteResult) - Method in class org.apache.iceberg.io.RollingDataWriter
 
addResult(DeleteWriteResult) - Method in class org.apache.iceberg.io.ClusteredEqualityDeleteWriter
 
addResult(DeleteWriteResult) - Method in class org.apache.iceberg.io.ClusteredPositionDeleteWriter
 
addResult(DeleteWriteResult) - Method in class org.apache.iceberg.io.RollingEqualityDeleteWriter
 
addResult(DeleteWriteResult) - Method in class org.apache.iceberg.io.RollingPositionDeleteWriter
 
addRows(DataFile) - Method in interface org.apache.iceberg.RowDelta
Add a DataFile to the table.
addSchema(Schema) - Method in class org.apache.iceberg.data.avro.IcebergDecoder
Adds an Iceberg schema that can be used to decode buffers.
addSchema(Schema, int) - Method in class org.apache.iceberg.TableMetadata.Builder
 
AddSchema(Schema, int) - Constructor for class org.apache.iceberg.MetadataUpdate.AddSchema
 
addSnapshot(Snapshot) - Method in class org.apache.iceberg.TableMetadata.Builder
 
AddSnapshot(Snapshot) - Constructor for class org.apache.iceberg.MetadataUpdate.AddSnapshot
 
addSortOrder(SortOrder) - Method in class org.apache.iceberg.TableMetadata.Builder
 
AddSortOrder(SortOrder) - Constructor for class org.apache.iceberg.MetadataUpdate.AddSortOrder
 
addStagedSnapshot(Snapshot) - Method in class org.apache.iceberg.TableMetadata
 
addValue(double) - Method in class org.apache.iceberg.DoubleFieldMetrics.Builder
 
addValue(float) - Method in class org.apache.iceberg.FloatFieldMetrics.Builder
 
ADJUST_TO_UTC_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil
 
advance() - Method in class org.apache.iceberg.parquet.BaseColumnIterator
 
advanceNextPageCount - Variable in class org.apache.iceberg.parquet.BaseColumnIterator
 
after(long) - Method in class org.apache.iceberg.ScanSummary.Builder
 
after(String) - Method in class org.apache.iceberg.ScanSummary.Builder
 
afterElementField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
afterElementField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
afterField(String, TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
afterField(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
afterField(Types.NestedField) - Method in class org.apache.iceberg.types.IndexParents
 
afterField(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
afterField(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
afterField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
afterKeyField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
afterKeyField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
afterListElement(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
afterListElement(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
afterListElement(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
afterMapKey(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
afterMapKey(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
afterMapKey(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
afterMapValue(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
afterMapValue(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
afterMapValue(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
afterRepeatedElement(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
afterRepeatedKeyValue(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
afterValueField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
afterValueField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
aggregatedResult() - Method in class org.apache.iceberg.io.ClusteredDataWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.ClusteredEqualityDeleteWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.ClusteredPositionDeleteWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.FanoutDataWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.RollingDataWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.RollingEqualityDeleteWriter
 
aggregatedResult() - Method in class org.apache.iceberg.io.RollingPositionDeleteWriter
 
aliasToId(String) - Method in class org.apache.iceberg.Schema
Returns the column id for the given column alias.
AliyunClientFactories - Class in org.apache.iceberg.aliyun
 
AliyunClientFactory - Interface in org.apache.iceberg.aliyun
 
aliyunProperties() - Method in interface org.apache.iceberg.aliyun.AliyunClientFactory
Returns an initialized AliyunProperties
AliyunProperties - Class in org.apache.iceberg.aliyun
 
AliyunProperties() - Constructor for class org.apache.iceberg.aliyun.AliyunProperties
 
AliyunProperties(Map<String, String>) - Constructor for class org.apache.iceberg.aliyun.AliyunProperties
 
ALL_DATA_FILES - org.apache.iceberg.MetadataTableType
 
ALL_ENTRIES - org.apache.iceberg.MetadataTableType
 
ALL_MANIFESTS - org.apache.iceberg.MetadataTableType
 
AllDataFilesTable - Class in org.apache.iceberg
A Table implementation that exposes a table's valid data files as rows.
AllDataFilesTable.AllDataFilesTableScan - Class in org.apache.iceberg
 
AllEntriesTable - Class in org.apache.iceberg
A Table implementation that exposes a table's manifest entries as rows, for both delete and data files.
allManifests() - Method in interface org.apache.iceberg.Snapshot
Return all ManifestFile instances for either data or delete manifests in this snapshot.
AllManifestsTable - Class in org.apache.iceberg
A Table implementation that exposes a table's valid manifest files as rows.
AllManifestsTable.AllManifestsTableScan - Class in org.apache.iceberg
 
allowIncompatibleChanges() - Method in interface org.apache.iceberg.UpdateSchema
Allow incompatible changes to the schema.
AlreadyExistsException - Exception in org.apache.iceberg.exceptions
Exception raised when attempting to create a table that already exists.
AlreadyExistsException(String, Object...) - Constructor for exception org.apache.iceberg.exceptions.AlreadyExistsException
 
AlreadyExistsException(Throwable, String, Object...) - Constructor for exception org.apache.iceberg.exceptions.AlreadyExistsException
 
ALTER - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
ALTER - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
ALTER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext
 
alterDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterNamespace(String[], NamespaceChange...) - Method in class org.apache.iceberg.spark.SparkCatalog
 
alterNamespace(String[], NamespaceChange...) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterTable(Identifier, TableChange...) - Method in class org.apache.iceberg.spark.SparkCatalog
 
alterTable(Identifier, TableChange...) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
alwaysFalse() - Static method in class org.apache.iceberg.expressions.Expressions
 
alwaysFalse() - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor
 
alwaysNull() - Static method in class org.apache.iceberg.transforms.Transforms
Returns a Transform that always produces null.
alwaysNull(int, String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor
 
alwaysNull(String) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
alwaysNull(String, String) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
alwaysTrue() - Static method in class org.apache.iceberg.expressions.Expressions
 
alwaysTrue() - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor
 
ancestorIds(Snapshot, Function<Long, Snapshot>) - Static method in class org.apache.iceberg.util.SnapshotUtil
 
ancestorIdsBetween(long, Long, Function<Long, Snapshot>) - Static method in class org.apache.iceberg.util.SnapshotUtil
 
ancestorsBetween(long, Long, Function<Long, Snapshot>) - Static method in class org.apache.iceberg.util.SnapshotUtil
 
ancestorsOf(long, Function<Long, Snapshot>) - Static method in class org.apache.iceberg.util.SnapshotUtil
 
AncestorsOfProcedure - Class in org.apache.iceberg.spark.procedures
 
and(Expression, Expression) - Static method in class org.apache.iceberg.expressions.Expressions
 
and(Expression, Expression, Expression...) - Static method in class org.apache.iceberg.expressions.Expressions
 
and(R, R) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor
 
And - Class in org.apache.iceberg.expressions
 
AND - org.apache.iceberg.expressions.Expression.Operation
 
ANYWHERE - Static variable in class org.apache.iceberg.mr.mapreduce.IcebergSplit
 
APP_ID - Static variable in class org.apache.iceberg.CatalogProperties
 
append() - Method in class org.apache.iceberg.flink.sink.FlinkSink.Builder
Append the iceberg sink operators to write records to iceberg table.
APPEND - Static variable in class org.apache.iceberg.DataOperations
New data is appended to the table and no data is removed or deleted.
appendFile(DataFile) - Method in interface org.apache.iceberg.AppendFiles
Append a DataFile to the table.
AppendFiles - Interface in org.apache.iceberg
API for appending new files in a table.
appendManifest(ManifestFile) - Method in interface org.apache.iceberg.AppendFiles
Append a ManifestFile to the table.
appendsAfter(long) - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder
 
appendsAfter(long) - Method in class org.apache.iceberg.DataFilesTable.FilesTableScan
 
appendsAfter(long) - Method in class org.apache.iceberg.DataTableScan
 
appendsAfter(long) - Method in interface org.apache.iceberg.TableScan
Create a new TableScan to read appended data from fromSnapshotId exclusive to the current snapshot inclusive.
appendsBetween(long, long) - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder
 
appendsBetween(long, long) - Method in class org.apache.iceberg.DataFilesTable.FilesTableScan
 
appendsBetween(long, long) - Method in class org.apache.iceberg.DataTableScan
 
appendsBetween(long, long) - Method in interface org.apache.iceberg.TableScan
Create a new TableScan to read appended data from fromSnapshotId exclusive to toSnapshotId inclusive.
apply() - Method in class org.apache.iceberg.BaseReplaceSortOrder
 
apply() - Method in interface org.apache.iceberg.PendingUpdate
Apply the pending changes and return the uncommitted changes for validation.
apply() - Method in class org.apache.iceberg.SetLocation
 
apply() - Method in class org.apache.iceberg.SnapshotManager
 
apply(TableMetadata) - Method in class org.apache.iceberg.BaseReplacePartitions
 
apply(TableMetadata) - Method in class org.apache.iceberg.BaseRewriteManifests
 
apply(S) - Method in interface org.apache.iceberg.transforms.Transform
Transforms a value to its corresponding partition value.
apply(S) - Method in class org.apache.iceberg.transforms.UnknownTransform
 
applyFilters(List<ResolvedExpression>) - Method in class org.apache.iceberg.flink.IcebergTableSource
 
applyLimit(long) - Method in class org.apache.iceberg.flink.IcebergTableSource
 
applyNameMapping(MessageType, NameMapping) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil
 
applyOverwrite(boolean) - Method in class org.apache.iceberg.flink.IcebergTableSink
 
applyProjection(int[][]) - Method in class org.apache.iceberg.flink.IcebergTableSource
 
applyPropertyChanges(UpdateProperties, List<TableChange>) - Static method in class org.apache.iceberg.spark.Spark3Util
Applies a list of Spark table changes to an UpdateProperties operation.
applySchemaChanges(UpdateSchema, List<TableChange>) - Static method in class org.apache.iceberg.spark.Spark3Util
Applies a list of Spark table changes to an UpdateSchema operation.
applyStaticPartition(Map<String, String>) - Method in class org.apache.iceberg.flink.IcebergTableSink
 
ApplyTransformContext(IcebergSqlExtensionsParser.TransformContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ApplyTransformContext
 
arguments - Variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ApplyTransformContext
 
array(Schema, Schema) - Method in class org.apache.iceberg.avro.RemoveIds
 
array(Schema, T) - Method in class org.apache.iceberg.avro.AvroSchemaVisitor
 
array(ValueReader<T>) - Static method in class org.apache.iceberg.avro.ValueReaders
 
array(ValueWriter<T>) - Static method in class org.apache.iceberg.avro.ValueWriters
 
array(OrcValueReader<?>) - Static method in class org.apache.iceberg.data.orc.GenericOrcReaders
 
array(Types.ListType, Schema, T) - Method in class org.apache.iceberg.avro.AvroSchemaWithTypeVisitor
 
array(P, Schema, T) - Method in class org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor
 
arrayElementType(LogicalType) - Method in class org.apache.iceberg.flink.data.AvroWithFlinkSchemaVisitor
 
arrayElementType(DataType) - Method in class org.apache.iceberg.spark.data.AvroWithSparkSchemaVisitor
 
arrayElementType(P) - Method in class org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor
 
arrayMap(ValueReader<K>, ValueReader<V>) - Static method in class org.apache.iceberg.avro.ValueReaders
 
arrayMap(ValueWriter<K>, ValueWriter<V>) - Static method in class org.apache.iceberg.avro.ValueWriters
 
ArrayUtil - Class in org.apache.iceberg.util
 
ArrowAllocation - Class in org.apache.iceberg.arrow
 
ArrowReader - Class in org.apache.iceberg.arrow.vectorized
Vectorized reader that returns an iterator of ColumnarBatch.
ArrowReader(TableScan, int, boolean) - Constructor for class org.apache.iceberg.arrow.vectorized.ArrowReader
Create a new instance of the reader.
ArrowSchemaUtil - Class in org.apache.iceberg.arrow
 
ArrowVectorAccessor<DecimalT,​Utf8StringT,​ArrayT,​ChildVectorT extends java.lang.AutoCloseable> - Class in org.apache.iceberg.arrow.vectorized
 
ArrowVectorAccessor(ValueVector) - Constructor for class org.apache.iceberg.arrow.vectorized.ArrowVectorAccessor
 
ArrowVectorAccessor(ValueVector, ChildVectorT[]) - Constructor for class org.apache.iceberg.arrow.vectorized.ArrowVectorAccessor
 
ArrowVectorAccessors - Class in org.apache.iceberg.spark.data.vectorized
 
as(String) - Method in interface org.apache.iceberg.actions.SnapshotTable
Sets the table identifier for the newly created Iceberg table.
as(String) - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
AS - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
AS - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
AS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
AS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
AS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
AS_OF_TIMESTAMP - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
AS_OF_TIMESTAMP - Static variable in class org.apache.iceberg.spark.SparkReadOptions
 
asc(String) - Method in interface org.apache.iceberg.SortOrderBuilder
Add a field to the sort by field name, ascending with nulls first.
asc(String, NullOrder) - Method in interface org.apache.iceberg.SortOrderBuilder
Add a field to the sort by field name, ascending with the given null order.
asc(Term) - Method in interface org.apache.iceberg.SortOrderBuilder
Add an expression term to the sort, ascending with nulls first.
asc(Term, NullOrder) - Method in class org.apache.iceberg.BaseReplaceSortOrder
 
asc(Term, NullOrder) - Method in class org.apache.iceberg.SortOrder.Builder
Add an expression term to the sort, ascending with the given null order.
asc(Term, NullOrder) - Method in interface org.apache.iceberg.SortOrderBuilder
Add an expression term to the sort, ascending with the given null order.
ASC - org.apache.iceberg.SortDirection
 
ASC - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
ASC - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
ASC() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
ASC() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
asCombinedScanTask() - Method in interface org.apache.iceberg.CombinedScanTask
 
asCombinedScanTask() - Method in interface org.apache.iceberg.ScanTask
Returns this cast to CombinedScanTask if it is one
asDataTask() - Method in interface org.apache.iceberg.DataTask
 
asDataTask() - Method in interface org.apache.iceberg.ScanTask
Returns this cast to DataTask if it is one
asFileScanTask() - Method in interface org.apache.iceberg.FileScanTask
 
asFileScanTask() - Method in interface org.apache.iceberg.ScanTask
Returns this cast to FileScanTask if it is one
asListType() - Method in interface org.apache.iceberg.types.Type
 
asListType() - Method in class org.apache.iceberg.types.Types.ListType
 
asLiteralPredicate() - Method in class org.apache.iceberg.expressions.BoundLiteralPredicate
 
asLiteralPredicate() - Method in class org.apache.iceberg.expressions.BoundPredicate
 
asMappedFields() - Method in class org.apache.iceberg.mapping.NameMapping
 
asMapType() - Method in interface org.apache.iceberg.types.Type
 
asMapType() - Method in class org.apache.iceberg.types.Types.MapType
 
asNestedType() - Method in interface org.apache.iceberg.types.Type
 
asNestedType() - Method in class org.apache.iceberg.types.Type.NestedType
 
asOfTime(long) - Method in class org.apache.iceberg.AllDataFilesTable.AllDataFilesTableScan
 
asOfTime(long) - Method in class org.apache.iceberg.AllManifestsTable.AllManifestsTableScan
 
asOfTime(long) - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder
 
asOfTime(long) - Method in class org.apache.iceberg.FindFiles.Builder
Base results on files in the snapshot that was current as of a timestamp.
asOfTime(long) - Method in class org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
 
asOfTime(long) - Method in interface org.apache.iceberg.TableScan
Create a new TableScan from this scan's configuration that will use the most recent snapshot as of the given time in milliseconds.
asOfTimestamp() - Method in class org.apache.iceberg.spark.SparkReadConf
 
asOfTimestamp(Long) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
asOptional() - Method in class org.apache.iceberg.types.Types.NestedField
 
asPrimitiveType() - Method in interface org.apache.iceberg.types.Type
 
asPrimitiveType() - Method in class org.apache.iceberg.types.Type.PrimitiveType
 
asRequired() - Method in class org.apache.iceberg.types.Types.NestedField
 
asResult() - Method in class org.apache.iceberg.actions.RewriteFileGroup
 
asSetPredicate() - Method in class org.apache.iceberg.expressions.BoundPredicate
 
asSetPredicate() - Method in class org.apache.iceberg.expressions.BoundSetPredicate
 
assignFreshIds(int, Schema, TypeUtil.NextID) - Static method in class org.apache.iceberg.types.TypeUtil
Assigns fresh ids from the nextId function for all fields in a schema.
assignFreshIds(Schema, Schema, TypeUtil.NextID) - Static method in class org.apache.iceberg.types.TypeUtil
Assigns ids to match a given schema, and fresh ids from the nextId function for all other fields.
assignFreshIds(Schema, TypeUtil.NextID) - Static method in class org.apache.iceberg.types.TypeUtil
Assigns fresh ids from the nextId function for all fields in a schema.
assignFreshIds(Type, TypeUtil.NextID) - Static method in class org.apache.iceberg.types.TypeUtil
Assigns fresh ids from the nextId function for all fields in a type.
assignIncreasingFreshIds(Schema) - Static method in class org.apache.iceberg.types.TypeUtil
Assigns strictly increasing fresh ids for all fields in a schema, starting from 1.
assignUUID() - Method in class org.apache.iceberg.TableMetadata.Builder
 
AssignUUID(String) - Constructor for class org.apache.iceberg.MetadataUpdate.AssignUUID
 
asStatic() - Method in class org.apache.iceberg.common.DynFields.UnboundField
Returns this field as a StaticField.
asStatic() - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod
Returns this method as a StaticMethod.
asStruct() - Method in class org.apache.iceberg.Schema
Returns the underlying struct type for this schema.
asStructLike(Record) - Method in class org.apache.iceberg.data.GenericDeleteFilter
 
asStructLike(T) - Method in class org.apache.iceberg.data.DeleteFilter
 
asStructLike(T) - Method in class org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter
Wrap the data as a StructLike.
asStructType() - Method in interface org.apache.iceberg.types.Type
 
asStructType() - Method in class org.apache.iceberg.types.Types.StructType
 
AssumeRoleAwsClientFactory - Class in org.apache.iceberg.aws
 
AssumeRoleAwsClientFactory() - Constructor for class org.apache.iceberg.aws.AssumeRoleAwsClientFactory
 
asSummaryString() - Method in class org.apache.iceberg.flink.IcebergTableSink
 
asSummaryString() - Method in class org.apache.iceberg.flink.IcebergTableSource
 
asUnaryPredicate() - Method in class org.apache.iceberg.expressions.BoundPredicate
 
asUnaryPredicate() - Method in class org.apache.iceberg.expressions.BoundUnaryPredicate
 
Avro - Class in org.apache.iceberg.avro
 
AVRO - org.apache.iceberg.FileFormat
 
AVRO_COMPRESSION - Static variable in class org.apache.iceberg.TableProperties
 
AVRO_COMPRESSION_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
Avro.DataWriteBuilder - Class in org.apache.iceberg.avro
 
Avro.DeleteWriteBuilder - Class in org.apache.iceberg.avro
 
Avro.ReadBuilder - Class in org.apache.iceberg.avro
 
Avro.WriteBuilder - Class in org.apache.iceberg.avro
 
AvroEncoderUtil - Class in org.apache.iceberg.avro
 
AvroIterable<D> - Class in org.apache.iceberg.avro
 
AvroMetrics - Class in org.apache.iceberg.avro
 
AvroSchemaUtil - Class in org.apache.iceberg.avro
 
AvroSchemaVisitor<T> - Class in org.apache.iceberg.avro
 
AvroSchemaVisitor() - Constructor for class org.apache.iceberg.avro.AvroSchemaVisitor
 
AvroSchemaWithTypeVisitor<T> - Class in org.apache.iceberg.avro
 
AvroSchemaWithTypeVisitor() - Constructor for class org.apache.iceberg.avro.AvroSchemaWithTypeVisitor
 
AvroWithFlinkSchemaVisitor<T> - Class in org.apache.iceberg.flink.data
 
AvroWithFlinkSchemaVisitor() - Constructor for class org.apache.iceberg.flink.data.AvroWithFlinkSchemaVisitor
 
AvroWithPartnerByStructureVisitor<P,​T> - Class in org.apache.iceberg.avro
A abstract avro schema visitor with partner type.
AvroWithPartnerByStructureVisitor() - Constructor for class org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor
 
AvroWithSparkSchemaVisitor<T> - Class in org.apache.iceberg.spark.data
 
AvroWithSparkSchemaVisitor() - Constructor for class org.apache.iceberg.spark.data.AvroWithSparkSchemaVisitor
 
AwsClientFactories - Class in org.apache.iceberg.aws
 
AwsClientFactory - Interface in org.apache.iceberg.aws
Interface to customize AWS clients used by Iceberg.
AwsProperties - Class in org.apache.iceberg.aws
 
AwsProperties() - Constructor for class org.apache.iceberg.aws.AwsProperties
 
AwsProperties(Map<String, String>) - Constructor for class org.apache.iceberg.aws.AwsProperties
 

B

BACKQUOTED_IDENTIFIER - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
BACKQUOTED_IDENTIFIER - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
BACKQUOTED_IDENTIFIER() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierContext
 
BASE_NAMESPACE - Static variable in class org.apache.iceberg.flink.FlinkCatalogFactory
 
BaseBatchReader<T> - Class in org.apache.iceberg.arrow.vectorized
A base BatchReader class that contains common functionality
BaseBatchReader(List<VectorizedReader<?>>) - Constructor for class org.apache.iceberg.arrow.vectorized.BaseBatchReader
 
BaseColumnIterator - Class in org.apache.iceberg.parquet
 
BaseColumnIterator(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.BaseColumnIterator
 
BaseCombinedScanTask - Class in org.apache.iceberg
 
BaseCombinedScanTask(List<FileScanTask>) - Constructor for class org.apache.iceberg.BaseCombinedScanTask
 
BaseCombinedScanTask(FileScanTask...) - Constructor for class org.apache.iceberg.BaseCombinedScanTask
 
BaseDeleteOrphanFilesActionResult - Class in org.apache.iceberg.actions
 
BaseDeleteOrphanFilesActionResult(Iterable<String>) - Constructor for class org.apache.iceberg.actions.BaseDeleteOrphanFilesActionResult
 
BaseDeleteOrphanFilesSparkAction - Class in org.apache.iceberg.spark.actions
An action that removes orphan metadata and data files by listing a given location and comparing the actual files in that location with data and metadata files referenced by all valid snapshots.
BaseDeleteOrphanFilesSparkAction(SparkSession, Table) - Constructor for class org.apache.iceberg.spark.actions.BaseDeleteOrphanFilesSparkAction
 
BaseDeleteReachableFilesActionResult - Class in org.apache.iceberg.actions
 
BaseDeleteReachableFilesActionResult(long, long, long, long) - Constructor for class org.apache.iceberg.actions.BaseDeleteReachableFilesActionResult
 
BaseDeleteReachableFilesSparkAction - Class in org.apache.iceberg.spark.actions
An implementation of DeleteReachableFiles that uses metadata tables in Spark to determine which files should be deleted.
BaseDeleteReachableFilesSparkAction(SparkSession, String) - Constructor for class org.apache.iceberg.spark.actions.BaseDeleteReachableFilesSparkAction
 
BaseEqualityDeltaWriter(StructLike, Schema, Schema) - Constructor for class org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter
 
BaseExpireSnapshotsActionResult - Class in org.apache.iceberg.actions
 
BaseExpireSnapshotsActionResult(long, long, long) - Constructor for class org.apache.iceberg.actions.BaseExpireSnapshotsActionResult
 
BaseExpireSnapshotsSparkAction - Class in org.apache.iceberg.spark.actions
An action that performs the same operation as ExpireSnapshots but uses Spark to determine the delta in files between the pre and post-expiration table metadata.
BaseExpireSnapshotsSparkAction(SparkSession, Table) - Constructor for class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
BaseFileGroupRewriteResult - Class in org.apache.iceberg.actions
 
BaseFileGroupRewriteResult(RewriteDataFiles.FileGroupInfo, int, int) - Constructor for class org.apache.iceberg.actions.BaseFileGroupRewriteResult
 
BaseFileWriterFactory<T> - Class in org.apache.iceberg.data
A base writer factory to be extended by query engine integrations.
BaseFileWriterFactory(Table, FileFormat, Schema, SortOrder, FileFormat, int[], Schema, SortOrder, Schema) - Constructor for class org.apache.iceberg.data.BaseFileWriterFactory
 
BaseLockManager() - Constructor for class org.apache.iceberg.util.LockManagers.BaseLockManager
 
BaseMetastoreCatalog - Class in org.apache.iceberg
 
BaseMetastoreCatalog() - Constructor for class org.apache.iceberg.BaseMetastoreCatalog
 
BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder - Class in org.apache.iceberg
 
BaseMetastoreCatalogTableBuilder(TableIdentifier, Schema) - Constructor for class org.apache.iceberg.BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder
 
BaseMetastoreTableOperations - Class in org.apache.iceberg
 
BaseMetastoreTableOperations() - Constructor for class org.apache.iceberg.BaseMetastoreTableOperations
 
BaseMetastoreTableOperations.CommitStatus - Enum in org.apache.iceberg
 
BaseMigrateTableActionResult - Class in org.apache.iceberg.actions
 
BaseMigrateTableActionResult(long) - Constructor for class org.apache.iceberg.actions.BaseMigrateTableActionResult
 
BaseMigrateTableSparkAction - Class in org.apache.iceberg.spark.actions
Takes a Spark table in the source catalog and attempts to transform it into an Iceberg table in the same location with the same identifier.
BaseMigrateTableSparkAction(SparkSession, CatalogPlugin, Identifier) - Constructor for class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
BaseOverwriteFiles - Class in org.apache.iceberg
 
BaseOverwriteFiles(String, TableOperations) - Constructor for class org.apache.iceberg.BaseOverwriteFiles
 
BasePageIterator - Class in org.apache.iceberg.parquet
 
BasePageIterator(ColumnDescriptor, String) - Constructor for class org.apache.iceberg.parquet.BasePageIterator
 
BasePageIterator.IntIterator - Class in org.apache.iceberg.parquet
 
BaseParquetReaders<T> - Class in org.apache.iceberg.data.parquet
 
BaseParquetReaders() - Constructor for class org.apache.iceberg.data.parquet.BaseParquetReaders
 
BaseParquetWriter<T> - Class in org.apache.iceberg.data.parquet
 
BaseParquetWriter() - Constructor for class org.apache.iceberg.data.parquet.BaseParquetWriter
 
BasePositionDeltaWriter<T> - Class in org.apache.iceberg.io
 
BasePositionDeltaWriter(PartitioningWriter<T, DataWriteResult>, PartitioningWriter<PositionDelete<T>, DeleteWriteResult>) - Constructor for class org.apache.iceberg.io.BasePositionDeltaWriter
 
BaseReplacePartitions - Class in org.apache.iceberg
 
BaseReplaceSortOrder - Class in org.apache.iceberg
 
BaseRewriteDataFilesAction<ThisT> - Class in org.apache.iceberg.actions
 
BaseRewriteDataFilesAction(Table) - Constructor for class org.apache.iceberg.actions.BaseRewriteDataFilesAction
 
BaseRewriteDataFilesFileGroupInfo - Class in org.apache.iceberg.actions
 
BaseRewriteDataFilesFileGroupInfo(int, int, StructLike) - Constructor for class org.apache.iceberg.actions.BaseRewriteDataFilesFileGroupInfo
 
BaseRewriteDataFilesResult - Class in org.apache.iceberg.actions
 
BaseRewriteDataFilesResult(List<RewriteDataFiles.FileGroupRewriteResult>) - Constructor for class org.apache.iceberg.actions.BaseRewriteDataFilesResult
 
BaseRewriteDataFilesSpark3Action - Class in org.apache.iceberg.spark.actions
 
BaseRewriteDataFilesSpark3Action(SparkSession, Table) - Constructor for class org.apache.iceberg.spark.actions.BaseRewriteDataFilesSpark3Action
 
BaseRewriteManifests - Class in org.apache.iceberg
 
BaseRewriteManifestsActionResult - Class in org.apache.iceberg.actions
 
BaseRewriteManifestsActionResult(Iterable<ManifestFile>, Iterable<ManifestFile>) - Constructor for class org.apache.iceberg.actions.BaseRewriteManifestsActionResult
 
BaseRewriteManifestsSparkAction - Class in org.apache.iceberg.spark.actions
An action that rewrites manifests in a distributed manner and co-locates metadata for partitions.
BaseRewriteManifestsSparkAction(SparkSession, Table) - Constructor for class org.apache.iceberg.spark.actions.BaseRewriteManifestsSparkAction
 
BaseSnapshotTableActionResult - Class in org.apache.iceberg.actions
 
BaseSnapshotTableActionResult(long) - Constructor for class org.apache.iceberg.actions.BaseSnapshotTableActionResult
 
BaseSnapshotTableSparkAction - Class in org.apache.iceberg.spark.actions
Creates a new Iceberg table based on a source Spark table.
BaseSnapshotTableSparkAction(SparkSession, CatalogPlugin, Identifier, CatalogPlugin, Identifier) - Constructor for class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
BaseTable - Class in org.apache.iceberg
Base Table implementation.
BaseTable(TableOperations, String) - Constructor for class org.apache.iceberg.BaseTable
 
BaseTaskWriter<T> - Class in org.apache.iceberg.io
 
BaseTaskWriter(PartitionSpec, FileFormat, FileAppenderFactory<T>, OutputFileFactory, FileIO, long) - Constructor for class org.apache.iceberg.io.BaseTaskWriter
 
BaseTaskWriter.BaseEqualityDeltaWriter - Class in org.apache.iceberg.io
Base equality delta writer to write both insert records and equality-deletes.
BaseTaskWriter.RollingEqDeleteWriter - Class in org.apache.iceberg.io
 
BaseTaskWriter.RollingFileWriter - Class in org.apache.iceberg.io
 
BaseVectorizedParquetValuesReader - Class in org.apache.iceberg.arrow.vectorized.parquet
A values reader for Parquet's run-length encoded data that reads column data in batches instead of one value at a time.
BaseVectorizedParquetValuesReader(int, boolean) - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.BaseVectorizedParquetValuesReader
 
BaseVectorizedParquetValuesReader(int, int, boolean) - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.BaseVectorizedParquetValuesReader
 
BaseVectorizedParquetValuesReader(int, int, boolean, boolean) - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.BaseVectorizedParquetValuesReader
 
BatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.BatchReader
 
before(long) - Method in class org.apache.iceberg.ScanSummary.Builder
 
before(String) - Method in class org.apache.iceberg.ScanSummary.Builder
 
beforeElementField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
beforeElementField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
beforeField(String, TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
beforeField(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
beforeField(Types.NestedField) - Method in class org.apache.iceberg.types.IndexParents
 
beforeField(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
beforeField(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
beforeField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
beforeKeyField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
beforeKeyField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
beforeListElement(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
beforeListElement(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
beforeListElement(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
beforeMapKey(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
beforeMapKey(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
beforeMapKey(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
beforeMapValue(Types.NestedField) - Method in class org.apache.iceberg.types.IndexByName
 
beforeMapValue(Types.NestedField) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
beforeMapValue(Types.NestedField, P) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
beforeRepeatedElement(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
beforeRepeatedKeyValue(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
beforeValueField(TypeDescription) - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
beforeValueField(Type) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
BIGDECIMAL_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
BIGDECIMAL_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
BIGDECIMAL_LITERAL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigDecimalLiteralContext
 
BigDecimalLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigDecimalLiteralContext
 
BIGINT_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
BIGINT_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
BIGINT_LITERAL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigIntLiteralContext
 
BigIntLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigIntLiteralContext
 
BINARY - org.apache.iceberg.orc.ORCSchemaUtil.BinaryType
 
BINARY - org.apache.iceberg.types.Type.TypeID
 
BinaryAsDecimalReader(ColumnDescriptor, int) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.BinaryAsDecimalReader
 
BinaryType() - Constructor for class org.apache.iceberg.types.Types.BinaryType
 
BinaryUtil - Class in org.apache.iceberg.util
 
bind(Object) - Method in class org.apache.iceberg.common.DynConstructors.Ctor
 
bind(Object) - Method in class org.apache.iceberg.common.DynFields.UnboundField
Returns this method as a BoundMethod for the given receiver.
bind(Object) - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod
Returns this method as a BoundMethod for the given receiver.
bind(Types.StructType, boolean) - Method in class org.apache.iceberg.expressions.NamedReference
 
bind(Types.StructType, boolean) - Method in interface org.apache.iceberg.expressions.Unbound
Bind this value expression to concrete types.
bind(Types.StructType, boolean) - Method in class org.apache.iceberg.expressions.UnboundPredicate
Bind this UnboundPredicate.
bind(Types.StructType, boolean) - Method in class org.apache.iceberg.expressions.UnboundTransform
 
bind(Types.StructType, Expression, boolean) - Static method in class org.apache.iceberg.expressions.Binder
Replaces all unbound/named references with bound references to fields in the given struct.
Binder - Class in org.apache.iceberg.expressions
Rewrites expressions by replacing unbound named references with references to fields in a struct schema.
binPack() - Method in interface org.apache.iceberg.actions.RewriteDataFiles
Choose BINPACK as a strategy for this rewrite operation
BinPacking - Class in org.apache.iceberg.util
 
BinPacking() - Constructor for class org.apache.iceberg.util.BinPacking
 
BinPacking.ListPacker<T> - Class in org.apache.iceberg.util
 
BinPacking.PackingIterable<T> - Class in org.apache.iceberg.util
 
binPackStrategy() - Method in class org.apache.iceberg.spark.actions.BaseRewriteDataFilesSpark3Action
 
BinPackStrategy - Class in org.apache.iceberg.actions
A rewrite strategy for data files which determines which files to rewrite based on their size.
BinPackStrategy() - Constructor for class org.apache.iceberg.actions.BinPackStrategy
 
blockLocations(CombinedScanTask, Configuration) - Static method in class org.apache.iceberg.hadoop.Util
 
blockLocations(FileIO, CombinedScanTask) - Static method in class org.apache.iceberg.hadoop.Util
 
BOOLEAN - org.apache.iceberg.types.Type.TypeID
 
booleanBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
BooleanBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.BooleanBatchReader
 
BooleanLiteralContext(IcebergSqlExtensionsParser.ConstantContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanLiteralContext
 
booleans() - Static method in class org.apache.iceberg.avro.ValueReaders
 
booleans() - Static method in class org.apache.iceberg.avro.ValueWriters
 
booleans() - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
booleans() - Static method in class org.apache.iceberg.orc.OrcValueReaders
 
booleans(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
BooleanType() - Constructor for class org.apache.iceberg.types.Types.BooleanType
 
booleanValue() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanLiteralContext
 
booleanValue() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
BooleanValueContext(ParserRuleContext, int) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanValueContext
 
Bound<T> - Interface in org.apache.iceberg.expressions
Represents a bound value expression.
BoundExpressionVisitor() - Constructor for class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor
 
BoundLiteralPredicate<T> - Class in org.apache.iceberg.expressions
 
BoundPredicate<T> - Class in org.apache.iceberg.expressions
 
BoundPredicate(Expression.Operation, BoundTerm<T>) - Constructor for class org.apache.iceberg.expressions.BoundPredicate
 
BoundReference<T> - Class in org.apache.iceberg.expressions
 
boundReferences(Types.StructType, List<Expression>, boolean) - Static method in class org.apache.iceberg.expressions.Binder
 
BoundSetPredicate<T> - Class in org.apache.iceberg.expressions
 
BoundTerm<T> - Interface in org.apache.iceberg.expressions
Represents a bound term.
BoundTransform<S,​T> - Class in org.apache.iceberg.expressions
A transform expression.
BoundUnaryPredicate<T> - Class in org.apache.iceberg.expressions
 
BoundVisitor() - Constructor for class org.apache.iceberg.expressions.ExpressionVisitors.BoundVisitor
 
BRACKETED_COMMENT - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
BRACKETED_COMMENT - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
bucket() - Method in class org.apache.iceberg.aliyun.oss.OSSURI
Return OSS bucket name.
bucket(int, String, int, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor
 
bucket(String, int) - Static method in class org.apache.iceberg.expressions.Expressions
 
bucket(String, int) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
bucket(String, int, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor
 
bucket(String, int, int, SortDirection, NullOrder) - Method in interface org.apache.iceberg.transforms.SortOrderVisitor
 
bucket(String, int, String) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
bucket(Type, int) - Static method in class org.apache.iceberg.transforms.Transforms
Returns a bucket Transform for the given type and number of buckets.
buffer() - Method in interface org.apache.iceberg.encryption.EncryptionKeyMetadata
Opaque blob representing metadata about a file's encryption key.
build() - Method in class org.apache.iceberg.avro.Avro.DataWriteBuilder
 
build() - Method in class org.apache.iceberg.avro.Avro.ReadBuilder
 
build() - Method in class org.apache.iceberg.avro.Avro.WriteBuilder
 
build() - Method in class org.apache.iceberg.common.DynClasses.Builder
Returns the first implementation or throws RuntimeException if one was not found.
build() - Method in class org.apache.iceberg.common.DynConstructors.Builder
 
build() - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a UnboundField or throws a NoSuchFieldException if there is none.
build() - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a UnboundMethod or throws a RuntimeError if there is none.
build() - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder
 
build() - Method in class org.apache.iceberg.DataFiles.Builder
 
build() - Method in class org.apache.iceberg.DoubleFieldMetrics.Builder
 
build() - Method in class org.apache.iceberg.FileMetadata.Builder
 
build() - Method in class org.apache.iceberg.flink.sink.FlinkSink.Builder
Deprecated.
this will be removed in 0.14.0; use FlinkSink.Builder.append() because its returned DataStreamSink has a more correct data type.
build() - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
build() - Method in class org.apache.iceberg.FloatFieldMetrics.Builder
 
build() - Method in class org.apache.iceberg.GenericManifestFile.CopyBuilder
 
build() - Method in class org.apache.iceberg.io.OutputFileFactory.Builder
 
build() - Method in class org.apache.iceberg.io.WriteResult.Builder
 
build() - Method in class org.apache.iceberg.orc.ORC.DataWriteBuilder
 
build() - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
build() - Method in class org.apache.iceberg.orc.ORC.WriteBuilder
 
build() - Method in class org.apache.iceberg.parquet.Parquet.DataWriteBuilder
 
build() - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
build() - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder
 
build() - Method in class org.apache.iceberg.PartitionSpec.Builder
 
build() - Method in class org.apache.iceberg.ScanSummary.Builder
Summarizes a table scan as a map of partition key to metrics for that partition.
build() - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
build() - Method in class org.apache.iceberg.SortOrder.Builder
 
build() - Method in interface org.apache.iceberg.spark.procedures.SparkProcedures.ProcedureBuilder
 
build() - Method in class org.apache.iceberg.spark.source.SparkScanBuilder
 
build() - Method in class org.apache.iceberg.TableMetadata.Builder
 
build() - Method in interface org.apache.spark.sql.connector.iceberg.write.DeltaWriteBuilder
Returns a logical delta write.
build() - Method in interface org.apache.spark.sql.connector.iceberg.write.RowLevelOperationBuilder
Returns a row-level operation that controls how Spark rewrites data for DELETE, UPDATE, MERGE commands.
build(Object) - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a BoundMethod or throws a RuntimeException if there is none.
build(Object) - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a BoundMethod or throws a RuntimeError if there is none.
buildAvroProjection(Schema, Schema, Map<String, String>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
buildChecked() - Method in class org.apache.iceberg.common.DynClasses.Builder
Returns the first implementation or throws ClassNotFoundException if one was not found.
buildChecked() - Method in class org.apache.iceberg.common.DynConstructors.Builder
 
buildChecked() - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a UnboundField or throws a NoSuchFieldException if there is none.
buildChecked() - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a UnboundMethod or throws a NoSuchMethodException if there is none.
buildChecked(Object) - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a BoundMethod or throws a NoSuchMethodException if there is none.
buildChecked(Object) - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a BoundMethod or throws a NoSuchMethodException if there is none.
buildCopyOnWriteDistribution(Table, RowLevelOperation.Command, DistributionMode) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildCopyOnWriteOrdering(Table, RowLevelOperation.Command, Distribution) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildCopyOnWriteScan() - Method in class org.apache.iceberg.spark.source.SparkScanBuilder
 
buildEqualityWriter() - Method in class org.apache.iceberg.avro.Avro.DeleteWriteBuilder
 
buildEqualityWriter() - Method in class org.apache.iceberg.orc.ORC.DeleteWriteBuilder
 
buildEqualityWriter() - Method in class org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder
 
builder() - Static method in class org.apache.iceberg.common.DynClasses
 
builder() - Static method in class org.apache.iceberg.common.DynConstructors
 
builder() - Static method in class org.apache.iceberg.common.DynFields
 
builder() - Static method in class org.apache.iceberg.io.WriteResult
 
builder() - Static method in class org.apache.iceberg.SnapshotSummary
 
builder() - Static method in class org.apache.iceberg.spark.procedures.AncestorsOfProcedure
 
builder() - Static method in class org.apache.iceberg.spark.procedures.ExpireSnapshotsProcedure
 
builder() - Static method in class org.apache.iceberg.spark.procedures.RemoveOrphanFilesProcedure
 
builder(Class<?>) - Static method in class org.apache.iceberg.common.DynConstructors
 
builder(String) - Static method in class org.apache.iceberg.common.DynMethods
Constructs a new builder for calling methods dynamically.
builder(PartitionSpec) - Static method in class org.apache.iceberg.DataFiles
 
Builder() - Constructor for class org.apache.iceberg.common.DynClasses.Builder
 
Builder() - Constructor for class org.apache.iceberg.common.DynConstructors.Builder
 
Builder() - Constructor for class org.apache.iceberg.common.DynFields.Builder
 
Builder() - Constructor for class org.apache.iceberg.flink.source.FlinkSource.Builder
 
Builder() - Constructor for class org.apache.iceberg.SnapshotSummary.Builder
 
Builder(int) - Constructor for class org.apache.iceberg.DoubleFieldMetrics.Builder
 
Builder(int) - Constructor for class org.apache.iceberg.FloatFieldMetrics.Builder
 
Builder(Class<?>) - Constructor for class org.apache.iceberg.common.DynConstructors.Builder
 
Builder(Iterable<I>) - Constructor for class org.apache.iceberg.util.Tasks.Builder
 
Builder(String) - Constructor for class org.apache.iceberg.common.DynMethods.Builder
 
Builder(PartitionSpec) - Constructor for class org.apache.iceberg.DataFiles.Builder
 
Builder(Table) - Constructor for class org.apache.iceberg.FindFiles.Builder
 
Builder(TableScan) - Constructor for class org.apache.iceberg.ScanSummary.Builder
 
builderFor(int) - Method in class org.apache.iceberg.FloatFieldMetrics
 
builderFor(DataStream<T>, MapFunction<T, RowData>, TypeInformation<RowData>) - Static method in class org.apache.iceberg.flink.sink.FlinkSink
Initialize a FlinkSink.Builder to export the data from generic input data stream into iceberg table.
builderFor(Schema) - Static method in class org.apache.iceberg.PartitionSpec
Creates a new partition spec builder for the given Schema.
builderFor(Schema) - Static method in class org.apache.iceberg.SortOrder
Creates a new sort order builder for the given Schema.
builderFor(Table, int, long) - Static method in class org.apache.iceberg.io.OutputFileFactory
 
buildFormat() - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
buildFrom(TableMetadata) - Static method in class org.apache.iceberg.TableMetadata
 
buildIcebergCatalog(String, Map<String, String>, Object) - Static method in class org.apache.iceberg.CatalogUtil
Build an Iceberg Catalog based on a map of catalog properties and optional Hadoop configuration.
buildIcebergCatalog(String, CaseInsensitiveStringMap) - Method in class org.apache.iceberg.spark.SparkCatalog
Build an Iceberg Catalog to be used by this Spark catalog adapter.
buildIdentifier(Identifier) - Method in class org.apache.iceberg.spark.SparkCatalog
Build an Iceberg TableIdentifier for the given Spark identifier.
buildList(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader
 
buildList(List<E>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader
 
buildMap(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader
 
buildMap(Map<K, V>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader
 
buildMergeOnReadScan() - Method in class org.apache.iceberg.spark.source.SparkScanBuilder
 
buildOrcProjection(Schema, TypeDescription) - Static method in class org.apache.iceberg.orc.ORCSchemaUtil
Converts an Iceberg schema to a corresponding ORC schema within the context of an existing ORC file schema.
buildOtherMetadataFileDF(Table) - Method in class org.apache.iceberg.spark.actions.BaseDeleteReachableFilesSparkAction
 
buildPositionDeltaDistribution(Table, RowLevelOperation.Command, DistributionMode) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildPositionDeltaOrdering(Table, RowLevelOperation.Command, Distribution) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildPositionWriter() - Method in class org.apache.iceberg.avro.Avro.DeleteWriteBuilder
 
buildPositionWriter() - Method in class org.apache.iceberg.orc.ORC.DeleteWriteBuilder
 
buildPositionWriter() - Method in class org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder
 
buildReader(Schema, TypeDescription) - Static method in class org.apache.iceberg.data.orc.GenericOrcReader
 
buildReader(Schema, TypeDescription, Map<Integer, ?>) - Static method in class org.apache.iceberg.data.orc.GenericOrcReader
 
buildReader(Schema, TypeDescription, Map<Integer, ?>) - Static method in class org.apache.iceberg.spark.data.vectorized.VectorizedSparkOrcReaders
 
buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.data.parquet.GenericParquetReaders
 
buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.flink.data.FlinkParquetReaders
 
buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.parquet.ParquetAvroValueReaders
 
buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.spark.data.SparkParquetReaders
 
buildReader(Schema, MessageType, boolean) - Static method in class org.apache.iceberg.spark.data.vectorized.VectorizedSparkParquetReaders
 
buildReader(Schema, MessageType, boolean, Map<Integer, ?>) - Static method in class org.apache.iceberg.spark.data.vectorized.VectorizedSparkParquetReaders
 
buildReader(Schema, MessageType, boolean, Map<Integer, ?>, DeleteFilter<InternalRow>) - Static method in class org.apache.iceberg.spark.data.vectorized.VectorizedSparkParquetReaders
 
buildReader(Schema, MessageType, Map<Integer, ?>) - Static method in class org.apache.iceberg.data.parquet.GenericParquetReaders
 
buildReader(Schema, MessageType, Map<Integer, ?>) - Static method in class org.apache.iceberg.flink.data.FlinkParquetReaders
 
buildReader(Schema, MessageType, Map<Integer, ?>) - Static method in class org.apache.iceberg.spark.data.SparkParquetReaders
 
buildReader(MessageType, Schema, Map<Integer, Object>) - Static method in class org.apache.iceberg.pig.PigParquetReader
 
buildReplacement(Schema, PartitionSpec, SortOrder, String, Map<String, String>) - Method in class org.apache.iceberg.TableMetadata
 
buildRequiredDistribution(Table, DistributionMode) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildRequiredOrdering(Table, Distribution) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
buildSortOrder(Schema, PartitionSpec, SortOrder) - Static method in class org.apache.iceberg.util.SortOrderUtil
 
buildSortOrder(Table) - Static method in class org.apache.iceberg.util.SortOrderUtil
 
buildSortOrder(Table, SortOrder) - Static method in class org.apache.iceberg.util.SortOrderUtil
 
buildSparkCatalog(String, CaseInsensitiveStringMap) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
Build a SparkCatalog to be used for Iceberg operations.
buildStatic() - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a StaticField or throws a RuntimeException if there is none.
buildStatic() - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a StaticMethod or throws a RuntimeException if there is none.
buildStaticChecked() - Method in class org.apache.iceberg.common.DynFields.Builder
Returns the first valid implementation as a StaticField or throws a NoSuchFieldException if there is none.
buildStaticChecked() - Method in class org.apache.iceberg.common.DynMethods.Builder
Returns the first valid implementation as a StaticMethod or throws a NoSuchMethodException if there is none.
buildStruct(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader
 
buildTable(String, Schema) - Method in class org.apache.iceberg.hadoop.HadoopTables
 
buildTable(TableIdentifier, Schema) - Method in class org.apache.iceberg.BaseMetastoreCatalog
 
buildTable(TableIdentifier, Schema) - Method in class org.apache.iceberg.CachingCatalog
 
buildTable(TableIdentifier, Schema) - Method in interface org.apache.iceberg.catalog.Catalog
/** Instantiate a builder to either create a table or start a create/replace transaction.
buildTable(TableIdentifier, Schema) - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
buildWriter(LogicalType, MessageType) - Static method in class org.apache.iceberg.flink.data.FlinkParquetWriters
 
buildWriter(RowType, Schema) - Static method in class org.apache.iceberg.flink.data.FlinkOrcWriter
 
buildWriter(Schema, TypeDescription) - Static method in class org.apache.iceberg.data.orc.GenericOrcWriter
 
buildWriter(MessageType) - Static method in class org.apache.iceberg.data.parquet.GenericParquetWriter
 
buildWriter(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetAvroWriter
 
buildWriter(StructType, MessageType) - Static method in class org.apache.iceberg.spark.data.SparkParquetWriters
 
BY - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
BY - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
BY() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
BY() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteDistributionSpecContext
 
BY() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteOrderingSpecContext
 
byId() - Method in class org.apache.iceberg.types.IndexByName
Returns a mapping from field ID to full name.
byName() - Method in class org.apache.iceberg.types.IndexByName
Returns a mapping from full field name to ID.
ByteArrayReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.ByteArrayReader
 
byteArrays() - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
byteBuffers() - Static method in class org.apache.iceberg.avro.ValueReaders
 
byteBuffers() - Static method in class org.apache.iceberg.avro.ValueWriters
 
byteBuffers() - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
byteBuffers(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
ByteBuffers - Class in org.apache.iceberg.util
 
bytes() - Static method in class org.apache.iceberg.avro.ValueReaders
 
bytes() - Static method in class org.apache.iceberg.avro.ValueWriters
 
bytes() - Static method in class org.apache.iceberg.data.orc.GenericOrcReaders
 
bytes() - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
bytes() - Static method in class org.apache.iceberg.orc.OrcValueReaders
 
BytesReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.BytesReader
 

C

CACHE_ENABLED - Static variable in class org.apache.iceberg.CatalogProperties
Controls whether the catalog will cache table entries upon load.
CACHE_ENABLED - Static variable in class org.apache.iceberg.flink.FlinkCatalogFactory
 
CACHE_ENABLED_DEFAULT - Static variable in class org.apache.iceberg.CatalogProperties
 
CACHE_EXPIRATION_INTERVAL_MS - Static variable in class org.apache.iceberg.CatalogProperties
Controls the duration for which entries in the catalog are cached.
CACHE_EXPIRATION_INTERVAL_MS_DEFAULT - Static variable in class org.apache.iceberg.CatalogProperties
 
CACHE_EXPIRATION_INTERVAL_MS_OFF - Static variable in class org.apache.iceberg.CatalogProperties
 
CachedClientPool - Class in org.apache.iceberg.hive
 
CachingCatalog - Class in org.apache.iceberg
Class that wraps an Iceberg Catalog to cache tables.
CachingCatalog(Catalog, boolean, long, Ticker) - Constructor for class org.apache.iceberg.CachingCatalog
 
call(InternalRow) - Method in class org.apache.iceberg.spark.procedures.AncestorsOfProcedure
 
call(InternalRow) - Method in class org.apache.iceberg.spark.procedures.ExpireSnapshotsProcedure
 
call(InternalRow) - Method in class org.apache.iceberg.spark.procedures.RemoveOrphanFilesProcedure
 
call(InternalRow) - Method in interface org.apache.spark.sql.connector.iceberg.catalog.Procedure
Executes this procedure.
CALL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
CALL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
CALL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
CALL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
callArgument() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
callArgument() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
callArgument(int) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
CallArgumentContext() - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallArgumentContext
 
CallArgumentContext(ParserRuleContext, int) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallArgumentContext
 
CallContext(IcebergSqlExtensionsParser.StatementContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
callInit() - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
cancel() - Method in class org.apache.iceberg.flink.source.StreamingMonitorFunction
 
canContainAny(ManifestFile, Iterable<StructLike>, Function<Integer, PartitionSpec>) - Static method in class org.apache.iceberg.util.ManifestFileUtil
 
canContainAny(ManifestFile, Iterable<Pair<Integer, StructLike>>, Map<Integer, PartitionSpec>) - Static method in class org.apache.iceberg.util.ManifestFileUtil
 
canDeleteWhere(Filter[]) - Method in class org.apache.iceberg.spark.source.SparkTable
 
canTransform(Type) - Method in interface org.apache.iceberg.transforms.Transform
Checks whether this function can be applied to the given Type.
canTransform(Type) - Method in class org.apache.iceberg.transforms.UnknownTransform
 
capabilities() - Method in class org.apache.iceberg.spark.RollbackStagedTable
 
capabilities() - Method in class org.apache.iceberg.spark.source.SparkTable
 
CASE_SENSITIVE - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
CASE_SENSITIVE_DEFAULT - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
caseInsensitive() - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder
 
caseInsensitive() - Method in class org.apache.iceberg.FindFiles.Builder
 
caseInsensitive() - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
caseInsensitiveField(String) - Method in class org.apache.iceberg.types.Types.StructType
 
caseInsensitiveFindField(String) - Method in class org.apache.iceberg.Schema
Returns a sub-field by name as a Types.NestedField.
caseInsensitiveSelect(String...) - Method in class org.apache.iceberg.Schema
Creates a projection schema for a subset of columns, selected by case insensitive names
caseInsensitiveSelect(Collection<String>) - Method in class org.apache.iceberg.Schema
Creates a projection schema for a subset of columns, selected by case insensitive names
caseSensitive() - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
 
caseSensitive() - Method in class org.apache.iceberg.spark.SparkReadConf
 
caseSensitive(boolean) - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
Is it case sensitive
caseSensitive(boolean) - Method in interface org.apache.iceberg.DeleteFiles
Enables or disables case sensitive expression binding for methods that accept expressions.
caseSensitive(boolean) - Method in class org.apache.iceberg.FindFiles.Builder
 
caseSensitive(boolean) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
caseSensitive(boolean) - Method in class org.apache.iceberg.ManifestReader
 
caseSensitive(boolean) - Method in class org.apache.iceberg.MicroBatches.MicroBatchBuilder
 
caseSensitive(boolean) - Method in class org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
 
caseSensitive(boolean) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
caseSensitive(boolean) - Method in interface org.apache.iceberg.OverwriteFiles
Enables or disables case sensitive expression binding for validations that accept expressions.
caseSensitive(boolean) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
caseSensitive(boolean) - Method in interface org.apache.iceberg.RowDelta
Enables or disables case sensitive expression binding for validations that accept expressions.
caseSensitive(boolean) - Method in class org.apache.iceberg.SortOrder.Builder
 
caseSensitive(boolean) - Method in class org.apache.iceberg.spark.source.SparkScanBuilder
 
caseSensitive(boolean) - Method in interface org.apache.iceberg.TableScan
Create a new TableScan from this that, if data columns where selected via TableScan.select(java.util.Collection), controls whether the match to the schema will be done with case sensitivity.
caseSensitive(boolean) - Method in interface org.apache.iceberg.UpdatePartitionSpec
Set whether column resolution in the source schema should be case sensitive.
castAndThrow(Throwable, Class<E>) - Static method in class org.apache.iceberg.util.ExceptionUtil
 
catalog() - Method in class org.apache.iceberg.flink.FlinkCatalog
 
catalog() - Method in class org.apache.iceberg.spark.Spark3Util.CatalogAndIdentifier
 
Catalog - Interface in org.apache.iceberg.catalog
A Catalog API for table create, drop, and load operations.
CATALOG - Static variable in class org.apache.iceberg.mr.InputFormatConfig
Deprecated.
please use InputFormatConfig.catalogPropertyConfigKey(String, String) with config key CatalogUtil.ICEBERG_CATALOG_TYPE to specify the type of a catalog.
CATALOG_CONFIG_PREFIX - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
CATALOG_IMPL - Static variable in class org.apache.iceberg.CatalogProperties
 
CATALOG_LOADER_CLASS - Static variable in class org.apache.iceberg.mr.InputFormatConfig
Deprecated.
please use InputFormatConfig.catalogPropertyConfigKey(String, String) with config key CatalogProperties.CATALOG_IMPL to specify the implementation of a catalog.
CATALOG_NAME - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
Catalog.TableBuilder - Interface in org.apache.iceberg.catalog
A builder used to create valid tables or start create/replace transactions.
catalogAndIdentifier(String, SparkSession, String) - Static method in class org.apache.iceberg.spark.Spark3Util
 
catalogAndIdentifier(String, SparkSession, String, CatalogPlugin) - Static method in class org.apache.iceberg.spark.Spark3Util
 
catalogAndIdentifier(List<String>, Function<String, C>, BiFunction<String[], String, T>, C, String[]) - Static method in class org.apache.iceberg.spark.SparkUtil
A modified version of Spark's LookupCatalog.CatalogAndIdentifier.unapply Attempts to find the catalog and identifier a multipart identifier represents
catalogAndIdentifier(SparkSession, String) - Static method in class org.apache.iceberg.spark.Spark3Util
 
catalogAndIdentifier(SparkSession, String, CatalogPlugin) - Static method in class org.apache.iceberg.spark.Spark3Util
 
catalogAndIdentifier(SparkSession, List<String>) - Static method in class org.apache.iceberg.spark.Spark3Util
 
catalogAndIdentifier(SparkSession, List<String>, CatalogPlugin) - Static method in class org.apache.iceberg.spark.Spark3Util
A modified version of Spark's LookupCatalog.CatalogAndIdentifier.unapply Attempts to find the catalog and identifier a multipart identifier represents
CatalogAndIdentifier(Pair<CatalogPlugin, Identifier>) - Constructor for class org.apache.iceberg.spark.Spark3Util.CatalogAndIdentifier
 
CatalogAndIdentifier(CatalogPlugin, Identifier) - Constructor for class org.apache.iceberg.spark.Spark3Util.CatalogAndIdentifier
 
CatalogLoader - Interface in org.apache.iceberg.flink
Serializable loader to load an Iceberg Catalog.
CatalogLoader.CustomCatalogLoader - Class in org.apache.iceberg.flink
 
CatalogLoader.HadoopCatalogLoader - Class in org.apache.iceberg.flink
 
CatalogLoader.HiveCatalogLoader - Class in org.apache.iceberg.flink
 
catalogName(Configuration, String) - Static method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
Returns the catalog name serialized to the configuration.
CatalogProperties - Class in org.apache.iceberg
 
catalogPropertyConfigKey(String, String) - Static method in class org.apache.iceberg.mr.InputFormatConfig
Get Hadoop config key of a catalog property based on catalog name
Catalogs - Class in org.apache.iceberg.mr
Class for catalog resolution and accessing the common functions for Catalog API.
CatalogUtil - Class in org.apache.iceberg
 
CHANGED_PARTITION_COUNT_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
CHANGED_PARTITION_PREFIX - Static variable in class org.apache.iceberg.SnapshotSummary
 
changes() - Method in class org.apache.iceberg.TableMetadata
 
channelNames - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
channelReadChunkSize() - Method in class org.apache.iceberg.gcp.GCPProperties
 
channelWriteChunkSize() - Method in class org.apache.iceberg.gcp.GCPProperties
 
charAt(int) - Method in class org.apache.iceberg.util.CharSequenceWrapper
 
charSequences() - Static method in class org.apache.iceberg.types.Comparators
 
CharSequenceSet - Class in org.apache.iceberg.util
 
CharSequenceWrapper - Class in org.apache.iceberg.util
Wrapper class to adapt CharSequence for use in maps and sets.
check(boolean, String, Object...) - Static method in exception org.apache.iceberg.exceptions.NoSuchIcebergTableException
 
check(boolean, String, Object...) - Static method in exception org.apache.iceberg.exceptions.ValidationException
 
CHECK_NULLABILITY - Static variable in class org.apache.iceberg.spark.SparkSQLProperties
 
CHECK_NULLABILITY - Static variable in class org.apache.iceberg.spark.SparkWriteOptions
 
CHECK_NULLABILITY_DEFAULT - Static variable in class org.apache.iceberg.spark.SparkSQLProperties
 
CHECK_ORDERING - Static variable in class org.apache.iceberg.spark.SparkSQLProperties
 
CHECK_ORDERING - Static variable in class org.apache.iceberg.spark.SparkWriteOptions
 
CHECK_ORDERING_DEFAULT - Static variable in class org.apache.iceberg.spark.SparkSQLProperties
 
checkAndSetIoConfig(Configuration, Table) - Static method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
If enabled, it populates the FileIO's hadoop configuration with the input config object.
checkAndSkipIoConfigSerialization(Configuration, Table) - Static method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
If enabled, it ensures that the FileIO's hadoop configuration will not be serialized.
checkCommitStatus(String, TableMetadata) - Method in class org.apache.iceberg.BaseMetastoreTableOperations
Attempt to load the table and see if any current or past metadata location matches the one we were attempting to set.
checkCompatibility(SortOrder, Schema) - Static method in class org.apache.iceberg.SortOrder
 
CheckCompatibility - Class in org.apache.iceberg.types
 
checkNullability() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
checkOrdering() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.iceberg.mr.hive.HiveIcebergOutputFormat
 
checkSourceCatalog(CatalogPlugin) - Method in class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
checkSourceCatalog(CatalogPlugin) - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
cherrypick(long) - Method in interface org.apache.iceberg.ManageSnapshots
Apply supported changes in given snapshot and create a new snapshot which will be set as the current snapshot on commit.
cherrypick(long) - Method in class org.apache.iceberg.SnapshotManager
 
CherrypickAncestorCommitException - Exception in org.apache.iceberg.exceptions
This exception occurs when one cherrypicks an ancestor or when the picked snapshot is already linked to a published ancestor.
CherrypickAncestorCommitException(long) - Constructor for exception org.apache.iceberg.exceptions.CherrypickAncestorCommitException
 
CherrypickAncestorCommitException(long, long) - Constructor for exception org.apache.iceberg.exceptions.CherrypickAncestorCommitException
 
child() - Method in class org.apache.iceberg.expressions.Not
 
childColumn(int) - Method in class org.apache.iceberg.arrow.vectorized.ArrowVectorAccessor
 
classLoader(ClassLoader) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder
 
cleanExpiredFiles(boolean) - Method in interface org.apache.iceberg.ExpireSnapshots
Allows expiration of snapshots without any cleanup of underlying manifest or data files.
cleanUncommitted(Set<ManifestFile>) - Method in class org.apache.iceberg.BaseRewriteManifests
 
clear() - Method in class org.apache.iceberg.DataFiles.Builder
 
clear() - Method in class org.apache.iceberg.FileMetadata.Builder
 
clear() - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
clear() - Method in class org.apache.iceberg.util.CharSequenceSet
 
clear() - Method in class org.apache.iceberg.util.PartitionSet
 
clear() - Method in class org.apache.iceberg.util.SerializableMap
 
clear() - Method in class org.apache.iceberg.util.StructLikeMap
 
clear() - Method in class org.apache.iceberg.util.StructLikeSet
 
clearRewrite(Table, String) - Method in class org.apache.iceberg.spark.FileRewriteCoordinator
 
CLIENT_ACCESS_KEY_ID - Static variable in class org.apache.iceberg.aliyun.AliyunProperties
Aliyun uses an AccessKey pair, which includes an AccessKey ID and an AccessKey secret to implement symmetric encryption and verify the identity of a requester.
CLIENT_ACCESS_KEY_SECRET - Static variable in class org.apache.iceberg.aliyun.AliyunProperties
Aliyun uses an AccessKey pair, which includes an AccessKey ID and an AccessKey secret to implement symmetric encryption and verify the identity of a requester.
CLIENT_ASSUME_ROLE_ARN - Static variable in class org.apache.iceberg.aws.AwsProperties
CLIENT_ASSUME_ROLE_EXTERNAL_ID - Static variable in class org.apache.iceberg.aws.AwsProperties
CLIENT_ASSUME_ROLE_REGION - Static variable in class org.apache.iceberg.aws.AwsProperties
CLIENT_ASSUME_ROLE_TIMEOUT_SEC - Static variable in class org.apache.iceberg.aws.AwsProperties
CLIENT_ASSUME_ROLE_TIMEOUT_SEC_DEFAULT - Static variable in class org.apache.iceberg.aws.AwsProperties
 
CLIENT_ENABLE_ETAG_CHECK_DEFAULT - Static variable in class org.apache.iceberg.aws.AwsProperties
 
CLIENT_FACTORY - Static variable in class org.apache.iceberg.aliyun.AliyunProperties
The implementation class of AliyunClientFactory to customize Aliyun client configurations.
CLIENT_FACTORY - Static variable in class org.apache.iceberg.aws.AwsProperties
The implementation class of AwsClientFactory to customize AWS client configurations.
CLIENT_POOL_CACHE_EVICTION_INTERVAL_MS - Static variable in class org.apache.iceberg.CatalogProperties
 
CLIENT_POOL_CACHE_EVICTION_INTERVAL_MS_DEFAULT - Static variable in class org.apache.iceberg.CatalogProperties
 
CLIENT_POOL_SIZE - Static variable in class org.apache.iceberg.CatalogProperties
 
CLIENT_POOL_SIZE_DEFAULT - Static variable in class org.apache.iceberg.CatalogProperties
 
clientLibToken() - Method in class org.apache.iceberg.gcp.GCPProperties
 
ClientPool<C,​E extends java.lang.Exception> - Interface in org.apache.iceberg
 
ClientPool.Action<R,​C,​E extends java.lang.Exception> - Interface in org.apache.iceberg
 
ClientPoolImpl<C,​E extends java.lang.Exception> - Class in org.apache.iceberg
 
ClientPoolImpl(int, Class<? extends E>, boolean) - Constructor for class org.apache.iceberg.ClientPoolImpl
 
clone(RowData, RowData, RowType, TypeSerializer[]) - Static method in class org.apache.iceberg.flink.data.RowDataUtil
Similar to the private RowDataSerializer.copyRowData(RowData, RowData) method.
close() - Method in class org.apache.iceberg.actions.RewriteDataFilesCommitManager.CommitService
 
close() - Method in class org.apache.iceberg.aliyun.oss.OSSFileIO
 
close() - Method in class org.apache.iceberg.aliyun.oss.OSSInputStream
 
close() - Method in class org.apache.iceberg.aliyun.oss.OSSOutputStream
 
close() - Method in class org.apache.iceberg.arrow.vectorized.ArrowReader
 
close() - Method in class org.apache.iceberg.arrow.vectorized.ArrowVectorAccessor
 
close() - Method in class org.apache.iceberg.arrow.vectorized.BaseBatchReader
 
close() - Method in class org.apache.iceberg.arrow.vectorized.ColumnarBatch
Called to close all the columns in this batch.
close() - Method in class org.apache.iceberg.arrow.vectorized.ColumnVector
 
close() - Method in class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
 
close() - Method in class org.apache.iceberg.arrow.vectorized.VectorizedTableScanIterable
 
close() - Method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
close() - Method in class org.apache.iceberg.aws.glue.GlueCatalog
 
close() - Method in class org.apache.iceberg.aws.s3.S3FileIO
 
close() - Method in class org.apache.iceberg.ClientPoolImpl
 
close() - Method in class org.apache.iceberg.deletes.EqualityDeleteWriter
 
close() - Method in class org.apache.iceberg.deletes.PositionDeleteWriter
 
close() - Method in class org.apache.iceberg.flink.FlinkCatalog
 
close() - Method in class org.apache.iceberg.flink.source.DataIterator
 
close() - Method in class org.apache.iceberg.flink.source.FlinkInputFormat
 
close() - Method in class org.apache.iceberg.flink.source.StreamingMonitorFunction
 
close() - Method in class org.apache.iceberg.flink.source.StreamingReaderOperator
 
close() - Method in class org.apache.iceberg.flink.TableLoader.CatalogTableLoader
 
close() - Method in class org.apache.iceberg.flink.TableLoader.HadoopTableLoader
 
close() - Method in class org.apache.iceberg.gcp.gcs.GCSFileIO
 
close() - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
close() - Method in class org.apache.iceberg.io.BasePositionDeltaWriter
 
close() - Method in class org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter
 
close() - Method in class org.apache.iceberg.io.CloseableGroup
Close all the registered resources.
close() - Method in class org.apache.iceberg.io.DataWriter
 
close() - Method in interface org.apache.iceberg.io.FileIO
Close File IO to release underlying resources.
close() - Method in class org.apache.iceberg.io.FilterIterator
 
close() - Method in class org.apache.iceberg.io.PartitionedFanoutWriter
 
close() - Method in class org.apache.iceberg.io.PartitionedWriter
 
close() - Method in class org.apache.iceberg.io.ResolvingFileIO
 
close() - Method in class org.apache.iceberg.io.UnpartitionedWriter
 
close() - Method in class org.apache.iceberg.jdbc.JdbcCatalog
 
close() - Method in class org.apache.iceberg.ManifestWriter
 
close() - Method in class org.apache.iceberg.mr.mapred.AbstractMapredIcebergRecordReader
 
close() - Method in class org.apache.iceberg.nessie.NessieCatalog
 
close() - Method in class org.apache.iceberg.orc.VectorizedRowBatchIterator
 
close() - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter
Deprecated.
 
close() - Method in interface org.apache.iceberg.parquet.VectorizedReader
Release any resources allocated.
close() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader
 
close() - Method in class org.apache.iceberg.spark.data.vectorized.IcebergArrowColumnVector
 
close() - Method in class org.apache.iceberg.spark.data.vectorized.RowPositionColumnVector
 
close(C) - Method in class org.apache.iceberg.ClientPoolImpl
 
close(Closeable, boolean) - Static method in class org.apache.iceberg.util.Exceptions
 
close(IMetaStoreClient) - Method in class org.apache.iceberg.hive.HiveClientPool
 
CloseableGroup - Class in org.apache.iceberg.io
This class acts as a helper for handling the closure of multiple resource.
CloseableGroup() - Constructor for class org.apache.iceberg.io.CloseableGroup
 
CloseableIterable<T> - Interface in org.apache.iceberg.io
 
CloseableIterable.ConcatCloseableIterable<E> - Class in org.apache.iceberg.io
 
CloseableIterator<T> - Interface in org.apache.iceberg.io
 
closeVectors() - Method in class org.apache.iceberg.arrow.vectorized.BaseBatchReader
 
ClosingIterator<T> - Class in org.apache.iceberg.io
A convenience wrapper around CloseableIterator, providing auto-close functionality when all of the elements in the iterator are consumed.
ClosingIterator(CloseableIterator<T>) - Constructor for class org.apache.iceberg.io.ClosingIterator
 
clusterBy(Function<DataFile, Object>) - Method in class org.apache.iceberg.BaseRewriteManifests
 
clusterBy(Function<DataFile, Object>) - Method in interface org.apache.iceberg.RewriteManifests
Groups an existing DataFile by a cluster key produced by a function.
ClusteredDataWriter<T> - Class in org.apache.iceberg.io
A data writer capable of writing to multiple specs and partitions that requires the incoming records to be properly clustered by partition spec and by partition within each spec.
ClusteredDataWriter(FileWriterFactory<T>, OutputFileFactory, FileIO, FileFormat, long) - Constructor for class org.apache.iceberg.io.ClusteredDataWriter
 
ClusteredEqualityDeleteWriter<T> - Class in org.apache.iceberg.io
An equality delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
ClusteredEqualityDeleteWriter(FileWriterFactory<T>, OutputFileFactory, FileIO, FileFormat, long) - Constructor for class org.apache.iceberg.io.ClusteredEqualityDeleteWriter
 
ClusteredPositionDeleteWriter<T> - Class in org.apache.iceberg.io
A position delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
ClusteredPositionDeleteWriter(FileWriterFactory<T>, OutputFileFactory, FileIO, FileFormat, long) - Constructor for class org.apache.iceberg.io.ClusteredPositionDeleteWriter
 
clusterHadoopConf() - Static method in class org.apache.iceberg.flink.FlinkCatalogFactory
 
collect() - Method in class org.apache.iceberg.FindFiles.Builder
Returns all files in the table that match all of the filters.
collections(int, int, ParquetValueWriter<E>) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
column - Variable in class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader
 
column - Variable in class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter
 
column() - Method in interface org.apache.iceberg.parquet.ParquetValueReader
 
column() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader
 
column() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader
 
column() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader
 
column() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader
 
column(int) - Method in class org.apache.iceberg.arrow.vectorized.ColumnarBatch
Returns the column at `ordinal`.
COLUMN_SIZES - Static variable in interface org.apache.iceberg.DataFile
 
ColumnarBatch - Class in org.apache.iceberg.arrow.vectorized
This class is inspired by Spark's ColumnarBatch.
ColumnarBatchReader - Class in org.apache.iceberg.spark.data.vectorized
VectorizedReader that returns Spark's ColumnarBatch to support Spark's vectorized read path.
ColumnarBatchReader(List<VectorizedReader<?>>) - Constructor for class org.apache.iceberg.spark.data.vectorized.ColumnarBatchReader
 
ColumnIterator<T> - Class in org.apache.iceberg.parquet
 
columnMode(String) - Method in class org.apache.iceberg.MetricsConfig
 
columns() - Method in interface org.apache.iceberg.parquet.ParquetValueReader
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader
 
columns() - Method in interface org.apache.iceberg.parquet.ParquetValueWriter
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter
 
columns() - Method in class org.apache.iceberg.parquet.ParquetValueWriters.StructWriter
 
columns() - Method in class org.apache.iceberg.Schema
Returns a List of the columns in this Schema.
columnSizes() - Method in interface org.apache.iceberg.ContentFile
Returns if collected, map from column ID to the size of the column in bytes, null otherwise.
columnSizes() - Method in class org.apache.iceberg.Metrics
Get the number of bytes for all fields in a file.
columnSizes() - Method in class org.apache.iceberg.spark.SparkDataFile
 
ColumnVector - Class in org.apache.iceberg.arrow.vectorized
This class is inspired by Spark's ColumnVector.
ColumnVectorWithFilter - Class in org.apache.iceberg.spark.data.vectorized
 
ColumnVectorWithFilter(VectorHolder, int[]) - Constructor for class org.apache.iceberg.spark.data.vectorized.ColumnVectorWithFilter
 
ColumnWriter<T> - Class in org.apache.iceberg.parquet
 
combine(Iterable<E>, Closeable) - Static method in interface org.apache.iceberg.io.CloseableIterable
 
CombinedScanTask - Interface in org.apache.iceberg
A scan task made of several ranges from files.
command() - Method in interface org.apache.spark.sql.connector.iceberg.write.RowLevelOperation
Returns the actual SQL operation being performed.
command() - Method in interface org.apache.spark.sql.connector.iceberg.write.RowLevelOperationInfo
Returns the SQL command (e.g.
commit() - Method in class org.apache.iceberg.BaseReplaceSortOrder
 
commit() - Method in interface org.apache.iceberg.PendingUpdate
Apply the pending changes and commit.
commit() - Method in class org.apache.iceberg.SetLocation
 
commit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
commit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.hadoop.HadoopTableOperations
 
commit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.StaticTableOperations
 
commit(TableMetadata, TableMetadata) - Method in interface org.apache.iceberg.TableOperations
Replace the base table metadata with a new version.
commit(Offset) - Method in class org.apache.iceberg.spark.source.SparkMicroBatchStream
 
COMMIT_FILE_THREAD_POOL_SIZE - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
COMMIT_FILE_THREAD_POOL_SIZE_DEFAULT - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
COMMIT_MAX_RETRY_WAIT_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_MAX_RETRY_WAIT_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_MIN_RETRY_WAIT_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_MIN_RETRY_WAIT_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_NUM_RETRIES - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_NUM_RETRIES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_NUM_STATUS_CHECKS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_NUM_STATUS_CHECKS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_MAX_WAIT_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_MAX_WAIT_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_MIN_WAIT_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_MIN_WAIT_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_TOTAL_WAIT_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_STATUS_CHECKS_TOTAL_WAIT_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_TABLE_THREAD_POOL_SIZE - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
COMMIT_TABLE_THREAD_POOL_SIZE_DEFAULT - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
COMMIT_TOTAL_RETRY_TIME_MS - Static variable in class org.apache.iceberg.TableProperties
 
COMMIT_TOTAL_RETRY_TIME_MS_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
commitCreateTable(Table) - Method in class org.apache.iceberg.mr.hive.HiveIcebergMetaHook
 
commitDropTable(Table, boolean) - Method in class org.apache.iceberg.mr.hive.HiveIcebergMetaHook
 
CommitFailedException - Exception in org.apache.iceberg.exceptions
Exception raised when a commit fails because of out of date metadata.
CommitFailedException(String, Object...) - Constructor for exception org.apache.iceberg.exceptions.CommitFailedException
 
CommitFailedException(Throwable, String, Object...) - Constructor for exception org.apache.iceberg.exceptions.CommitFailedException
 
commitFileGroups(Set<RewriteFileGroup>) - Method in class org.apache.iceberg.actions.RewriteDataFilesCommitManager
Perform a commit operation on the table adding and removing files as required for this set of file groups
commitJob(JobContext) - Method in class org.apache.iceberg.mr.hive.HiveIcebergOutputCommitter
Reads the commit files stored in the temp directories and collects the generated committed data files.
commitOrClean(Set<RewriteFileGroup>) - Method in class org.apache.iceberg.actions.RewriteDataFilesCommitManager
 
commitStagedChanges() - Method in class org.apache.iceberg.spark.RollbackStagedTable
 
commitStagedChanges() - Method in class org.apache.iceberg.spark.source.StagedSparkTable
 
CommitStateUnknownException - Exception in org.apache.iceberg.exceptions
Exception for a failure to confirm either affirmatively or negatively that a commit was applied.
CommitStateUnknownException(Throwable) - Constructor for exception org.apache.iceberg.exceptions.CommitStateUnknownException
 
commitTask(TaskAttemptContext) - Method in class org.apache.iceberg.mr.hive.HiveIcebergOutputCommitter
Collects the generated data files and creates a commit file storing the data file list.
commitTransaction() - Method in interface org.apache.iceberg.Transaction
Apply the pending changes from all actions and commit.
comparator() - Method in interface org.apache.iceberg.expressions.BoundTerm
Returns a Comparator for values produced by this term.
comparator() - Method in interface org.apache.iceberg.expressions.Literal
Return a Comparator for values.
Comparators - Class in org.apache.iceberg.types
 
CompatibilityTaskAttemptContextImpl(Configuration, TaskAttemptID, Reporter) - Constructor for class org.apache.iceberg.mr.mapred.MapredIcebergInputFormat.CompatibilityTaskAttemptContextImpl
 
compatibleWith(PartitionSpec) - Method in class org.apache.iceberg.PartitionSpec
Returns true if this spec is equivalent to the other, with partition field ids ignored.
complete() - Method in class org.apache.iceberg.io.BaseTaskWriter
 
complete() - Method in interface org.apache.iceberg.io.TaskWriter
Close the writer and get the completed data and delete files.
COMPRESSION_FACTOR - Static variable in class org.apache.iceberg.spark.actions.Spark3SortStrategy
The number of shuffle partitions and consequently the number of output files created by the Spark Sort is based on the size of the input data files used in this rewrite operation.
concat(Iterable<File>, File, int, Schema, Map<String, String>) - Static method in class org.apache.iceberg.parquet.Parquet
Combines several files into one
concat(Iterable<CloseableIterable<E>>) - Static method in interface org.apache.iceberg.io.CloseableIterable
 
conf() - Method in class org.apache.iceberg.hadoop.HadoopFileIO
 
conf() - Method in class org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
 
config(String, String) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
config(String, String) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder
Deprecated.
Please use #set(String, String) instead
CONFIG - Static variable in class org.apache.iceberg.flink.actions.Actions
 
CONFIG_CLIENT_BUILDER_IMPL - Static variable in class org.apache.iceberg.nessie.NessieUtil
 
CONFIG_SERIALIZATION_DISABLED - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
CONFIG_SERIALIZATION_DISABLED_DEFAULT - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
ConfigBuilder(Configuration) - Constructor for class org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
 
ConfigProperties - Class in org.apache.iceberg.hadoop
 
Configurable<C> - Interface in org.apache.iceberg.hadoop
Interface used to avoid runtime dependencies on Hadoop Configurable
configure(Configuration) - Method in class org.apache.iceberg.flink.source.FlinkInputFormat
 
configure(JobConf) - Static method in class org.apache.iceberg.mr.mapred.MapredIcebergInputFormat
Configures the JobConf to use the MapredIcebergInputFormat and returns a helper to add further configuration.
configure(Job) - Static method in class org.apache.iceberg.mr.mapreduce.IcebergInputFormat
Configures the Job to use the IcebergInputFormat and returns a helper to add further configuration.
configureDataWrite(Avro.DataWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureDataWrite(ORC.DataWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureDataWrite(Parquet.DataWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureEqualityDelete(Avro.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureEqualityDelete(ORC.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureEqualityDelete(Parquet.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureHadoopConf(Object, Object) - Static method in class org.apache.iceberg.CatalogUtil
Dynamically detects whether an object is a Hadoop Configurable and calls setConf.
configureInputJobCredentials(TableDesc, Map<String, String>) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
configureInputJobProperties(TableDesc, Map<String, String>) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
configureJobConf(TableDesc, JobConf) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
configureOutputJobProperties(TableDesc, Map<String, String>) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
configurePositionDelete(Avro.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configurePositionDelete(ORC.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configurePositionDelete(Parquet.DeleteWriteBuilder) - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
configureTableJobProperties(TableDesc, Map<String, String>) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
conflictDetectionFilter(Expression) - Method in class org.apache.iceberg.BaseOverwriteFiles
 
conflictDetectionFilter(Expression) - Method in interface org.apache.iceberg.OverwriteFiles
Sets a conflict detection filter used to validate concurrently added data and delete files.
conflictDetectionFilter(Expression) - Method in interface org.apache.iceberg.RowDelta
Sets a conflict detection filter used to validate concurrently added data and delete files.
constant() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
constant() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExpressionContext
 
constant() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringMapContext
 
constant() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TransformArgumentContext
 
constant(int) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringMapContext
 
constant(C) - Static method in class org.apache.iceberg.parquet.ParquetValueReaders
 
ConstantContext() - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ConstantContext
 
ConstantContext(ParserRuleContext, int) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ConstantContext
 
constantHolder(int, T) - Static method in class org.apache.iceberg.arrow.vectorized.VectorHolder
 
constants(C) - Static method in class org.apache.iceberg.orc.OrcValueReaders
 
constantsMap(FileScanTask) - Static method in class org.apache.iceberg.util.PartitionUtil
 
constantsMap(FileScanTask, BiFunction<Type, Object, Object>) - Static method in class org.apache.iceberg.util.PartitionUtil
 
constantsMap(FileScanTask, Types.StructType, BiFunction<Type, Object, Object>) - Static method in class org.apache.iceberg.util.PartitionUtil
 
ConstantVectorHolder(int) - Constructor for class org.apache.iceberg.arrow.vectorized.VectorHolder.ConstantVectorHolder
 
ConstantVectorHolder(int, T) - Constructor for class org.apache.iceberg.arrow.vectorized.VectorHolder.ConstantVectorHolder
 
ConstantVectorReader(T) - Constructor for class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader.ConstantVectorReader
 
Container<T> - Class in org.apache.iceberg.mr.mapred
A simple container of objects that you can get and set.
Container() - Constructor for class org.apache.iceberg.mr.mapred.Container
 
contains(int, StructLike) - Method in class org.apache.iceberg.util.PartitionSet
 
contains(Object) - Method in class org.apache.iceberg.util.CharSequenceSet
 
contains(Object) - Method in class org.apache.iceberg.util.PartitionSet
 
contains(Object) - Method in class org.apache.iceberg.util.StructLikeSet
 
containsAll(Collection<?>) - Method in class org.apache.iceberg.util.CharSequenceSet
 
containsAll(Collection<?>) - Method in class org.apache.iceberg.util.PartitionSet
 
containsAll(Collection<?>) - Method in class org.apache.iceberg.util.StructLikeSet
 
containsKey(Object) - Method in class org.apache.iceberg.util.SerializableMap
 
containsKey(Object) - Method in class org.apache.iceberg.util.StructLikeMap
 
containsNaN() - Method in class org.apache.iceberg.GenericPartitionFieldSummary
 
containsNaN() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary
Returns true if at least one data file in the manifest has a NaN value for the field.
containsNull() - Method in class org.apache.iceberg.GenericPartitionFieldSummary
 
containsNull() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary
Returns true if at least one data file in the manifest has a null value for the field.
containsValue(Object) - Method in class org.apache.iceberg.util.SerializableMap
 
containsValue(Object) - Method in class org.apache.iceberg.util.StructLikeMap
 
content() - Method in interface org.apache.iceberg.ContentFile
Returns type of content stored in the file; one of DATA, POSITION_DELETES, or EQUALITY_DELETES.
content() - Method in interface org.apache.iceberg.DataFile
 
content() - Method in class org.apache.iceberg.GenericManifestFile
 
content() - Method in interface org.apache.iceberg.ManifestFile
Returns the content stored in the manifest; either DATA or DELETES.
content() - Method in class org.apache.iceberg.ManifestWriter
 
content() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
CONTENT - Static variable in interface org.apache.iceberg.DataFile
 
ContentFile<F> - Interface in org.apache.iceberg
Superinterface of DataFile and DeleteFile that exposes common methods.
Conversions - Class in org.apache.iceberg.types
 
convert(byte[]) - Static method in class org.apache.iceberg.util.UUIDUtil
 
convert(byte[], int) - Static method in class org.apache.iceberg.util.UUIDUtil
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergBinaryObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergDateObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergDecimalObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergFixedObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimeObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimestampObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimestampWithZoneObjectInspector
 
convert(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergUUIDObjectInspector
 
convert(Object) - Method in interface org.apache.iceberg.mr.hive.serde.objectinspector.WriteObjectInspector
 
convert(ByteBuffer) - Static method in class org.apache.iceberg.util.UUIDUtil
 
convert(List<String>, List<TypeInfo>, List<String>) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts the Hive list of column names and column types to an Iceberg schema.
convert(List<String>, List<TypeInfo>, List<String>, boolean) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts the Hive list of column names and column types to an Iceberg schema.
convert(List<FieldSchema>) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts a Hive schema (list of FieldSchema objects) to an Iceberg schema.
convert(List<FieldSchema>, boolean) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts a Hive schema (list of FieldSchema objects) to an Iceberg schema.
convert(UUID) - Static method in class org.apache.iceberg.util.UUIDUtil
 
convert(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(TableSchema) - Static method in class org.apache.iceberg.flink.FlinkSchemaUtil
Convert the flink table schema to apache iceberg schema.
convert(Expression) - Static method in class org.apache.iceberg.flink.FlinkFilters
Convert flink expression to iceberg expression.
convert(TypeInfo) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts a Hive typeInfo object to an Iceberg type.
convert(Schema) - Static method in class org.apache.iceberg.arrow.ArrowSchemaUtil
Convert Iceberg schema to Arrow Schema.
convert(Schema) - Static method in class org.apache.iceberg.flink.FlinkSchemaUtil
Convert a Schema to a Flink type.
convert(Schema) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts the Iceberg schema to a Hive schema (list of FieldSchema objects).
convert(Schema) - Static method in class org.apache.iceberg.orc.ORCSchemaUtil
 
convert(Schema) - Static method in class org.apache.iceberg.pig.SchemaUtil
 
convert(Schema) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Schema to a Spark type.
convert(Schema, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(Schema, String) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil
 
convert(Schema, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType
 
convert(Schema, Map<Types.StructType, String>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(Schema, TableSchema) - Static method in class org.apache.iceberg.flink.FlinkSchemaUtil
Convert a Flink TableSchema to a Schema based on the given schema.
convert(Schema, Row) - Static method in class org.apache.iceberg.spark.SparkValueConverter
 
convert(Schema, StructType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Spark struct to a Schema based on the given schema.
convert(SortOrder) - Static method in class org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
 
convert(Type) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(Type) - Static method in class org.apache.iceberg.flink.FlinkSchemaUtil
Convert a Type to a Flink type.
convert(Type) - Static method in class org.apache.iceberg.hive.HiveSchemaUtil
Converts an Iceberg type to a Hive TypeInfo object.
convert(Type) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Type to a Spark type.
convert(Type, Object) - Static method in class org.apache.iceberg.spark.SparkValueConverter
 
convert(Type, Map<Types.StructType, String>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(Types.NestedField) - Static method in class org.apache.iceberg.arrow.ArrowSchemaUtil
 
convert(Types.StructType, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
convert(TypeDescription) - Static method in class org.apache.iceberg.orc.ORCSchemaUtil
Convert an ORC schema to an Iceberg schema.
convert(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil
Converts a Parquet schema to an Iceberg schema.
convert(Filter) - Static method in class org.apache.iceberg.spark.SparkFilters
 
convert(Filter[]) - Static method in class org.apache.iceberg.spark.SparkFilters
 
convert(DataType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Spark struct to a Type with new field ids.
convert(StructType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Spark struct to a Schema with new field ids.
convert(StructType, boolean) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Convert a Spark struct to a Schema with new field ids.
convertAndPrune(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil
Converts a Parquet schema to an Iceberg schema and prunes fields without IDs.
convertConstant(Type, Object) - Static method in class org.apache.iceberg.data.IdentityPartitionConverters
Conversions from internal representations to Iceberg generic values.
convertConstant(Type, Object) - Static method in class org.apache.iceberg.flink.data.RowDataUtil
 
convertDeleteFiles(Iterable<DeleteFile>) - Method in interface org.apache.iceberg.actions.ConvertEqualityDeleteStrategy
Define how to convert the deletes.
convertedEqualityDeleteFilesCount() - Method in interface org.apache.iceberg.actions.ConvertEqualityDeleteFiles.Result
Returns the count of the deletes that been converted.
ConvertEqualityDeleteFiles - Interface in org.apache.iceberg.actions
An action for converting the equality delete files to position delete files.
ConvertEqualityDeleteFiles.Result - Interface in org.apache.iceberg.actions
The action result that contains a summary of the execution.
ConvertEqualityDeleteStrategy - Interface in org.apache.iceberg.actions
A strategy for the action to convert equality delete to position deletes.
convertToByteBuffer(UUID) - Static method in class org.apache.iceberg.util.UUIDUtil
 
convertTypes(Types.StructType, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil
 
copy() - Method in interface org.apache.iceberg.ContentFile
Copies this file.
copy() - Method in class org.apache.iceberg.data.GenericRecord
 
copy() - Method in interface org.apache.iceberg.data.Record
 
copy() - Method in interface org.apache.iceberg.encryption.EncryptionKeyMetadata
 
copy() - Method in class org.apache.iceberg.flink.IcebergTableSink
 
copy() - Method in class org.apache.iceberg.flink.IcebergTableSource
 
copy() - Method in class org.apache.iceberg.GenericManifestFile
 
copy() - Method in class org.apache.iceberg.GenericPartitionFieldSummary
 
copy() - Method in interface org.apache.iceberg.ManifestFile
Copies this manifest file.
copy() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary
Copies this summary.
copy() - Method in class org.apache.iceberg.PartitionKey
 
copy() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
copy() - Method in class org.apache.iceberg.spark.SparkDataFile
 
copy(String, Object) - Method in interface org.apache.iceberg.data.Record
 
copy(String, Object, String, Object) - Method in interface org.apache.iceberg.data.Record
 
copy(String, Object, String, Object, String, Object) - Method in interface org.apache.iceberg.data.Record
 
copy(ByteBuffer) - Static method in class org.apache.iceberg.util.ByteBuffers
 
copy(Map<String, Object>) - Method in class org.apache.iceberg.data.GenericRecord
 
copy(Map<String, Object>) - Method in interface org.apache.iceberg.data.Record
 
copy(DataFile) - Method in class org.apache.iceberg.DataFiles.Builder
 
copy(DeleteFile) - Method in class org.apache.iceberg.FileMetadata.Builder
 
copy(PartitionSpec, StructLike) - Static method in class org.apache.iceberg.DataFiles
 
COPY_ON_WRITE - org.apache.iceberg.RowLevelOperationMode
 
copyFrom(IcebergSqlExtensionsParser.CallArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallArgumentContext
 
copyFrom(IcebergSqlExtensionsParser.ConstantContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ConstantContext
 
copyFrom(IcebergSqlExtensionsParser.IdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IdentifierContext
 
copyFrom(IcebergSqlExtensionsParser.NumberContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NumberContext
 
copyFrom(IcebergSqlExtensionsParser.StatementContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StatementContext
 
copyFrom(IcebergSqlExtensionsParser.TransformContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TransformContext
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergBinaryObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergDateObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergDecimalObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergFixedObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimeObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimestampObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergTimestampWithZoneObjectInspector
 
copyObject(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergUUIDObjectInspector
 
copyOf(Map<K, V>) - Static method in class org.apache.iceberg.util.SerializableMap
 
copyOf(ManifestFile) - Static method in class org.apache.iceberg.GenericManifestFile
 
copyOf(Table) - Static method in class org.apache.iceberg.SerializableTable
Creates a read-only serializable table that can be sent to other nodes in a cluster.
copyOnWriteDeleteDistributionMode() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
copyOnWriteMergeDistributionMode() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
copyOnWriteUpdateDistributionMode() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
copyWithoutStats() - Method in interface org.apache.iceberg.ContentFile
Copies this file without file stats.
copyWithoutStats() - Method in class org.apache.iceberg.spark.SparkDataFile
 
Counts() - Constructor for class org.apache.iceberg.MetricsModes.Counts
 
create() - Method in class org.apache.iceberg.aws.s3.S3OutputFile
Create an output stream for the specified location if the target object does not exist in S3 at the time of invocation.
create() - Method in class org.apache.iceberg.BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder
 
create() - Method in interface org.apache.iceberg.catalog.Catalog.TableBuilder
Creates the table.
create() - Static method in class org.apache.iceberg.deletes.PositionDelete
 
create() - Method in class org.apache.iceberg.flink.sink.RowDataTaskWriterFactory
 
create() - Method in interface org.apache.iceberg.flink.sink.TaskWriterFactory
Initialize a TaskWriter with given task id and attempt id.
create() - Method in class org.apache.iceberg.gcp.gcs.GCSOutputFile
Create an output stream for the specified location if the target object does not exist in GCS at the time of invocation.
create() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile
 
create() - Method in interface org.apache.iceberg.io.OutputFile
Create a new file and return a PositionOutputStream to it.
create() - Method in class org.apache.iceberg.orc.OrcValueReaders.StructReader
 
create(Map<Integer, PartitionSpec>) - Static method in class org.apache.iceberg.util.PartitionSet
 
create(Schema) - Static method in class org.apache.iceberg.data.avro.DataWriter
 
create(RowType, Types.StructType, Types.StructType) - Static method in class org.apache.iceberg.flink.data.RowDataProjection
Creates a projecting wrapper for RowData rows.
create(Schema) - Static method in class org.apache.iceberg.data.GenericRecord
 
create(Schema) - Static method in class org.apache.iceberg.mapping.MappingUtil
Create a name-based mapping for a schema.
create(Schema) - Static method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergObjectInspector
 
create(Schema, String) - Method in interface org.apache.iceberg.Tables
 
create(Schema, Set<Integer>) - Static method in class org.apache.iceberg.util.StructProjection
Creates a projecting wrapper for StructLike rows.
create(Schema, Schema) - Static method in class org.apache.iceberg.data.avro.DataReader
 
create(Schema, Schema, Map<Integer, ?>) - Static method in class org.apache.iceberg.data.avro.DataReader
 
create(Schema, PartitionSpec, String) - Method in interface org.apache.iceberg.Tables
 
create(Schema, PartitionSpec, Map<String, String>, String) - Method in interface org.apache.iceberg.Tables
 
create(Schema, PartitionSpec, SortOrder, Map<String, String>, String) - Method in class org.apache.iceberg.hadoop.HadoopTables
Create a table using the FileSystem implementation resolve from location.
create(Schema, PartitionSpec, SortOrder, Map<String, String>, String) - Method in interface org.apache.iceberg.Tables
 
create(Schema, Schema) - Static method in class org.apache.iceberg.flink.data.RowDataProjection
Creates a projecting wrapper for RowData rows.
create(Schema, Schema) - Static method in class org.apache.iceberg.util.StructProjection
Creates a projecting wrapper for StructLike rows.
create(Types.NestedField...) - Static method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergObjectInspector
 
create(Types.StructType) - Static method in class org.apache.iceberg.data.GenericRecord
 
create(Types.StructType) - Static method in class org.apache.iceberg.util.StructLikeMap
 
create(Types.StructType) - Static method in class org.apache.iceberg.util.StructLikeSet
 
create(Types.StructType, Types.StructType) - Static method in class org.apache.iceberg.util.StructProjection
Creates a projecting wrapper for StructLike rows.
createAllowMissing(Types.StructType, Types.StructType) - Static method in class org.apache.iceberg.util.StructProjection
Creates a projecting wrapper for StructLike rows.
createBatchedReaderFunc(Function<TypeDescription, OrcBatchReader<?>>) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
createBatchedReaderFunc(Function<MessageType, VectorizedReader<?>>) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
createBatchWriterFactory(PhysicalWriteInfo) - Method in interface org.apache.spark.sql.connector.iceberg.write.DeltaBatchWrite
 
createCatalog(String, Map<String, String>) - Method in class org.apache.iceberg.flink.FlinkCatalogFactory
 
createCatalog(String, Map<String, String>, Configuration) - Method in class org.apache.iceberg.flink.FlinkCatalogFactory
 
createDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
createDynamicTableSink(DynamicTableFactory.Context) - Method in class org.apache.iceberg.flink.FlinkDynamicTableFactory
 
createDynamicTableSource(DynamicTableFactory.Context) - Method in class org.apache.iceberg.flink.FlinkDynamicTableFactory
 
createFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
createInputSplits(int) - Method in class org.apache.iceberg.flink.source.FlinkInputFormat
 
createKey() - Method in class org.apache.iceberg.mr.mapred.AbstractMapredIcebergRecordReader
 
createMetadataTableInstance(TableOperations, String, String, MetadataTableType) - Static method in class org.apache.iceberg.MetadataTableUtils
 
createMetadataTableInstance(TableOperations, String, TableIdentifier, TableIdentifier, MetadataTableType) - Static method in class org.apache.iceberg.MetadataTableUtils
 
createMetadataTableInstance(Table, MetadataTableType) - Static method in class org.apache.iceberg.MetadataTableUtils
 
createNamespace(String[], Map<String, String>) - Method in class org.apache.iceberg.spark.SparkCatalog
 
createNamespace(String[], Map<String, String>) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
createNamespace(Namespace) - Method in interface org.apache.iceberg.catalog.SupportsNamespaces
Create a namespace in the catalog.
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.aws.glue.GlueCatalog
 
createNamespace(Namespace, Map<String, String>) - Method in interface org.apache.iceberg.catalog.SupportsNamespaces
Create a namespace in the catalog.
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.hive.HiveCatalog
 
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.jdbc.JdbcCatalog
 
createNamespace(Namespace, Map<String, String>) - Method in class org.apache.iceberg.nessie.NessieCatalog
creating namespaces in nessie is implicit, therefore this is a no-op.
createNanValueCounts(Stream<FieldMetrics<?>>, MetricsConfig, Schema) - Static method in class org.apache.iceberg.MetricsUtil
Construct mapping relationship between column id to NaN value counts from input metrics and metrics config.
createOrOverwrite() - Method in class org.apache.iceberg.aws.s3.S3OutputFile
 
createOrOverwrite() - Method in class org.apache.iceberg.gcp.gcs.GCSOutputFile
 
createOrOverwrite() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile
 
createOrOverwrite() - Method in interface org.apache.iceberg.io.OutputFile
Create a new file and return a PositionOutputStream to it.
createOrReplaceTableTransaction(String, TableOperations, TableMetadata) - Static method in class org.apache.iceberg.Transactions
 
createOrReplaceTransaction() - Method in class org.apache.iceberg.BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder
 
createOrReplaceTransaction() - Method in interface org.apache.iceberg.catalog.Catalog.TableBuilder
Starts a transaction to create or replace the table.
createPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
createReader(Schema, MessageType) - Method in class org.apache.iceberg.data.parquet.BaseParquetReaders
 
createReader(Schema, MessageType, Map<Integer, ?>) - Method in class org.apache.iceberg.data.parquet.BaseParquetReaders
 
createReaderFactory() - Method in class org.apache.iceberg.spark.source.SparkMicroBatchStream
 
createReaderFunc(BiFunction<Schema, Schema, DatumReader<?>>) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder
 
createReaderFunc(Function<Schema, DatumReader<?>>) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder
 
createReaderFunc(Function<TypeDescription, OrcRowReader<?>>) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
createReaderFunc(Function<MessageType, ParquetValueReader<?>>) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.iceberg.mr.mapreduce.IcebergInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.iceberg.pig.IcebergPigInputFormat
 
CreateSnapshotEvent - Class in org.apache.iceberg.events
 
CreateSnapshotEvent(String, String, long, long, Map<String, String>) - Constructor for class org.apache.iceberg.events.CreateSnapshotEvent
 
createStructReader(List<Type>, List<ParquetValueReader<?>>, Types.StructType) - Method in class org.apache.iceberg.data.parquet.BaseParquetReaders
 
createStructReader(List<Type>, List<ParquetValueReader<?>>, Types.StructType) - Method in class org.apache.iceberg.data.parquet.GenericParquetReaders
 
createStructReader(Types.StructType, List<ValueReader<?>>, Map<Integer, ?>) - Method in class org.apache.iceberg.data.avro.DataReader
 
createStructWriter(List<ValueWriter<?>>) - Method in class org.apache.iceberg.data.avro.DataWriter
 
createStructWriter(List<ParquetValueWriter<?>>) - Method in class org.apache.iceberg.data.parquet.BaseParquetWriter
 
createStructWriter(List<ParquetValueWriter<?>>) - Method in class org.apache.iceberg.data.parquet.GenericParquetWriter
 
createTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
createTable(Configuration, Properties) - Static method in class org.apache.iceberg.mr.Catalogs
Creates an Iceberg table using the catalog specified by the configuration.
createTable(TableIdentifier, Schema) - Method in interface org.apache.iceberg.catalog.Catalog
Create an unpartitioned table.
createTable(TableIdentifier, Schema, PartitionSpec) - Method in interface org.apache.iceberg.catalog.Catalog
Create a table.
createTable(TableIdentifier, Schema, PartitionSpec, String, Map<String, String>) - Method in interface org.apache.iceberg.catalog.Catalog
Create a table.
createTable(TableIdentifier, Schema, PartitionSpec, Map<String, String>) - Method in interface org.apache.iceberg.catalog.Catalog
Create a table.
createTable(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.iceberg.spark.SparkCatalog
 
createTable(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
createTableTransaction(String, TableOperations, TableMetadata) - Static method in class org.apache.iceberg.Transactions
 
createTransaction() - Method in class org.apache.iceberg.BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder
 
createTransaction() - Method in interface org.apache.iceberg.catalog.Catalog.TableBuilder
Starts a transaction to create the table.
createVectorSchemaRootFromVectors() - Method in class org.apache.iceberg.arrow.vectorized.ColumnarBatch
Create a new instance of VectorSchemaRoot from the arrow vectors stored in this arrow batch.
createWriter(int, long) - Method in interface org.apache.spark.sql.connector.iceberg.write.DeltaWriterFactory
 
createWriter(MessageType) - Method in class org.apache.iceberg.data.parquet.BaseParquetWriter
 
createWriterFunc(BiFunction<Schema, TypeDescription, OrcRowWriter<?>>) - Method in class org.apache.iceberg.orc.ORC.DataWriteBuilder
 
createWriterFunc(BiFunction<Schema, TypeDescription, OrcRowWriter<?>>) - Method in class org.apache.iceberg.orc.ORC.DeleteWriteBuilder
 
createWriterFunc(BiFunction<Schema, TypeDescription, OrcRowWriter<?>>) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder
 
createWriterFunc(Function<Schema, DatumWriter<?>>) - Method in class org.apache.iceberg.avro.Avro.DataWriteBuilder
 
createWriterFunc(Function<Schema, DatumWriter<?>>) - Method in class org.apache.iceberg.avro.Avro.DeleteWriteBuilder
 
createWriterFunc(Function<Schema, DatumWriter<?>>) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder
 
createWriterFunc(Function<MessageType, ParquetValueWriter<?>>) - Method in class org.apache.iceberg.parquet.Parquet.DataWriteBuilder
 
createWriterFunc(Function<MessageType, ParquetValueWriter<?>>) - Method in class org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder
 
createWriterFunc(Function<MessageType, ParquetValueWriter<?>>) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder
 
ctorImpl(Class<?>, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder
 
ctorImpl(String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder
 
current() - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
current() - Method in class org.apache.iceberg.hadoop.HadoopTableOperations
 
current() - Method in class org.apache.iceberg.StaticTableOperations
 
current() - Method in interface org.apache.iceberg.TableOperations
Return the currently loaded table metadata, without checking for updates.
currentAncestorIds(Table) - Static method in class org.apache.iceberg.util.SnapshotUtil
Return the snapshot IDs for the ancestors of the current table state.
currentAncestors(Table) - Static method in class org.apache.iceberg.util.SnapshotUtil
Returns an iterable that traverses the table's snapshots from the current to the last known ancestor.
currentDefinitionLevel() - Method in class org.apache.iceberg.parquet.ColumnIterator
 
currentDL - Variable in class org.apache.iceberg.parquet.BasePageIterator
 
currentFieldName() - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
currentHash() - Method in class org.apache.iceberg.nessie.NessieCatalog
 
currentMetadataLocation() - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
currentPageCount() - Method in class org.apache.iceberg.parquet.BasePageIterator
 
currentPath() - Method in class org.apache.iceberg.flink.data.ParquetWithFlinkSchemaVisitor
 
currentPath() - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
currentPath() - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor
 
currentPath() - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor
 
currentPath() - Method in class org.apache.iceberg.spark.data.ParquetWithSparkSchemaVisitor
 
currentRepetitionLevel() - Method in class org.apache.iceberg.parquet.ColumnIterator
 
currentRL - Variable in class org.apache.iceberg.parquet.BasePageIterator
 
currentSchemaId() - Method in class org.apache.iceberg.TableMetadata
 
currentSnapshot() - Method in class org.apache.iceberg.BaseTable
 
currentSnapshot() - Method in class org.apache.iceberg.SerializableTable
 
currentSnapshot() - Method in interface org.apache.iceberg.Table
Get the current snapshot for this table, or null if there are no snapshots.
currentSnapshot() - Method in class org.apache.iceberg.TableMetadata
 
currentVersion() - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
custom(String, Map<String, String>, Configuration, String) - Static method in interface org.apache.iceberg.flink.CatalogLoader
 
CustomOrderSchemaVisitor() - Constructor for class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor
 

D

data(PartitionSpec, String) - Static method in class org.apache.iceberg.DataFiles
 
DATA - org.apache.iceberg.FileContent
 
DATA - org.apache.iceberg.ManifestContent
 
DATA_FILES - org.apache.iceberg.ManifestReader.FileType
 
databaseExists(String) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
DataFile - Interface in org.apache.iceberg
Interface for data files listed in a table manifest.
dataFileFormat() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
dataFiles() - Method in class org.apache.iceberg.io.DataWriteResult
 
dataFiles() - Method in interface org.apache.iceberg.io.TaskWriter
Close the writer and get the completed data files, it requires that the task writer would produce data files only.
dataFiles() - Method in class org.apache.iceberg.io.WriteResult
 
DataFiles - Class in org.apache.iceberg
 
DataFiles.Builder - Class in org.apache.iceberg
 
DataFilesTable - Class in org.apache.iceberg
A Table implementation that exposes a table's data files as rows.
DataFilesTable.FilesTableScan - Class in org.apache.iceberg
 
DataIterator<T> - Class in org.apache.iceberg.flink.source
Flink data iterator that reads CombinedScanTask into a CloseableIterator
DataIterator(FileScanTaskReader<T>, CombinedScanTask, FileIO, EncryptionManager) - Constructor for class org.apache.iceberg.flink.source.DataIterator
 
dataManifests() - Method in interface org.apache.iceberg.Snapshot
Return a ManifestFile for each data manifest in this snapshot.
DataOperations - Class in org.apache.iceberg
Data operations that produce snapshots.
DataReader<T> - Class in org.apache.iceberg.data.avro
 
DataReader(Schema, Schema, Map<Integer, ?>) - Constructor for class org.apache.iceberg.data.avro.DataReader
 
dataSchema() - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
DataTableScan - Class in org.apache.iceberg
 
DataTableScan(TableOperations, Table) - Constructor for class org.apache.iceberg.DataTableScan
 
DataTableScan(TableOperations, Table, Schema, TableScanContext) - Constructor for class org.apache.iceberg.DataTableScan
 
DataTask - Interface in org.apache.iceberg
A task that returns data as rows instead of where to read data.
dataTimestampMillis() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics
 
dataType() - Method in class org.apache.iceberg.spark.source.SparkMetadataColumn
 
dataType() - Method in interface org.apache.spark.sql.connector.iceberg.catalog.ProcedureParameter
Returns the type of this parameter.
DataWriter<T> - Class in org.apache.iceberg.data.avro
 
DataWriter<T> - Class in org.apache.iceberg.io
 
DataWriter(Schema) - Constructor for class org.apache.iceberg.data.avro.DataWriter
 
DataWriter(FileAppender<T>, FileFormat, String, PartitionSpec, StructLike, EncryptionKeyMetadata) - Constructor for class org.apache.iceberg.io.DataWriter
 
DataWriter(FileAppender<T>, FileFormat, String, PartitionSpec, StructLike, EncryptionKeyMetadata, SortOrder) - Constructor for class org.apache.iceberg.io.DataWriter
 
DataWriteResult - Class in org.apache.iceberg.io
A result of writing data files.
DataWriteResult(List<DataFile>) - Constructor for class org.apache.iceberg.io.DataWriteResult
 
DataWriteResult(DataFile) - Constructor for class org.apache.iceberg.io.DataWriteResult
 
DATE - org.apache.iceberg.types.Type.TypeID
 
DATE_INSPECTOR - Static variable in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergObjectInspector
 
dateFromDays(int) - Static method in class org.apache.iceberg.util.DateTimeUtil
 
dates() - Static method in class org.apache.iceberg.data.orc.GenericOrcReaders
 
dates() - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
DateTimeUtil - Class in org.apache.iceberg.util
 
DateType() - Constructor for class org.apache.iceberg.types.Types.DateType
 
day(int, String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor
 
day(String) - Static method in class org.apache.iceberg.expressions.Expressions
 
day(String) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
day(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor
 
day(String, int, SortDirection, NullOrder) - Method in interface org.apache.iceberg.transforms.SortOrderVisitor
 
day(String, String) - Method in class org.apache.iceberg.PartitionSpec.Builder
 
day(Type) - Static method in class org.apache.iceberg.transforms.Transforms
Returns a day Transform for date or timestamp types.
daysFromDate(LocalDate) - Static method in class org.apache.iceberg.util.DateTimeUtil
 
daysFromInstant(Instant) - Static method in class org.apache.iceberg.util.DateTimeUtil
 
decimal(int, int) - Static method in class org.apache.iceberg.avro.ValueWriters
 
decimal(int, int) - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
decimal(ValueReader<byte[]>, int) - Static method in class org.apache.iceberg.avro.ValueReaders
 
DECIMAL - org.apache.iceberg.types.Type.TypeID
 
DECIMAL_64 - org.apache.hadoop.hive.ql.exec.vector.VectorizedSupport.Support
 
DECIMAL_INT32_MAX_DIGITS - Static variable in class org.apache.iceberg.parquet.TypeToMessageType
 
DECIMAL_INT64_MAX_DIGITS - Static variable in class org.apache.iceberg.parquet.TypeToMessageType
 
DECIMAL_VALUE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
DECIMAL_VALUE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
DECIMAL_VALUE() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DecimalLiteralContext
 
decimalAsFixed(ColumnDescriptor, int, int) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
decimalAsInteger(ColumnDescriptor, int, int) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
decimalAsLong(ColumnDescriptor, int, int) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
decimalBytesReader(Schema) - Static method in class org.apache.iceberg.avro.ValueReaders
 
DecimalLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DecimalLiteralContext
 
decimalRequiredBytes(int) - Static method in class org.apache.iceberg.types.TypeUtil
 
decimals() - Static method in class org.apache.iceberg.data.orc.GenericOrcReaders
 
decimals(int, int) - Static method in class org.apache.iceberg.spark.data.SparkOrcValueReaders
 
DecimalUtil - Class in org.apache.iceberg.util
 
decode(byte[]) - Static method in class org.apache.iceberg.avro.AvroEncoderUtil
 
decode(byte[]) - Static method in class org.apache.iceberg.ManifestFiles
Decode the binary data into a ManifestFile.
decode(InputStream, D) - Method in class org.apache.iceberg.data.avro.IcebergDecoder
 
DecoderResolver - Class in org.apache.iceberg.data.avro
Resolver to resolve Decoder to a ResolvingDecoder.
decomposePredicate(JobConf, Deserializer, ExprNodeDesc) - Method in class org.apache.iceberg.mr.hive.HiveIcebergStorageHandler
 
decrypt(Iterable<EncryptedInputFile>) - Method in interface org.apache.iceberg.encryption.EncryptionManager
Variant of EncryptionManager.decrypt(EncryptedInputFile) that provides a sequence of files that all need to be decrypted in a single context.
decrypt(EncryptedInputFile) - Method in interface org.apache.iceberg.encryption.EncryptionManager
Given an EncryptedInputFile.encryptedInputFile() representing the raw encrypted bytes from the underlying file system, and given metadata about how the file was encrypted via EncryptedInputFile.keyMetadata(), return an InputFile that returns decrypted input streams.
decrypt(EncryptedInputFile) - Method in class org.apache.iceberg.encryption.PlaintextEncryptionManager
 
decryptionKey() - Method in class org.apache.iceberg.gcp.GCPProperties
 
dedupName() - Method in interface org.apache.iceberg.transforms.Transform
Return the unique transform name to check if similar transforms for the same source field are added multiple times in partition spec builder.
DEFAULT_BATCH_SIZE - Static variable in class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
 
DEFAULT_DATABASE - Static variable in class org.apache.iceberg.flink.FlinkCatalogFactory
 
DEFAULT_DATABASE_NAME - Static variable in class org.apache.iceberg.flink.FlinkCatalogFactory
 
DEFAULT_FILE_FORMAT - Static variable in class org.apache.iceberg.TableProperties
 
DEFAULT_FILE_FORMAT_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
DEFAULT_NAME_MAPPING - Static variable in class org.apache.iceberg.TableProperties
 
DEFAULT_WRITE_METRICS_MODE - Static variable in class org.apache.iceberg.TableProperties
 
DEFAULT_WRITE_METRICS_MODE_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
defaultAlwaysNull() - Method in class org.apache.iceberg.common.DynFields.Builder
Instructs this builder to return AlwaysNull if no implementation is found.
defaultFactory() - Static method in class org.apache.iceberg.aliyun.AliyunClientFactories
 
defaultFactory() - Static method in class org.apache.iceberg.aws.AwsClientFactories
 
defaultFormat(FileFormat) - Method in interface org.apache.iceberg.UpdateProperties
Set the default file format for the table.
defaultLocationProperty() - Static method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
The property used to set a default location for tables in a namespace.
defaultLockManager() - Static method in class org.apache.iceberg.util.LockManagers
 
defaultNamespace() - Method in class org.apache.iceberg.spark.SparkCatalog
 
defaultNamespace() - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
defaultSortOrderId() - Method in class org.apache.iceberg.TableMetadata
 
defaultSpec(PartitionSpec) - Method in class org.apache.iceberg.io.OutputFileFactory.Builder
 
defaultSpecId() - Method in class org.apache.iceberg.TableMetadata
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.aws.glue.GlueCatalog
This method produces the same result as using a HiveCatalog.
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.BaseMetastoreCatalog
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.jdbc.JdbcCatalog
 
defaultWarehouseLocation(TableIdentifier) - Method in class org.apache.iceberg.nessie.NessieCatalog
 
definitionLevels - Variable in class org.apache.iceberg.parquet.BasePageIterator
 
DelegatingInputStream - Interface in org.apache.iceberg.io
 
DelegatingOutputStream - Interface in org.apache.iceberg.io
 
delete(long) - Method in interface org.apache.iceberg.deletes.PositionDeleteIndex
Set a deleted row position.
delete(long, long) - Method in interface org.apache.iceberg.deletes.PositionDeleteIndex
Set a range of deleted row positions.
delete(F) - Method in class org.apache.iceberg.ManifestWriter
Add a delete entry for a file.
delete(CharSequence, long) - Method in class org.apache.iceberg.deletes.PositionDeleteWriter
Deprecated.
since 0.13.0, will be removed in 0.14.0; use PositionDeleteWriter.write(PositionDelete) instead.
delete(CharSequence, long, PartitionSpec, StructLike) - Method in interface org.apache.iceberg.io.PositionDeltaWriter
Deletes a position in the provided spec/partition.
delete(CharSequence, long, T) - Method in class org.apache.iceberg.deletes.PositionDeleteWriter
Deprecated.
since 0.13.0, will be removed in 0.14.0; use PositionDeleteWriter.write(PositionDelete) instead.
delete(CharSequence, long, T, PartitionSpec, StructLike) - Method in class org.apache.iceberg.io.BasePositionDeltaWriter
 
delete(CharSequence, long, T, PartitionSpec, StructLike) - Method in interface org.apache.iceberg.io.PositionDeltaWriter
Deletes a position in the provided spec/partition and records the deleted row in the delete file.
delete(T) - Method in class org.apache.iceberg.deletes.EqualityDeleteWriter
Deprecated.
since 0.13.0, will be removed in 0.14.0; use EqualityDeleteWriter.write(Object) instead.
delete(T) - Method in class org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter
Delete those rows whose equality fields has the same values with the given row.
delete(T, PartitionSpec, StructLike) - Method in interface org.apache.iceberg.io.EqualityDeltaWriter
Deletes a row from the provided spec/partition.
delete(T, T) - Method in interface org.apache.spark.sql.connector.iceberg.write.DeltaWriter
Passes information for a row that must be deleted.
DELETE - org.apache.spark.sql.connector.iceberg.write.RowLevelOperation.Command
 
DELETE - Static variable in class org.apache.iceberg.DataOperations
Data is deleted from the table and no data is added.
DELETE_AVRO_COMPRESSION - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_DEFAULT_FILE_FORMAT - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_DISTRIBUTION_MODE - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_FILE_PATH - Static variable in class org.apache.iceberg.MetadataColumns
 
DELETE_FILE_POS - Static variable in class org.apache.iceberg.MetadataColumns
 
DELETE_FILE_ROW_DOC - Static variable in class org.apache.iceberg.MetadataColumns
 
DELETE_FILE_ROW_FIELD_ID - Static variable in class org.apache.iceberg.MetadataColumns
 
DELETE_FILE_ROW_FIELD_NAME - Static variable in class org.apache.iceberg.MetadataColumns
 
DELETE_FILE_THRESHOLD - Static variable in class org.apache.iceberg.actions.BinPackStrategy
The minimum number of deletes that needs to be associated with a data file for it to be considered for rewriting.
DELETE_FILE_THRESHOLD_DEFAULT - Static variable in class org.apache.iceberg.actions.BinPackStrategy
 
DELETE_FILES - org.apache.iceberg.ManifestReader.FileType
 
DELETE_FORMAT - Static variable in class org.apache.iceberg.spark.SparkWriteOptions
 
DELETE_ISOLATION_LEVEL - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_ISOLATION_LEVEL_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_MODE - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_MODE_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_PARQUET_COMPRESSION - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_PARQUET_COMPRESSION_LEVEL - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_PARQUET_DICT_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_PARQUET_PAGE_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_PARQUET_ROW_GROUP_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_TARGET_FILE_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties
 
DELETE_TARGET_FILE_SIZE_BYTES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
deleteAll(Iterable<T>) - Method in class org.apache.iceberg.deletes.EqualityDeleteWriter
Deprecated.
since 0.13.0, will be removed in 0.14.0; use FileWriter.write(Iterable) instead.
deleteColumn(String) - Method in interface org.apache.iceberg.UpdateSchema
Delete a column in the schema.
DELETED_DUPLICATE_FILES - Static variable in class org.apache.iceberg.SnapshotSummary
 
DELETED_FILES_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
DELETED_FILES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
DELETED_RECORDS_PROP - Static variable in class org.apache.iceberg.SnapshotSummary
 
DELETED_ROWS_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
deletedDataFiles() - Method in class org.apache.iceberg.actions.RewriteDataFilesActionResult
 
deletedDataFilesCount() - Method in class org.apache.iceberg.actions.BaseDeleteReachableFilesActionResult
 
deletedDataFilesCount() - Method in class org.apache.iceberg.actions.BaseExpireSnapshotsActionResult
 
deletedDataFilesCount() - Method in interface org.apache.iceberg.actions.DeleteReachableFiles.Result
Returns the number of deleted data files.
deletedDataFilesCount() - Method in interface org.apache.iceberg.actions.ExpireSnapshots.Result
Returns the number of deleted data files.
deletedFile(PartitionSpec, ContentFile<?>) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
deletedFile(PartitionSpec, DataFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
deletedFile(PartitionSpec, DeleteFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder
 
deletedFiles() - Method in interface org.apache.iceberg.Snapshot
Return all files deleted from the table in this snapshot.
deletedFilesCount() - Method in class org.apache.iceberg.GenericManifestFile
 
deletedFilesCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the number of data files with status DELETED in the manifest file.
deletedFilesCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
deletedManifestListsCount() - Method in class org.apache.iceberg.actions.BaseDeleteReachableFilesActionResult
 
deletedManifestListsCount() - Method in class org.apache.iceberg.actions.BaseExpireSnapshotsActionResult
 
deletedManifestListsCount() - Method in interface org.apache.iceberg.actions.DeleteReachableFiles.Result
Returns the number of deleted manifest lists.
deletedManifestListsCount() - Method in interface org.apache.iceberg.actions.ExpireSnapshots.Result
Returns the number of deleted manifest lists.
deletedManifestsCount() - Method in class org.apache.iceberg.actions.BaseDeleteReachableFilesActionResult
 
deletedManifestsCount() - Method in class org.apache.iceberg.actions.BaseExpireSnapshotsActionResult
 
deletedManifestsCount() - Method in interface org.apache.iceberg.actions.DeleteReachableFiles.Result
Returns the number of deleted manifests.
deletedManifestsCount() - Method in interface org.apache.iceberg.actions.ExpireSnapshots.Result
Returns the number of deleted manifests.
deletedOtherFilesCount() - Method in class org.apache.iceberg.actions.BaseDeleteReachableFilesActionResult
 
deletedOtherFilesCount() - Method in interface org.apache.iceberg.actions.DeleteReachableFiles.Result
Returns the number of deleted metadata json, version hint files.
deletedRowPositions() - Method in class org.apache.iceberg.data.DeleteFilter
 
deletedRowsCount() - Method in class org.apache.iceberg.GenericManifestFile
 
deletedRowsCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the total number of rows in all data files with status DELETED in the manifest file.
deletedRowsCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
deleteFile(CharSequence) - Method in interface org.apache.iceberg.DeleteFiles
Delete a file path from the underlying table.
deleteFile(String) - Method in class org.apache.iceberg.aliyun.oss.OSSFileIO
 
deleteFile(String) - Method in class org.apache.iceberg.aws.s3.S3FileIO
 
deleteFile(String) - Method in class org.apache.iceberg.gcp.gcs.GCSFileIO
 
deleteFile(String) - Method in class org.apache.iceberg.hadoop.HadoopFileIO
 
deleteFile(String) - Method in interface org.apache.iceberg.io.FileIO
Delete the file at the given path.
deleteFile(String) - Method in class org.apache.iceberg.io.ResolvingFileIO
 
deleteFile(DataFile) - Method in class org.apache.iceberg.BaseOverwriteFiles
 
deleteFile(DataFile) - Method in interface org.apache.iceberg.DeleteFiles
Delete a file tracked by a DataFile from the underlying table.
deleteFile(DataFile) - Method in interface org.apache.iceberg.OverwriteFiles
Delete a DataFile from the table.
deleteFile(InputFile) - Method in interface org.apache.iceberg.io.FileIO
Convenience method to delete an InputFile.
deleteFile(OutputFile) - Method in interface org.apache.iceberg.io.FileIO
Convenience method to delete an OutputFile.
DeleteFile - Interface in org.apache.iceberg
Interface for delete files listed in a table delete manifest.
deleteFileBuilder(PartitionSpec) - Static method in class org.apache.iceberg.FileMetadata
 
deleteFileFormat() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
deleteFiles() - Method in class org.apache.iceberg.io.DeleteWriteResult
 
deleteFiles() - Method in class org.apache.iceberg.io.WriteResult
 
DeleteFiles - Interface in org.apache.iceberg
API for deleting files from a table.
DeleteFilter<T> - Class in org.apache.iceberg.data
 
DeleteFilter(FileScanTask, Schema, Schema) - Constructor for class org.apache.iceberg.data.DeleteFilter
 
deleteFromRowFilter(Expression) - Method in interface org.apache.iceberg.DeleteFiles
Delete files that match an Expression on data rows from the table.
deleteKey(T) - Method in class org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter
Delete those rows with the given key.
deleteKey(T, PartitionSpec, StructLike) - Method in interface org.apache.iceberg.io.EqualityDeltaWriter
Deletes a key from the provided spec/partition.
deleteManifest(ManifestFile) - Method in class org.apache.iceberg.BaseRewriteManifests
 
deleteManifest(ManifestFile) - Method in interface org.apache.iceberg.RewriteManifests
Deletes a manifest file from the table.
deleteManifests() - Method in interface org.apache.iceberg.Snapshot
Return a ManifestFile for each delete manifest in this snapshot.
deleteOrphanFiles(Table) - Method in interface org.apache.iceberg.actions.ActionsProvider
Instantiates an action to delete orphan files.
DeleteOrphanFiles - Interface in org.apache.iceberg.actions
An action that deletes orphan files in a table.
DeleteOrphanFiles.Result - Interface in org.apache.iceberg.actions
The action result that contains a summary of the execution.
deletePositions(CharSequence, List<CloseableIterable<T>>) - Static method in class org.apache.iceberg.deletes.Deletes
 
deletePositions(CharSequence, CloseableIterable<StructLike>) - Static method in class org.apache.iceberg.deletes.Deletes
 
deleteReachableFiles(String) - Method in interface org.apache.iceberg.actions.ActionsProvider
Instantiates an action to delete all the files reachable from given metadata location.
DeleteReachableFiles - Interface in org.apache.iceberg.actions
An action that deletes all files referenced by a table metadata file.
DeleteReachableFiles.Result - Interface in org.apache.iceberg.actions
The action result that contains a summary of the execution.
deletes() - Method in interface org.apache.iceberg.FileScanTask
A list of delete files to apply when reading the task's data file.
Deletes - Class in org.apache.iceberg.deletes
 
DELETES - org.apache.iceberg.ManifestContent
 
DeleteSchemaUtil - Class in org.apache.iceberg.io
 
deleteWhere(Filter[]) - Method in class org.apache.iceberg.spark.RollbackStagedTable
 
deleteWhere(Filter[]) - Method in class org.apache.iceberg.spark.source.SparkTable
 
deleteWith(Consumer<String>) - Method in interface org.apache.iceberg.actions.DeleteOrphanFiles
Passes an alternative delete implementation that will be used for orphan files.
deleteWith(Consumer<String>) - Method in interface org.apache.iceberg.actions.DeleteReachableFiles
Passes an alternative delete implementation that will be used for files.
deleteWith(Consumer<String>) - Method in interface org.apache.iceberg.actions.ExpireSnapshots
Passes an alternative delete implementation that will be used for manifests and data files.
deleteWith(Consumer<String>) - Method in interface org.apache.iceberg.ExpireSnapshots
Passes an alternative delete implementation that will be used for manifests and data files.
deleteWith(Consumer<String>) - Method in interface org.apache.iceberg.SnapshotUpdate
Set a callback to delete files instead of the table's default.
deleteWith(Consumer<String>) - Method in class org.apache.iceberg.spark.actions.BaseDeleteOrphanFilesSparkAction
 
deleteWith(Consumer<String>) - Method in class org.apache.iceberg.spark.actions.BaseDeleteReachableFilesSparkAction
 
deleteWith(Consumer<String>) - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
DeleteWriteResult - Class in org.apache.iceberg.io
A result of writing delete files.
DeleteWriteResult(List<DeleteFile>) - Constructor for class org.apache.iceberg.io.DeleteWriteResult
 
DeleteWriteResult(List<DeleteFile>, CharSequenceSet) - Constructor for class org.apache.iceberg.io.DeleteWriteResult
 
DeleteWriteResult(DeleteFile) - Constructor for class org.apache.iceberg.io.DeleteWriteResult
 
DeleteWriteResult(DeleteFile, CharSequenceSet) - Constructor for class org.apache.iceberg.io.DeleteWriteResult
 
DeltaBatchWrite - Interface in org.apache.spark.sql.connector.iceberg.write
An interface that defines how to write a delta of rows during batch processing.
DeltaWrite - Interface in org.apache.spark.sql.connector.iceberg.write
A logical representation of a data source write that handles a delta of rows.
DeltaWriteBuilder - Interface in org.apache.spark.sql.connector.iceberg.write
An interface for building delta writes.
DeltaWriter<T> - Interface in org.apache.spark.sql.connector.iceberg.write
A data writer responsible for writing a delta of rows.
DeltaWriterFactory - Interface in org.apache.spark.sql.connector.iceberg.write
A factory for creating and initializing delta writers at the executor side.
desc - Variable in class org.apache.iceberg.parquet.BaseColumnIterator
 
desc - Variable in class org.apache.iceberg.parquet.BasePageIterator
 
desc(String) - Method in interface org.apache.iceberg.SortOrderBuilder
Add a field to the sort by field name, ascending with nulls first.
desc(String, NullOrder) - Method in interface org.apache.iceberg.SortOrderBuilder
Add a field to the sort by field name, ascending with the given null order.
desc(Term) - Method in interface org.apache.iceberg.SortOrderBuilder
Add an expression term to the sort, ascending with nulls first.
desc(Term, NullOrder) - Method in class org.apache.iceberg.BaseReplaceSortOrder
 
desc(Term, NullOrder) - Method in class org.apache.iceberg.SortOrder.Builder
Add an expression term to the sort, ascending with the given null order.
desc(Term, NullOrder) - Method in interface org.apache.iceberg.SortOrderBuilder
Add an expression term to the sort, ascending with the given null order.
DESC - org.apache.iceberg.SortDirection
 
DESC - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
DESC - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
DESC() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
DESC() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
describe(Expression) - Static method in class org.apache.iceberg.spark.Spark3Util
 
describe(Schema) - Static method in class org.apache.iceberg.spark.Spark3Util
 
describe(SortOrder) - Static method in class org.apache.iceberg.spark.Spark3Util
 
describe(Type) - Static method in class org.apache.iceberg.spark.Spark3Util
 
description() - Method in class org.apache.iceberg.spark.JobGroupInfo
 
description() - Method in class org.apache.iceberg.spark.procedures.AncestorsOfProcedure
 
description() - Method in class org.apache.iceberg.spark.procedures.ExpireSnapshotsProcedure
 
description() - Method in class org.apache.iceberg.spark.procedures.RemoveOrphanFilesProcedure
 
description() - Method in interface org.apache.spark.sql.connector.iceberg.catalog.Procedure
Returns the description of this procedure.
description() - Method in interface org.apache.spark.sql.connector.iceberg.write.RowLevelOperation
Returns the description associated with this row-level operation.
descriptor() - Method in class org.apache.iceberg.arrow.vectorized.VectorHolder
 
deserialize(int, byte[]) - Method in class org.apache.iceberg.flink.source.split.IcebergSourceSplitSerializer
 
deserialize(Writable) - Method in class org.apache.iceberg.mr.hive.HiveIcebergSerDe
 
deserializeFromBase64(String) - Static method in class org.apache.iceberg.util.SerializationUtil
 
deserializeFromBytes(byte[]) - Static method in class org.apache.iceberg.util.SerializationUtil
 
deserializeOffset(String) - Method in class org.apache.iceberg.spark.source.SparkMicroBatchStream
 
destCatalog() - Method in class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
destCatalog() - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
destTableIdent() - Method in class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
destTableIdent() - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
destTableProps() - Method in class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
destTableProps() - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
dictionary - Variable in class org.apache.iceberg.parquet.BaseColumnIterator
 
dictionary - Variable in class org.apache.iceberg.parquet.BasePageIterator
 
dictionary() - Method in class org.apache.iceberg.arrow.vectorized.VectorHolder
 
dictionaryBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
DictionaryBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.DictionaryBatchReader
 
dictionaryIdReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
direction - Variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
direction() - Method in class org.apache.iceberg.SortField
Returns the sort direction
disableRefresh() - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
discardChanges() - Method in class org.apache.iceberg.TableMetadata.Builder
 
DISTRIBUTED - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
DISTRIBUTED - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
DISTRIBUTED() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
DISTRIBUTED() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteDistributionSpecContext
 
DISTRIBUTION_MODE - Static variable in class org.apache.iceberg.spark.SparkWriteOptions
 
distributionMode() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
distributionMode(DistributionMode) - Method in class org.apache.iceberg.flink.sink.FlinkSink.Builder
Configure the write DistributionMode that the flink sink will use.
DistributionMode - Enum in org.apache.iceberg
Enum of supported write distribution mode, it defines the write behavior of batch or streaming job:
doc() - Method in class org.apache.iceberg.types.Types.NestedField
 
doCommit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
doCommit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.hive.HiveTableOperations
 
doCommit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.nessie.NessieTableOperations
 
doRefresh() - Method in class org.apache.iceberg.BaseMetastoreTableOperations
 
doRefresh() - Method in class org.apache.iceberg.hive.HiveTableOperations
 
doRefresh() - Method in class org.apache.iceberg.nessie.NessieTableOperations
 
DOUBLE - org.apache.iceberg.types.Type.TypeID
 
DOUBLE_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
DOUBLE_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
DOUBLE_LITERAL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DoubleLiteralContext
 
doubleBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
DoubleBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.DoubleBatchReader
 
doubleDictEncodedReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
DoubleFieldMetrics - Class in org.apache.iceberg
Iceberg internally tracked field level metrics, used by Parquet and ORC writers only.
DoubleFieldMetrics.Builder - Class in org.apache.iceberg
 
DoubleLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DoubleLiteralContext
 
doubles() - Static method in class org.apache.iceberg.avro.ValueReaders
 
doubles() - Static method in class org.apache.iceberg.avro.ValueWriters
 
doubles() - Static method in class org.apache.iceberg.orc.OrcValueReaders
 
doubles(int) - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
doubles(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
DoubleType() - Constructor for class org.apache.iceberg.types.Types.DoubleType
 
DROP - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
DROP - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
DROP() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
DROP() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
DROP() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
dropDatabase(String, boolean, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
dropFunction(ObjectPath, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
DropIdentifierFieldsContext(IcebergSqlExtensionsParser.StatementContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
dropNamespace(String[]) - Method in class org.apache.iceberg.spark.SparkCatalog
 
dropNamespace(String[]) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
dropNamespace(Namespace) - Method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
dropNamespace(Namespace) - Method in class org.apache.iceberg.aws.glue.GlueCatalog
 
dropNamespace(Namespace) - Method in interface org.apache.iceberg.catalog.SupportsNamespaces
Drop a namespace.
dropNamespace(Namespace) - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
dropNamespace(Namespace) - Method in class org.apache.iceberg.hive.HiveCatalog
 
dropNamespace(Namespace) - Method in class org.apache.iceberg.jdbc.JdbcCatalog
 
dropNamespace(Namespace) - Method in class org.apache.iceberg.nessie.NessieCatalog
Namespaces in Nessie are implicit and therefore cannot be dropped
dropPartition(ObjectPath, CatalogPartitionSpec, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
DropPartitionFieldContext(IcebergSqlExtensionsParser.StatementContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
dropTable(String) - Method in class org.apache.iceberg.hadoop.HadoopTables
Drop a table and delete all data and metadata files.
dropTable(String, boolean) - Method in class org.apache.iceberg.hadoop.HadoopTables
Drop a table; optionally delete data and metadata files.
dropTable(ObjectPath, boolean) - Method in class org.apache.iceberg.flink.FlinkCatalog
 
dropTable(Configuration, Properties) - Static method in class org.apache.iceberg.mr.Catalogs
Drops an Iceberg table using the catalog specified by the configuration.
dropTable(TableIdentifier) - Method in interface org.apache.iceberg.catalog.Catalog
Drop a table and delete all data and metadata files.
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.aws.glue.GlueCatalog
 
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.CachingCatalog
 
dropTable(TableIdentifier, boolean) - Method in interface org.apache.iceberg.catalog.Catalog
Drop a table; optionally delete data and metadata files.
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.hadoop.HadoopCatalog
 
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.hive.HiveCatalog
 
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.jdbc.JdbcCatalog
 
dropTable(TableIdentifier, boolean) - Method in class org.apache.iceberg.nessie.NessieCatalog
 
dropTable(Identifier) - Method in class org.apache.iceberg.spark.SparkCatalog
 
dropTable(Identifier) - Method in class org.apache.iceberg.spark.SparkSessionCatalog
 
dropTableData(FileIO, TableMetadata) - Static method in class org.apache.iceberg.CatalogUtil
Drops all data and metadata files referenced by TableMetadata.
dummyHolder(int) - Static method in class org.apache.iceberg.arrow.vectorized.VectorHolder
 
DuplicateWAPCommitException - Exception in org.apache.iceberg.exceptions
This exception occurs when the WAP workflow detects a duplicate wap commit.
DuplicateWAPCommitException(String) - Constructor for exception org.apache.iceberg.exceptions.DuplicateWAPCommitException
 
dynamo() - Method in class org.apache.iceberg.aws.AssumeRoleAwsClientFactory
 
dynamo() - Method in interface org.apache.iceberg.aws.AwsClientFactory
Create a Amazon DynamoDB client
DYNAMODB_TABLE_NAME - Static variable in class org.apache.iceberg.aws.AwsProperties
DynamoDB table name for DynamoDbCatalog
DYNAMODB_TABLE_NAME_DEFAULT - Static variable in class org.apache.iceberg.aws.AwsProperties
 
DynamoDbCatalog - Class in org.apache.iceberg.aws.dynamodb
DynamoDB implementation of Iceberg catalog
DynamoDbCatalog() - Constructor for class org.apache.iceberg.aws.dynamodb.DynamoDbCatalog
 
dynamoDbTableName() - Method in class org.apache.iceberg.aws.AwsProperties
 
DynClasses - Class in org.apache.iceberg.common
 
DynClasses.Builder - Class in org.apache.iceberg.common
 
DynConstructors - Class in org.apache.iceberg.common
Copied from parquet-common
DynConstructors.Builder - Class in org.apache.iceberg.common
 
DynConstructors.Ctor<C> - Class in org.apache.iceberg.common
 
DynFields - Class in org.apache.iceberg.common
 
DynFields.BoundField<T> - Class in org.apache.iceberg.common
 
DynFields.Builder - Class in org.apache.iceberg.common
 
DynFields.StaticField<T> - Class in org.apache.iceberg.common
 
DynFields.UnboundField<T> - Class in org.apache.iceberg.common
Convenience wrapper class around Field.
DynMethods - Class in org.apache.iceberg.common
Copied from parquet-common
DynMethods.BoundMethod - Class in org.apache.iceberg.common
 
DynMethods.Builder - Class in org.apache.iceberg.common
 
DynMethods.StaticMethod - Class in org.apache.iceberg.common
 
DynMethods.UnboundMethod - Class in org.apache.iceberg.common
Convenience wrapper class around Method.

E

ELEMENT_ID_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil
 
elementId() - Method in class org.apache.iceberg.types.Types.ListType
 
elementName() - Method in class org.apache.iceberg.orc.OrcSchemaVisitor
 
elements(L) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter
 
elementType() - Method in class org.apache.iceberg.types.Types.ListType
 
empty() - Static method in class org.apache.iceberg.actions.BaseRewriteManifestsActionResult
 
empty() - Static method in class org.apache.iceberg.catalog.Namespace
 
empty() - Static method in interface org.apache.iceberg.encryption.EncryptionKeyMetadata
 
empty() - Static method in interface org.apache.iceberg.io.CloseableIterable
 
empty() - Static method in interface org.apache.iceberg.io.CloseableIterator
 
empty() - Static method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergRecordObjectInspector
 
empty() - Static method in class org.apache.iceberg.util.CharSequenceSet
 
EMPTY - Static variable in interface org.apache.iceberg.encryption.EncryptionKeyMetadata
 
EMPTY_BOOLEAN_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_BYTE_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_DOUBLE_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_FLOAT_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_INT_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_LONG_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
EMPTY_SHORT_ARRAY - Static variable in class org.apache.iceberg.util.ArrayUtil
 
encode(D) - Method in class org.apache.iceberg.data.avro.IcebergEncoder
 
encode(D, OutputStream) - Method in class org.apache.iceberg.data.avro.IcebergEncoder
 
encode(ManifestFile) - Static method in class org.apache.iceberg.ManifestFiles
Encode the ManifestFile to a byte array by using avro encoder.
encode(T, Schema) - Static method in class org.apache.iceberg.avro.AvroEncoderUtil
 
encrypt(Iterable<OutputFile>) - Method in interface org.apache.iceberg.encryption.EncryptionManager
Variant of EncryptionManager.encrypt(OutputFile) that provides a sequence of files that all need to be encrypted in a single context.
encrypt(OutputFile) - Method in interface org.apache.iceberg.encryption.EncryptionManager
Given a handle on an OutputFile that writes raw bytes to the underlying file system, return a bundle of an EncryptedOutputFile.encryptingOutputFile() that writes encrypted bytes to the underlying file system, and the EncryptedOutputFile.keyMetadata() that points to the encryption key that is being used to encrypt this file.
encrypt(OutputFile) - Method in class org.apache.iceberg.encryption.PlaintextEncryptionManager
 
EncryptedFiles - Class in org.apache.iceberg.encryption
 
encryptedInput(InputFile, byte[]) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
encryptedInput(InputFile, ByteBuffer) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
encryptedInput(InputFile, EncryptionKeyMetadata) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
encryptedInputFile() - Method in interface org.apache.iceberg.encryption.EncryptedInputFile
The InputFile that is reading raw encrypted bytes from the underlying file system.
EncryptedInputFile - Interface in org.apache.iceberg.encryption
Thin wrapper around an InputFile instance that is encrypted.
encryptedOutput(OutputFile, byte[]) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
encryptedOutput(OutputFile, ByteBuffer) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
encryptedOutput(OutputFile, EncryptionKeyMetadata) - Static method in class org.apache.iceberg.encryption.EncryptedFiles
 
EncryptedOutputFile - Interface in org.apache.iceberg.encryption
Thin wrapper around a OutputFile that is encrypting bytes written to the underlying file system, via an encryption key that is symbolized by the enclosed EncryptionKeyMetadata.
encryptingOutputFile() - Method in interface org.apache.iceberg.encryption.EncryptedOutputFile
An OutputFile instance that encrypts the bytes that are written to its output streams.
encryption() - Method in class org.apache.iceberg.BaseTable
 
encryption() - Method in class org.apache.iceberg.SerializableTable
 
encryption() - Method in interface org.apache.iceberg.Table
Returns an EncryptionManager to encrypt and decrypt data files.
encryption() - Method in interface org.apache.iceberg.TableOperations
Returns a EncryptionManager to encrypt and decrypt data files.
encryptionKey() - Method in class org.apache.iceberg.gcp.GCPProperties
 
EncryptionKeyMetadata - Interface in org.apache.iceberg.encryption
Light typedef over a ByteBuffer that indicates that the given bytes represent metadata about an encrypted data file's encryption key.
EncryptionKeyMetadatas - Class in org.apache.iceberg.encryption
 
encryptionManager() - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
 
EncryptionManager - Interface in org.apache.iceberg.encryption
Module for encrypting and decrypting table data files.
END_SNAPSHOT_ID - Static variable in class org.apache.iceberg.spark.SparkReadOptions
 
endFileIndex() - Method in class org.apache.iceberg.MicroBatches.MicroBatch
 
endSnapshotId() - Method in class org.apache.iceberg.spark.SparkReadConf
 
endSnapshotId(Long) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
ENGINE_HIVE_ENABLED - Static variable in class org.apache.iceberg.hadoop.ConfigProperties
 
ENGINE_HIVE_ENABLED - Static variable in class org.apache.iceberg.TableProperties
 
ENGINE_HIVE_ENABLED_DEFAULT - Static variable in class org.apache.iceberg.TableProperties
 
enrichContextWithAttemptWrapper(TaskAttemptContext) - Static method in class org.apache.iceberg.mr.hive.TezUtil
Creates a new taskAttemptContext by replacing the taskAttemptID with a wrapped object.
enrichContextWithVertexId(JobContext) - Static method in class org.apache.iceberg.mr.hive.TezUtil
If the Tez vertex id is present in config, creates a new jobContext by appending the Tez vertex id to the jobID.
enterAddPartitionField(IcebergSqlExtensionsParser.AddPartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the addPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterAddPartitionField(IcebergSqlExtensionsParser.AddPartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the addPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterApplyTransform(IcebergSqlExtensionsParser.ApplyTransformContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the applyTransform labeled alternative in IcebergSqlExtensionsParser.transform().
enterApplyTransform(IcebergSqlExtensionsParser.ApplyTransformContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the applyTransform labeled alternative in IcebergSqlExtensionsParser.transform().
enterBigDecimalLiteral(IcebergSqlExtensionsParser.BigDecimalLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the bigDecimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterBigDecimalLiteral(IcebergSqlExtensionsParser.BigDecimalLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the bigDecimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterBigIntLiteral(IcebergSqlExtensionsParser.BigIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the bigIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterBigIntLiteral(IcebergSqlExtensionsParser.BigIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the bigIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterBooleanLiteral(IcebergSqlExtensionsParser.BooleanLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the booleanLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterBooleanLiteral(IcebergSqlExtensionsParser.BooleanLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the booleanLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterBooleanValue(IcebergSqlExtensionsParser.BooleanValueContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.booleanValue().
enterBooleanValue(IcebergSqlExtensionsParser.BooleanValueContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.booleanValue().
enterCall(IcebergSqlExtensionsParser.CallContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the call labeled alternative in IcebergSqlExtensionsParser.statement().
enterCall(IcebergSqlExtensionsParser.CallContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the call labeled alternative in IcebergSqlExtensionsParser.statement().
enterDecimalLiteral(IcebergSqlExtensionsParser.DecimalLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the decimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterDecimalLiteral(IcebergSqlExtensionsParser.DecimalLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the decimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterDoubleLiteral(IcebergSqlExtensionsParser.DoubleLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the doubleLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterDoubleLiteral(IcebergSqlExtensionsParser.DoubleLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the doubleLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterDropIdentifierFields(IcebergSqlExtensionsParser.DropIdentifierFieldsContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the dropIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
enterDropIdentifierFields(IcebergSqlExtensionsParser.DropIdentifierFieldsContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the dropIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
enterDropPartitionField(IcebergSqlExtensionsParser.DropPartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the dropPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterDropPartitionField(IcebergSqlExtensionsParser.DropPartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the dropPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterEveryRule(ParserRuleContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
enterExponentLiteral(IcebergSqlExtensionsParser.ExponentLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the exponentLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterExponentLiteral(IcebergSqlExtensionsParser.ExponentLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the exponentLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterExpression(IcebergSqlExtensionsParser.ExpressionContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.expression().
enterExpression(IcebergSqlExtensionsParser.ExpressionContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.expression().
enterFieldList(IcebergSqlExtensionsParser.FieldListContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.fieldList().
enterFieldList(IcebergSqlExtensionsParser.FieldListContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.fieldList().
enterFloatLiteral(IcebergSqlExtensionsParser.FloatLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the floatLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterFloatLiteral(IcebergSqlExtensionsParser.FloatLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the floatLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterIdentityTransform(IcebergSqlExtensionsParser.IdentityTransformContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the identityTransform labeled alternative in IcebergSqlExtensionsParser.transform().
enterIdentityTransform(IcebergSqlExtensionsParser.IdentityTransformContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the identityTransform labeled alternative in IcebergSqlExtensionsParser.transform().
enterIntegerLiteral(IcebergSqlExtensionsParser.IntegerLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the integerLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterIntegerLiteral(IcebergSqlExtensionsParser.IntegerLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the integerLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterMultipartIdentifier(IcebergSqlExtensionsParser.MultipartIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.multipartIdentifier().
enterMultipartIdentifier(IcebergSqlExtensionsParser.MultipartIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.multipartIdentifier().
enterNamedArgument(IcebergSqlExtensionsParser.NamedArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the namedArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
enterNamedArgument(IcebergSqlExtensionsParser.NamedArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the namedArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
enterNonReserved(IcebergSqlExtensionsParser.NonReservedContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.nonReserved().
enterNonReserved(IcebergSqlExtensionsParser.NonReservedContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.nonReserved().
enterNumericLiteral(IcebergSqlExtensionsParser.NumericLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the numericLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterNumericLiteral(IcebergSqlExtensionsParser.NumericLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the numericLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterOrder(IcebergSqlExtensionsParser.OrderContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.order().
enterOrder(IcebergSqlExtensionsParser.OrderContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.order().
enterOrderField(IcebergSqlExtensionsParser.OrderFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.orderField().
enterOrderField(IcebergSqlExtensionsParser.OrderFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.orderField().
enterPositionalArgument(IcebergSqlExtensionsParser.PositionalArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the positionalArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
enterPositionalArgument(IcebergSqlExtensionsParser.PositionalArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the positionalArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
enterQuotedIdentifier(IcebergSqlExtensionsParser.QuotedIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.quotedIdentifier().
enterQuotedIdentifier(IcebergSqlExtensionsParser.QuotedIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.quotedIdentifier().
enterQuotedIdentifierAlternative(IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the quotedIdentifierAlternative labeled alternative in IcebergSqlExtensionsParser.identifier().
enterQuotedIdentifierAlternative(IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the quotedIdentifierAlternative labeled alternative in IcebergSqlExtensionsParser.identifier().
enterReplacePartitionField(IcebergSqlExtensionsParser.ReplacePartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the replacePartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterReplacePartitionField(IcebergSqlExtensionsParser.ReplacePartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the replacePartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ApplyTransformContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigDecimalLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigIntLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanValueContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DecimalLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DoubleLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExponentLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExpressionContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FieldListContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FloatLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IdentityTransformContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IntegerLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.MultipartIdentifierContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NamedArgumentContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NumericLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.PositionalArgumentContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SingleStatementContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SmallIntLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringMapContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TinyIntLiteralContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TransformArgumentContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TypeConstructorContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.UnquotedIdentifierContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteDistributionSpecContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteOrderingSpecContext
 
enterRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteSpecContext
 
enterSetIdentifierFields(IcebergSqlExtensionsParser.SetIdentifierFieldsContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the setIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
enterSetIdentifierFields(IcebergSqlExtensionsParser.SetIdentifierFieldsContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the setIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
enterSetWriteDistributionAndOrdering(IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the setWriteDistributionAndOrdering labeled alternative in IcebergSqlExtensionsParser.statement().
enterSetWriteDistributionAndOrdering(IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the setWriteDistributionAndOrdering labeled alternative in IcebergSqlExtensionsParser.statement().
enterSingleStatement(IcebergSqlExtensionsParser.SingleStatementContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.singleStatement().
enterSingleStatement(IcebergSqlExtensionsParser.SingleStatementContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.singleStatement().
enterSmallIntLiteral(IcebergSqlExtensionsParser.SmallIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the smallIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterSmallIntLiteral(IcebergSqlExtensionsParser.SmallIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the smallIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterStringLiteral(IcebergSqlExtensionsParser.StringLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the stringLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterStringLiteral(IcebergSqlExtensionsParser.StringLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the stringLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
enterStringMap(IcebergSqlExtensionsParser.StringMapContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.stringMap().
enterStringMap(IcebergSqlExtensionsParser.StringMapContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.stringMap().
enterTinyIntLiteral(IcebergSqlExtensionsParser.TinyIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the tinyIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterTinyIntLiteral(IcebergSqlExtensionsParser.TinyIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the tinyIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
enterTransformArgument(IcebergSqlExtensionsParser.TransformArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.transformArgument().
enterTransformArgument(IcebergSqlExtensionsParser.TransformArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.transformArgument().
enterTypeConstructor(IcebergSqlExtensionsParser.TypeConstructorContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the typeConstructor labeled alternative in IcebergSqlExtensionsParser.constant().
enterTypeConstructor(IcebergSqlExtensionsParser.TypeConstructorContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the typeConstructor labeled alternative in IcebergSqlExtensionsParser.constant().
enterUnquotedIdentifier(IcebergSqlExtensionsParser.UnquotedIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by the unquotedIdentifier labeled alternative in IcebergSqlExtensionsParser.identifier().
enterUnquotedIdentifier(IcebergSqlExtensionsParser.UnquotedIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by the unquotedIdentifier labeled alternative in IcebergSqlExtensionsParser.identifier().
enterWriteDistributionSpec(IcebergSqlExtensionsParser.WriteDistributionSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
enterWriteDistributionSpec(IcebergSqlExtensionsParser.WriteDistributionSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
enterWriteOrderingSpec(IcebergSqlExtensionsParser.WriteOrderingSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.writeOrderingSpec().
enterWriteOrderingSpec(IcebergSqlExtensionsParser.WriteOrderingSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.writeOrderingSpec().
enterWriteSpec(IcebergSqlExtensionsParser.WriteSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Enter a parse tree produced by IcebergSqlExtensionsParser.writeSpec().
enterWriteSpec(IcebergSqlExtensionsParser.WriteSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Enter a parse tree produced by IcebergSqlExtensionsParser.writeSpec().
ENTRIES - org.apache.iceberg.MetadataTableType
 
entrySet() - Method in class org.apache.iceberg.util.SerializableMap
 
entrySet() - Method in class org.apache.iceberg.util.StructLikeMap
 
enums(List<String>) - Static method in class org.apache.iceberg.avro.ValueReaders
 
env(StreamExecutionEnvironment) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
EOF() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SingleStatementContext
 
EPOCH - Static variable in class org.apache.iceberg.util.DateTimeUtil
 
EPOCH_DAY - Static variable in class org.apache.iceberg.util.DateTimeUtil
 
eq(Bound<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundVisitor
 
eq(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor
 
EQ - org.apache.iceberg.expressions.Expression.Operation
 
eqDeletedRowFilter() - Method in class org.apache.iceberg.data.DeleteFilter
 
equal(String, T) - Static method in class org.apache.iceberg.expressions.Expressions
 
equal(UnboundTerm<T>, T) - Static method in class org.apache.iceberg.expressions.Expressions
 
EQUALITY_DELETES - org.apache.iceberg.FileContent
 
EQUALITY_IDS - Static variable in interface org.apache.iceberg.DataFile
 
EqualityDeleteRowReader - Class in org.apache.iceberg.spark.source
 
EqualityDeleteRowReader(CombinedScanTask, Table, Schema, boolean) - Constructor for class org.apache.iceberg.spark.source.EqualityDeleteRowReader
 
equalityDeleteRowSchema() - Method in class org.apache.iceberg.data.BaseFileWriterFactory
 
EqualityDeleteWriter<T> - Class in org.apache.iceberg.deletes
 
EqualityDeleteWriter(FileAppender<T>, FileFormat, String, PartitionSpec, StructLike, EncryptionKeyMetadata, SortOrder, int...) - Constructor for class org.apache.iceberg.deletes.EqualityDeleteWriter
 
EqualityDeltaWriter<T> - Interface in org.apache.iceberg.io
A writer capable of writing data and equality deletes that may belong to different specs and partitions.
equalityFieldColumns(List<String>) - Method in class org.apache.iceberg.flink.sink.FlinkSink.Builder
Configuring the equality field columns for iceberg table that accept CDC or UPSERT events.
equalityFieldIds() - Method in interface org.apache.iceberg.ContentFile
Returns the set of field IDs used for equality comparison, in equality delete files.
equalityFieldIds() - Method in interface org.apache.iceberg.DataFile
 
equalityFieldIds(int...) - Method in class org.apache.iceberg.avro.Avro.DeleteWriteBuilder
 
equalityFieldIds(int...) - Method in class org.apache.iceberg.orc.ORC.DeleteWriteBuilder
 
equalityFieldIds(int...) - Method in class org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder
 
equalityFieldIds(List<Integer>) - Method in class org.apache.iceberg.avro.Avro.DeleteWriteBuilder
 
equalityFieldIds(List<Integer>) - Method in class org.apache.iceberg.orc.ORC.DeleteWriteBuilder
 
equalityFieldIds(List<Integer>) - Method in class org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder
 
equals(Object) - Method in class org.apache.iceberg.catalog.Namespace
 
equals(Object) - Method in class org.apache.iceberg.catalog.TableIdentifier
 
equals(Object) - Method in class org.apache.iceberg.data.GenericRecord
 
equals(Object) - Method in class org.apache.iceberg.GenericManifestFile
 
equals(Object) - Method in class org.apache.iceberg.mapping.MappedField
 
equals(Object) - Method in class org.apache.iceberg.mapping.MappedFields
 
equals(Object) - Method in class org.apache.iceberg.MetricsModes.Truncate
 
equals(Object) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergRecordObjectInspector
 
equals(Object) - Method in class org.apache.iceberg.PartitionField
 
equals(Object) - Method in class org.apache.iceberg.PartitionKey
 
equals(Object) - Method in class org.apache.iceberg.PartitionSpec
 
equals(Object) - Method in class org.apache.iceberg.SortField
 
equals(Object) - Method in class org.apache.iceberg.SortOrder
 
equals(Object) - Method in class org.apache.iceberg.spark.source.SparkTable
 
equals(Object) - Method in class org.apache.iceberg.spark.SparkTableUtil.SparkPartition
 
equals(Object) - Method in class org.apache.iceberg.TableMetadata.MetadataLogEntry
 
equals(Object) - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry
 
equals(Object) - Method in class org.apache.iceberg.transforms.UnknownTransform
 
equals(Object) - Method in class org.apache.iceberg.types.Types.DecimalType
 
equals(Object) - Method in class org.apache.iceberg.types.Types.FixedType
 
equals(Object) - Method in class org.apache.iceberg.types.Types.ListType
 
equals(Object) - Method in class org.apache.iceberg.types.Types.MapType
 
equals(Object) - Method in class org.apache.iceberg.types.Types.NestedField
 
equals(Object) - Method in class org.apache.iceberg.types.Types.StructType
 
equals(Object) - Method in class org.apache.iceberg.types.Types.TimestampType
 
equals(Object) - Method in class org.apache.iceberg.util.CharSequenceWrapper
 
equals(Object) - Method in class org.apache.iceberg.util.Pair
 
equals(Object) - Method in class org.apache.iceberg.util.SerializableMap
 
equals(Object) - Method in class org.apache.iceberg.util.StructLikeSet
 
equals(Object) - Method in class org.apache.iceberg.util.StructLikeWrapper
 
estimateSize(StructType, long) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil
Estimate approximate table size based on Spark schema and total records.
eval(ContentFile<?>) - Method in class org.apache.iceberg.expressions.InclusiveMetricsEvaluator
Test whether the file may contain records that match the expression.
eval(ContentFile<?>) - Method in class org.apache.iceberg.expressions.StrictMetricsEvaluator
Test whether all records within the file match the expression.
eval(ManifestFile) - Method in class org.apache.iceberg.expressions.ManifestEvaluator
Test whether the file may contain records that match the expression.
eval(StructLike) - Method in interface org.apache.iceberg.expressions.Bound
Produce a value from the struct for this expression.
eval(StructLike) - Method in class org.apache.iceberg.expressions.BoundPredicate
 
eval(StructLike) - Method in class org.apache.iceberg.expressions.BoundReference
 
eval(StructLike) - Method in class org.apache.iceberg.expressions.BoundTransform
 
eval(StructLike) - Method in class org.apache.iceberg.expressions.Evaluator
 
Evaluator - Class in org.apache.iceberg.expressions
Evaluates an Expression for data described by a Types.StructType.
Evaluator(Types.StructType, Expression) - Constructor for class org.apache.iceberg.expressions.Evaluator
 
Evaluator(Types.StructType, Expression, boolean) - Constructor for class org.apache.iceberg.expressions.Evaluator
 
Exceptions - Class in org.apache.iceberg.util
 
ExceptionUtil - Class in org.apache.iceberg.util
 
ExceptionUtil.Block<R,​E1 extends java.lang.Exception,​E2 extends java.lang.Exception,​E3 extends java.lang.Exception> - Interface in org.apache.iceberg.util
 
ExceptionUtil.CatchBlock - Interface in org.apache.iceberg.util
 
ExceptionUtil.FinallyBlock - Interface in org.apache.iceberg.util
 
execute() - Method in interface org.apache.iceberg.actions.Action
Executes this action.
execute() - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseDeleteOrphanFilesSparkAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseDeleteReachableFilesSparkAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseMigrateTableSparkAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseRewriteManifestsSparkAction
 
execute() - Method in class org.apache.iceberg.spark.actions.BaseSnapshotTableSparkAction
 
executeDeleteWith(ExecutorService) - Method in interface org.apache.iceberg.actions.DeleteOrphanFiles
Passes an alternative executor service that will be used for removing orphaned files.
executeDeleteWith(ExecutorService) - Method in interface org.apache.iceberg.actions.DeleteReachableFiles
Passes an alternative executor service that will be used for files removal.
executeDeleteWith(ExecutorService) - Method in interface org.apache.iceberg.actions.ExpireSnapshots
Passes an alternative executor service that will be used for manifests and data files deletion.
executeDeleteWith(ExecutorService) - Method in interface org.apache.iceberg.ExpireSnapshots
Passes an alternative executor service that will be used for manifests and data files deletion.
executeDeleteWith(ExecutorService) - Method in class org.apache.iceberg.spark.actions.BaseDeleteOrphanFilesSparkAction
 
executeDeleteWith(ExecutorService) - Method in class org.apache.iceberg.spark.actions.BaseDeleteReachableFilesSparkAction
 
executeDeleteWith(ExecutorService) - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
executeWith(ExecutorService) - Method in class org.apache.iceberg.util.Tasks.Builder
 
existing(F, long, long) - Method in class org.apache.iceberg.ManifestWriter
Add an existing entry for a file.
EXISTING_FILES_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
EXISTING_ROWS_COUNT - Static variable in interface org.apache.iceberg.ManifestFile
 
existingFilesCount() - Method in class org.apache.iceberg.GenericManifestFile
 
existingFilesCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the number of data files with status EXISTING in the manifest file.
existingFilesCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
existingRowsCount() - Method in class org.apache.iceberg.GenericManifestFile
 
existingRowsCount() - Method in interface org.apache.iceberg.ManifestFile
Returns the total number of rows in all data files with status EXISTING in the manifest file.
existingRowsCount() - Method in class org.apache.iceberg.spark.actions.ManifestFileBean
 
exists() - Method in class org.apache.iceberg.hadoop.HadoopInputFile
 
exists() - Method in interface org.apache.iceberg.io.InputFile
Checks whether the file exists.
exists(String) - Method in class org.apache.iceberg.hadoop.HadoopTables
 
exists(String) - Method in interface org.apache.iceberg.Tables
 
exitAddPartitionField(IcebergSqlExtensionsParser.AddPartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the addPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitAddPartitionField(IcebergSqlExtensionsParser.AddPartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the addPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitApplyTransform(IcebergSqlExtensionsParser.ApplyTransformContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the applyTransform labeled alternative in IcebergSqlExtensionsParser.transform().
exitApplyTransform(IcebergSqlExtensionsParser.ApplyTransformContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the applyTransform labeled alternative in IcebergSqlExtensionsParser.transform().
exitBigDecimalLiteral(IcebergSqlExtensionsParser.BigDecimalLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the bigDecimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitBigDecimalLiteral(IcebergSqlExtensionsParser.BigDecimalLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the bigDecimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitBigIntLiteral(IcebergSqlExtensionsParser.BigIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the bigIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitBigIntLiteral(IcebergSqlExtensionsParser.BigIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the bigIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitBooleanLiteral(IcebergSqlExtensionsParser.BooleanLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the booleanLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitBooleanLiteral(IcebergSqlExtensionsParser.BooleanLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the booleanLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitBooleanValue(IcebergSqlExtensionsParser.BooleanValueContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.booleanValue().
exitBooleanValue(IcebergSqlExtensionsParser.BooleanValueContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.booleanValue().
exitCall(IcebergSqlExtensionsParser.CallContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the call labeled alternative in IcebergSqlExtensionsParser.statement().
exitCall(IcebergSqlExtensionsParser.CallContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the call labeled alternative in IcebergSqlExtensionsParser.statement().
exitDecimalLiteral(IcebergSqlExtensionsParser.DecimalLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the decimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitDecimalLiteral(IcebergSqlExtensionsParser.DecimalLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the decimalLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitDoubleLiteral(IcebergSqlExtensionsParser.DoubleLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the doubleLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitDoubleLiteral(IcebergSqlExtensionsParser.DoubleLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the doubleLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitDropIdentifierFields(IcebergSqlExtensionsParser.DropIdentifierFieldsContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the dropIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
exitDropIdentifierFields(IcebergSqlExtensionsParser.DropIdentifierFieldsContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the dropIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
exitDropPartitionField(IcebergSqlExtensionsParser.DropPartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the dropPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitDropPartitionField(IcebergSqlExtensionsParser.DropPartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the dropPartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitEveryRule(ParserRuleContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
exitExponentLiteral(IcebergSqlExtensionsParser.ExponentLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the exponentLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitExponentLiteral(IcebergSqlExtensionsParser.ExponentLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the exponentLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitExpression(IcebergSqlExtensionsParser.ExpressionContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.expression().
exitExpression(IcebergSqlExtensionsParser.ExpressionContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.expression().
exitFieldList(IcebergSqlExtensionsParser.FieldListContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.fieldList().
exitFieldList(IcebergSqlExtensionsParser.FieldListContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.fieldList().
exitFloatLiteral(IcebergSqlExtensionsParser.FloatLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the floatLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitFloatLiteral(IcebergSqlExtensionsParser.FloatLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the floatLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitIdentityTransform(IcebergSqlExtensionsParser.IdentityTransformContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the identityTransform labeled alternative in IcebergSqlExtensionsParser.transform().
exitIdentityTransform(IcebergSqlExtensionsParser.IdentityTransformContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the identityTransform labeled alternative in IcebergSqlExtensionsParser.transform().
exitIntegerLiteral(IcebergSqlExtensionsParser.IntegerLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the integerLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitIntegerLiteral(IcebergSqlExtensionsParser.IntegerLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the integerLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitMultipartIdentifier(IcebergSqlExtensionsParser.MultipartIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
exitMultipartIdentifier(IcebergSqlExtensionsParser.MultipartIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
exitNamedArgument(IcebergSqlExtensionsParser.NamedArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the namedArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
exitNamedArgument(IcebergSqlExtensionsParser.NamedArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the namedArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
exitNonReserved(IcebergSqlExtensionsParser.NonReservedContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.nonReserved().
exitNonReserved(IcebergSqlExtensionsParser.NonReservedContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.nonReserved().
exitNumericLiteral(IcebergSqlExtensionsParser.NumericLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the numericLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitNumericLiteral(IcebergSqlExtensionsParser.NumericLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the numericLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitOrder(IcebergSqlExtensionsParser.OrderContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.order().
exitOrder(IcebergSqlExtensionsParser.OrderContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.order().
exitOrderField(IcebergSqlExtensionsParser.OrderFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.orderField().
exitOrderField(IcebergSqlExtensionsParser.OrderFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.orderField().
exitPositionalArgument(IcebergSqlExtensionsParser.PositionalArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the positionalArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
exitPositionalArgument(IcebergSqlExtensionsParser.PositionalArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the positionalArgument labeled alternative in IcebergSqlExtensionsParser.callArgument().
exitQuotedIdentifier(IcebergSqlExtensionsParser.QuotedIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.quotedIdentifier().
exitQuotedIdentifier(IcebergSqlExtensionsParser.QuotedIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.quotedIdentifier().
exitQuotedIdentifierAlternative(IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the quotedIdentifierAlternative labeled alternative in IcebergSqlExtensionsParser.identifier().
exitQuotedIdentifierAlternative(IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the quotedIdentifierAlternative labeled alternative in IcebergSqlExtensionsParser.identifier().
exitReplacePartitionField(IcebergSqlExtensionsParser.ReplacePartitionFieldContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the replacePartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitReplacePartitionField(IcebergSqlExtensionsParser.ReplacePartitionFieldContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the replacePartitionField labeled alternative in IcebergSqlExtensionsParser.statement().
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ApplyTransformContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigDecimalLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BigIntLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanValueContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.CallContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DecimalLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DoubleLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExponentLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExpressionContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FieldListContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FloatLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IdentityTransformContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.IntegerLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.MultipartIdentifierContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NamedArgumentContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NumericLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.PositionalArgumentContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierAlternativeContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.QuotedIdentifierContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SingleStatementContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SmallIntLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.StringMapContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TinyIntLiteralContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TransformArgumentContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.TypeConstructorContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.UnquotedIdentifierContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteDistributionSpecContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteOrderingSpecContext
 
exitRule(ParseTreeListener) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.WriteSpecContext
 
exitSetIdentifierFields(IcebergSqlExtensionsParser.SetIdentifierFieldsContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the setIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
exitSetIdentifierFields(IcebergSqlExtensionsParser.SetIdentifierFieldsContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the setIdentifierFields labeled alternative in IcebergSqlExtensionsParser.statement().
exitSetWriteDistributionAndOrdering(IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the setWriteDistributionAndOrdering labeled alternative in IcebergSqlExtensionsParser.statement().
exitSetWriteDistributionAndOrdering(IcebergSqlExtensionsParser.SetWriteDistributionAndOrderingContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the setWriteDistributionAndOrdering labeled alternative in IcebergSqlExtensionsParser.statement().
exitSingleStatement(IcebergSqlExtensionsParser.SingleStatementContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.singleStatement().
exitSingleStatement(IcebergSqlExtensionsParser.SingleStatementContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.singleStatement().
exitSmallIntLiteral(IcebergSqlExtensionsParser.SmallIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the smallIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitSmallIntLiteral(IcebergSqlExtensionsParser.SmallIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the smallIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitStringLiteral(IcebergSqlExtensionsParser.StringLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the stringLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitStringLiteral(IcebergSqlExtensionsParser.StringLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the stringLiteral labeled alternative in IcebergSqlExtensionsParser.constant().
exitStringMap(IcebergSqlExtensionsParser.StringMapContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.stringMap().
exitStringMap(IcebergSqlExtensionsParser.StringMapContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.stringMap().
exitTinyIntLiteral(IcebergSqlExtensionsParser.TinyIntLiteralContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the tinyIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitTinyIntLiteral(IcebergSqlExtensionsParser.TinyIntLiteralContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the tinyIntLiteral labeled alternative in IcebergSqlExtensionsParser.number().
exitTransformArgument(IcebergSqlExtensionsParser.TransformArgumentContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.transformArgument().
exitTransformArgument(IcebergSqlExtensionsParser.TransformArgumentContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.transformArgument().
exitTypeConstructor(IcebergSqlExtensionsParser.TypeConstructorContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the typeConstructor labeled alternative in IcebergSqlExtensionsParser.constant().
exitTypeConstructor(IcebergSqlExtensionsParser.TypeConstructorContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the typeConstructor labeled alternative in IcebergSqlExtensionsParser.constant().
exitUnquotedIdentifier(IcebergSqlExtensionsParser.UnquotedIdentifierContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by the unquotedIdentifier labeled alternative in IcebergSqlExtensionsParser.identifier().
exitUnquotedIdentifier(IcebergSqlExtensionsParser.UnquotedIdentifierContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by the unquotedIdentifier labeled alternative in IcebergSqlExtensionsParser.identifier().
exitWriteDistributionSpec(IcebergSqlExtensionsParser.WriteDistributionSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
exitWriteDistributionSpec(IcebergSqlExtensionsParser.WriteDistributionSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
exitWriteOrderingSpec(IcebergSqlExtensionsParser.WriteOrderingSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.writeOrderingSpec().
exitWriteOrderingSpec(IcebergSqlExtensionsParser.WriteOrderingSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.writeOrderingSpec().
exitWriteSpec(IcebergSqlExtensionsParser.WriteSpecContext) - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsBaseListener
Exit a parse tree produced by IcebergSqlExtensionsParser.writeSpec().
exitWriteSpec(IcebergSqlExtensionsParser.WriteSpecContext) - Method in interface org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsListener
Exit a parse tree produced by IcebergSqlExtensionsParser.writeSpec().
expirationIntervalMillis - Variable in class org.apache.iceberg.CachingCatalog
 
expire() - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
Expires snapshots and commits the changes to the table, returning a Dataset of files to delete.
expireOlderThan(long) - Method in interface org.apache.iceberg.actions.ExpireSnapshots
Expires all snapshots older than the given timestamp.
expireOlderThan(long) - Method in interface org.apache.iceberg.ExpireSnapshots
Expires all snapshots older than the given timestamp.
expireOlderThan(long) - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
expireSnapshotId(long) - Method in interface org.apache.iceberg.actions.ExpireSnapshots
Expires a specific Snapshot identified by id.
expireSnapshotId(long) - Method in interface org.apache.iceberg.ExpireSnapshots
Expires a specific Snapshot identified by id.
expireSnapshotId(long) - Method in class org.apache.iceberg.spark.actions.BaseExpireSnapshotsSparkAction
 
expireSnapshots() - Method in class org.apache.iceberg.BaseTable
 
expireSnapshots() - Method in class org.apache.iceberg.SerializableTable
 
expireSnapshots() - Method in interface org.apache.iceberg.Table
Create a new expire API to manage snapshots in this table and commit.
expireSnapshots() - Method in interface org.apache.iceberg.Transaction
Create a new expire API to manage snapshots in this table.
expireSnapshots(Table) - Method in interface org.apache.iceberg.actions.ActionsProvider
Instantiates an action to expire snapshots.
ExpireSnapshots - Interface in org.apache.iceberg.actions
An action that expires snapshots in a table.
ExpireSnapshots - Interface in org.apache.iceberg
API for removing old snapshots from a table.
ExpireSnapshots.Result - Interface in org.apache.iceberg.actions
The action result that contains a summary of the execution.
ExpireSnapshotsProcedure - Class in org.apache.iceberg.spark.procedures
A procedure that expires snapshots in a table.
EXPONENT_VALUE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
EXPONENT_VALUE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
EXPONENT_VALUE() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExponentLiteralContext
 
exponentialBackoff(long, long, long, double) - Method in class org.apache.iceberg.util.Tasks.Builder
 
ExponentLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExponentLiteralContext
 
expression() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
expression() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NamedArgumentContext
 
expression() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.PositionalArgumentContext
 
Expression - Interface in org.apache.iceberg.expressions
Represents a boolean expression tree.
Expression.Operation - Enum in org.apache.iceberg.expressions
 
ExpressionContext(ParserRuleContext, int) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ExpressionContext
 
Expressions - Class in org.apache.iceberg.expressions
Factory methods for creating expressions.
ExpressionVisitor() - Constructor for class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor
 
ExpressionVisitors - Class in org.apache.iceberg.expressions
Utils for traversing expressions.
ExpressionVisitors.BoundExpressionVisitor<R> - Class in org.apache.iceberg.expressions
 
ExpressionVisitors.BoundVisitor<R> - Class in org.apache.iceberg.expressions
 
ExpressionVisitors.ExpressionVisitor<R> - Class in org.apache.iceberg.expressions
 
ExtendedLogicalWriteInfo - Interface in org.apache.spark.sql.connector.iceberg.write
A class that holds logical write information not covered by LogicalWriteInfo in Spark.
extensionsEnabled(SparkSession) - Static method in class org.apache.iceberg.spark.Spark3Util
 
EXTERNAL_TABLE_PURGE - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
EXTRA_METADATA_PREFIX - Static variable in class org.apache.iceberg.SnapshotSummary
 
extractCatalog(CaseInsensitiveStringMap) - Method in class org.apache.iceberg.spark.source.IcebergSource
 
extractIdentifier(CaseInsensitiveStringMap) - Method in class org.apache.iceberg.spark.source.IcebergSource
 
extraSnapshotMetadata() - Method in class org.apache.iceberg.spark.SparkWriteConf
 

F

factory() - Static method in class org.apache.iceberg.util.JsonUtil
 
factoryIdentifier() - Method in class org.apache.iceberg.flink.FlinkDynamicTableFactory
 
FAILURE - org.apache.iceberg.BaseMetastoreTableOperations.CommitStatus
 
False - Class in org.apache.iceberg.expressions
An expression that is always false.
FALSE - org.apache.iceberg.expressions.Expression.Operation
 
FALSE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
FALSE - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
FALSE() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.BooleanValueContext
 
FALSE() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
FANOUT_ENABLED - Static variable in class org.apache.iceberg.spark.SparkWriteOptions
 
FanoutDataWriter<T> - Class in org.apache.iceberg.io
A data writer capable of writing to multiple specs and partitions that keeps data writers for each seen spec/partition pair open until this writer is closed.
FanoutDataWriter(FileWriterFactory<T>, OutputFileFactory, FileIO, FileFormat, long) - Constructor for class org.apache.iceberg.io.FanoutDataWriter
 
fanoutWriterEnabled() - Method in class org.apache.iceberg.spark.SparkWriteConf
 
fetchNewDataFiles(Table, String) - Method in class org.apache.iceberg.spark.FileRewriteCoordinator
 
fetchSetIDs(Table) - Method in class org.apache.iceberg.spark.FileRewriteCoordinator
 
fetchSetIDs(Table) - Method in class org.apache.iceberg.spark.FileScanTaskSetManager
 
fetchTasks(Table, String) - Method in class org.apache.iceberg.spark.FileScanTaskSetManager
 
field() - Method in class org.apache.iceberg.expressions.BoundReference
 
field(int) - Method in class org.apache.iceberg.mapping.MappedFields
 
field(int) - Method in class org.apache.iceberg.types.Type.NestedType
 
field(int) - Method in class org.apache.iceberg.types.Types.ListType
 
field(int) - Method in class org.apache.iceberg.types.Types.MapType
 
field(int) - Method in class org.apache.iceberg.types.Types.StructType
 
field(String) - Method in class org.apache.iceberg.types.Types.StructType
 
field(String, int, SortDirection, NullOrder) - Method in interface org.apache.iceberg.transforms.SortOrderVisitor
 
field(Types.NestedField) - Method in class org.apache.iceberg.parquet.TypeToMessageType
 
field(Types.NestedField, Integer, Boolean) - Method in class org.apache.iceberg.schema.UnionByNameVisitor
 
field(Types.NestedField, String) - Method in class org.apache.iceberg.spark.Spark3Util.DescribeSchemaVisitor
 
field(Types.NestedField, Supplier<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility
 
field(Types.NestedField, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering
 
field(Types.NestedField, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering
 
field(Types.NestedField, Supplier<Type>) - Method in class org.apache.iceberg.types.FixupTypes
 
field(Types.NestedField, Supplier<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor
 
field(Types.NestedField, Map<Integer, Integer>) - Method in class org.apache.iceberg.types.IndexParents
 
field(Types.NestedField, Map<String, Integer>) - Method in class org.apache.iceberg.types.IndexByName
 
field(Types.NestedField, ObjectInspector) - Method in class org.apache.iceberg.mr.hive.serde.objectinspector.IcebergObjectInspector
 
field(Types.NestedField, P, R) - Method in class org.apache.iceberg.schema.SchemaWithPartnerVisitor
 
field(Types.NestedField, T) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor
 
FIELD - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
FIELD - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
FIELD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.AddPartitionFieldContext
 
FIELD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropPartitionFieldContext
 
FIELD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
FIELD() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.ReplacePartitionFieldContext
 
FIELD_ID_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil
 
fieldId() - Method in class org.apache.iceberg.expressions.BoundReference
 
fieldId() - Method in class org.apache.iceberg.PartitionField
Returns the partition field id across all the table metadata's partition specs.
fieldId() - Method in class org.apache.iceberg.types.Types.NestedField
 
fieldId(TypeDescription) - Static method in class org.apache.iceberg.orc.ORCSchemaUtil
 
fieldList() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
fieldList() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
fieldList() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
FieldListContext(ParserRuleContext, int) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FieldListContext
 
FieldMetrics<T> - Class in org.apache.iceberg
Iceberg internally tracked field level metrics.
FieldMetrics(int, long, long, long, T, T) - Constructor for class org.apache.iceberg.FieldMetrics
 
fieldNameAndType(LogicalType, int) - Method in class org.apache.iceberg.flink.data.AvroWithFlinkSchemaVisitor
 
fieldNameAndType(DataType, int) - Method in class org.apache.iceberg.spark.data.AvroWithSparkSchemaVisitor
 
fieldNameAndType(P, int) - Method in class org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor
 
fieldNames - Variable in class org.apache.iceberg.parquet.TypeWithSchemaVisitor
 
fieldNames() - Method in class org.apache.iceberg.avro.AvroSchemaVisitor
 
fieldPartner(P, int, String) - Method in interface org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors
 
fields - Variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FieldListContext
 
fields - Variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderContext
 
fields() - Method in class org.apache.iceberg.mapping.MappedFields
 
fields() - Method in class org.apache.iceberg.PartitionSpec
Returns the list of partition fields for this spec.
fields() - Method in class org.apache.iceberg.SortOrder
Returns the list of sort fields for this sort order
fields() - Method in class org.apache.iceberg.types.Type.NestedType
 
fields() - Method in class org.apache.iceberg.types.Types.ListType
 
fields() - Method in class org.apache.iceberg.types.Types.MapType
 
fields() - Method in class org.apache.iceberg.types.Types.StructType
 
FIELDS - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
FIELDS - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
FIELDS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.DropIdentifierFieldsContext
 
FIELDS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
FIELDS() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.SetIdentifierFieldsContext
 
fieldType(String) - Method in class org.apache.iceberg.types.Type.NestedType
 
fieldType(String) - Method in class org.apache.iceberg.types.Types.ListType
 
fieldType(String) - Method in class org.apache.iceberg.types.Types.MapType
 
fieldType(String) - Method in class org.apache.iceberg.types.Types.StructType
 
file() - Method in interface org.apache.iceberg.FileScanTask
The file to scan.
file() - Method in class org.apache.iceberg.ManifestReader
 
file() - Method in class org.apache.iceberg.TableMetadata.MetadataLogEntry
 
FILE_FORMAT - Static variable in interface org.apache.iceberg.DataFile
 
FILE_IO_IMPL - Static variable in class org.apache.iceberg.CatalogProperties
 
FILE_OPEN_COST - Static variable in class org.apache.iceberg.spark.SparkReadOptions
 
FILE_PATH - Static variable in interface org.apache.iceberg.DataFile
 
FILE_PATH - Static variable in class org.apache.iceberg.MetadataColumns
 
FILE_SCAN_TASK_SET_ID - Static variable in class org.apache.iceberg.spark.SparkReadOptions
 
FILE_SIZE - Static variable in interface org.apache.iceberg.DataFile
 
FileAppender<D> - Interface in org.apache.iceberg.io
 
FileAppenderFactory<T> - Interface in org.apache.iceberg.io
Factory to create a new FileAppender to write records.
FileContent - Enum in org.apache.iceberg
Content type stored in a file, one of DATA, POSITION_DELETES, or EQUALITY_DELETES.
fileCount() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics
 
FileFormat - Enum in org.apache.iceberg
Enum of supported file formats.
fileIO() - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
 
fileIO() - Method in class org.apache.iceberg.flink.actions.RewriteDataFilesAction
 
FileIO - Interface in org.apache.iceberg.io
Pluggable module for reading, writing, and deleting files.
FileMetadata - Class in org.apache.iceberg
 
FileMetadata.Builder - Class in org.apache.iceberg
 
fileMetrics(InputFile, MetricsConfig) - Static method in class org.apache.iceberg.parquet.ParquetUtil
 
fileMetrics(InputFile, MetricsConfig, NameMapping) - Static method in class org.apache.iceberg.parquet.ParquetUtil
 
fileOffset() - Method in class org.apache.iceberg.flink.source.split.IcebergSourceSplit
 
FileRewriteCoordinator - Class in org.apache.iceberg.spark
 
files() - Method in class org.apache.iceberg.BaseCombinedScanTask
 
files() - Method in interface org.apache.iceberg.CombinedScanTask
Return the tasks in this combined task.
Files - Class in org.apache.iceberg
 
FILES - org.apache.iceberg.MetadataTableType
 
fileScans() - Method in class org.apache.iceberg.actions.RewriteFileGroup
 
FileScanTask - Interface in org.apache.iceberg
A scan task over a range of a single file.
FileScanTaskReader<T> - Interface in org.apache.iceberg.flink.source
fileScanTaskSetId() - Method in class org.apache.iceberg.spark.SparkReadConf
 
FileScanTaskSetManager - Class in org.apache.iceberg.spark
 
fileSizeInBytes() - Method in interface org.apache.iceberg.ContentFile
Returns the file size in bytes.
fileSizeInBytes() - Method in class org.apache.iceberg.spark.SparkDataFile
 
FileWriter<T,​R> - Interface in org.apache.iceberg.io
A writer capable of writing files of a single type (i.e.
FileWriterFactory<T> - Interface in org.apache.iceberg.io
A factory for creating data and delete writers.
filter() - Method in class org.apache.iceberg.events.IncrementalScanEvent
 
filter() - Method in class org.apache.iceberg.events.ScanEvent
 
filter() - Method in interface org.apache.iceberg.TableScan
Returns this scan's filter Expression.
filter(Iterable<T>) - Method in class org.apache.iceberg.util.Filter
 
filter(Expression) - Method in class org.apache.iceberg.actions.BaseRewriteDataFilesAction
Pass a row Expression to filter DataFiles to be rewritten.
filter(Expression) - Method in interface org.apache.iceberg.actions.ConvertEqualityDeleteFiles
A filter for finding the equality deletes to convert.
filter(Expression) - Method in interface org.apache.iceberg.actions.RewriteDataFiles
A user provided filter for determining which files will be considered by the rewrite strategy.
filter(Expression) - Method in interface org.apache.iceberg.actions.RewritePositionDeleteFiles
A filter for finding deletes to rewrite.
filter(Expression) - Method in class org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
 
filter(Expression) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder
 
filter(Expression) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
filter(Expression) - Method in interface org.apache.iceberg.TableScan
Create a new TableScan from the results of this filtered by the Expression.
filter(CloseableIterable<E>, Predicate<E>) - Static method in interface org.apache.iceberg.io.CloseableIterable
 
filter(CloseableIterable<T>) - Method in class org.apache.iceberg.data.DeleteFilter
 
filter(CloseableIterable<T>) - Method in class org.apache.iceberg.util.Filter
 
filter(CloseableIterable<T>, Function<T, Long>, PositionDeleteIndex) - Static method in class org.apache.iceberg.deletes.Deletes
 
filter(CloseableIterable<T>, Function<T, StructLike>, StructLikeSet) - Static method in class org.apache.iceberg.deletes.Deletes
 
Filter<T> - Class in org.apache.iceberg.util
A Class for generic filters
Filter() - Constructor for class org.apache.iceberg.util.Filter
 
FILTER_EXPRESSION - Static variable in class org.apache.iceberg.mr.InputFormatConfig
 
FilterIterator<T> - Class in org.apache.iceberg.io
An Iterator that filters another Iterator.
FilterIterator(Iterator<T>) - Constructor for class org.apache.iceberg.io.FilterIterator
 
filterPartitions(List<SparkTableUtil.SparkPartition>, Map<String, String>) - Static method in class org.apache.iceberg.spark.SparkTableUtil
 
filterPartitions(Expression) - Method in class org.apache.iceberg.ManifestReader
 
filterRecords(boolean) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder
 
filterRows(Expression) - Method in class org.apache.iceberg.ManifestReader
 
filters(List<Expression>) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
finalize() - Method in class org.apache.iceberg.aliyun.oss.OSSInputStream
 
finalize() - Method in class org.apache.iceberg.aliyun.oss.OSSOutputStream
 
find(int) - Method in class org.apache.iceberg.mapping.NameMapping
 
find(String...) - Method in class org.apache.iceberg.mapping.NameMapping
 
find(List<String>) - Method in class org.apache.iceberg.mapping.NameMapping
 
find(Schema, Predicate<Type>) - Static method in class org.apache.iceberg.types.TypeUtil
 
findColumnName(int) - Method in class org.apache.iceberg.Schema
Returns the full column name for the given id.
findEqualityDeleteRows(CloseableIterable<T>) - Method in class org.apache.iceberg.data.DeleteFilter
 
findField(int) - Method in class org.apache.iceberg.Schema
Returns the sub-field identified by the field id as a Types.NestedField.
findField(String) - Method in class org.apache.iceberg.Schema
Returns a sub-field by name as a Types.NestedField.
FindFiles - Class in org.apache.iceberg
 
FindFiles.Builder - Class in org.apache.iceberg
 
findType(int) - Method in class org.apache.iceberg.Schema
Returns the Type of a sub-field identified by the field id.
findType(String) - Method in class org.apache.iceberg.Schema
Returns the Type of a sub-field identified by the field name.
finish() - Method in class org.apache.iceberg.flink.source.StreamingReaderOperator
 
first() - Method in class org.apache.iceberg.util.Pair
 
FIRST - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
FIRST - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
FIRST() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.NonReservedContext
 
FIRST() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.OrderFieldContext
 
fixed(int) - Static method in class org.apache.iceberg.avro.ValueReaders
 
fixed(int) - Static method in class org.apache.iceberg.avro.ValueWriters
 
fixed(Schema) - Static method in class org.apache.iceberg.avro.ValueReaders
 
FIXED - org.apache.iceberg.orc.ORCSchemaUtil.BinaryType
 
FIXED - org.apache.iceberg.types.Type.TypeID
 
fixedLengthDecimalBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
FixedLengthDecimalBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.FixedLengthDecimalBatchReader
 
fixedLengthDecimalDictEncodedReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
fixedSizeBinaryBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
FixedSizeBinaryBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.FixedSizeBinaryBatchReader
 
fixedSizeBinaryDictEncodedReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
fixedWidthBinaryDictEncodedReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
fixedWidthTypeBinaryBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
FixedWidthTypeBinaryBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.FixedWidthTypeBinaryBatchReader
 
fixupPrimitive(Type.PrimitiveType, Type) - Method in class org.apache.iceberg.types.FixupTypes
 
FixupTypes - Class in org.apache.iceberg.types
This is used to fix primitive types to match a table schema.
FixupTypes(Schema) - Constructor for class org.apache.iceberg.types.FixupTypes
 
FlinkAppenderFactory - Class in org.apache.iceberg.flink.sink
 
FlinkAppenderFactory(Schema, RowType, Map<String, String>, PartitionSpec) - Constructor for class org.apache.iceberg.flink.sink.FlinkAppenderFactory
 
FlinkAppenderFactory(Schema, RowType, Map<String, String>, PartitionSpec, int[], Schema, Schema) - Constructor for class org.apache.iceberg.flink.sink.FlinkAppenderFactory
 
FlinkAvroReader - Class in org.apache.iceberg.flink.data
 
FlinkAvroReader(Schema, Schema) - Constructor for class org.apache.iceberg.flink.data.FlinkAvroReader
 
FlinkAvroReader(Schema, Schema, Map<Integer, ?>) - Constructor for class org.apache.iceberg.flink.data.FlinkAvroReader
 
FlinkAvroWriter - Class in org.apache.iceberg.flink.data
 
FlinkAvroWriter(RowType) - Constructor for class org.apache.iceberg.flink.data.FlinkAvroWriter
 
FlinkCatalog - Class in org.apache.iceberg.flink
A Flink Catalog implementation that wraps an Iceberg Catalog.
FlinkCatalog(String, String, Namespace, CatalogLoader, boolean) - Constructor for class org.apache.iceberg.flink.FlinkCatalog
 
FlinkCatalogFactory - Class in org.apache.iceberg.flink
A Flink Catalog factory implementation that creates FlinkCatalog.
FlinkCatalogFactory() - Constructor for class org.apache.iceberg.flink.FlinkCatalogFactory
 
FlinkCompatibilityUtil - Class in org.apache.iceberg.flink.util
This is a small util class that try to hide calls to Flink Internal or PublicEvolve interfaces as Flink can change those APIs during minor version release.
flinkConf(ReadableConfig) - Method in class org.apache.iceberg.flink.source.FlinkSource.Builder
 
FlinkConfigOptions - Class in org.apache.iceberg.flink
 
FlinkDynamicTableFactory - Class in org.apache.iceberg.flink
 
FlinkDynamicTableFactory() - Constructor for class org.apache.iceberg.flink.FlinkDynamicTableFactory
 
FlinkDynamicTableFactory(FlinkCatalog) - Constructor for class org.apache.iceberg.flink.FlinkDynamicTableFactory
 
FlinkFilters - Class in org.apache.iceberg.flink
 
FlinkInputFormat - Class in org.apache.iceberg.flink.source
Flink InputFormat for Iceberg.
FlinkInputSplit - Class in org.apache.iceberg.flink.source
TODO Implement LocatableInputSplit.
FlinkOrcReader - Class in org.apache.iceberg.flink.data
 
FlinkOrcReader(Schema, TypeDescription) - Constructor for class org.apache.iceberg.flink.data.FlinkOrcReader
 
FlinkOrcReader(Schema, TypeDescription, Map<Integer, ?>) - Constructor for class org.apache.iceberg.flink.data.FlinkOrcReader
 
FlinkOrcWriter - Class in org.apache.iceberg.flink.data
 
FlinkParquetReaders - Class in org.apache.iceberg.flink.data
 
FlinkParquetWriters - Class in org.apache.iceberg.flink.data
 
FlinkSchemaUtil - Class in org.apache.iceberg.flink
Converter between Flink types and Iceberg type.
FlinkSink - Class in org.apache.iceberg.flink.sink
 
FlinkSink.Builder - Class in org.apache.iceberg.flink.sink
 
FlinkSource - Class in org.apache.iceberg.flink.source
 
FlinkSource.Builder - Class in org.apache.iceberg.flink.source
Source builder to build DataStream.
FlinkSplitPlanner - Class in org.apache.iceberg.flink.source
 
FlinkTypeVisitor<T> - Class in org.apache.iceberg.flink
 
FlinkTypeVisitor() - Constructor for class org.apache.iceberg.flink.FlinkTypeVisitor
 
FlinkValueReaders - Class in org.apache.iceberg.flink.data
 
FlinkValueWriters - Class in org.apache.iceberg.flink.data
 
flipLR() - Method in enum org.apache.iceberg.expressions.Expression.Operation
Returns the equivalent operation when the left and right operands are exchanged.
FLOAT - org.apache.iceberg.types.Type.TypeID
 
FLOAT_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsLexer
 
FLOAT_LITERAL - Static variable in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser
 
FLOAT_LITERAL() - Method in class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FloatLiteralContext
 
FloatAsDoubleReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.FloatAsDoubleReader
 
floatBatchReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator
 
FloatBatchReader() - Constructor for class org.apache.iceberg.arrow.vectorized.parquet.VectorizedColumnIterator.FloatBatchReader
 
floatDictEncodedReader() - Method in class org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader
 
FloatFieldMetrics - Class in org.apache.iceberg
Iceberg internally tracked field level metrics, used by Parquet and ORC writers only.
FloatFieldMetrics.Builder - Class in org.apache.iceberg
 
FloatLiteralContext(IcebergSqlExtensionsParser.NumberContext) - Constructor for class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsParser.FloatLiteralContext
 
floats() - Static method in class org.apache.iceberg.avro.ValueReaders
 
floats() - Static method in class org.apache.iceberg.avro.ValueWriters
 
floats() - Static method in class org.apache.iceberg.orc.OrcValueReaders
 
floats(int) - Static method in class org.apache.iceberg.data.orc.GenericOrcWriters
 
floats(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters
 
FloatType() - Constructor for class org.apache.iceberg.types.Types.FloatType
 
flush() - Method in class org.apache.iceberg.aliyun.oss.OSSOutputStream
 
footerMetrics(ParquetMetadata, Stream<FieldMetrics<?>>, MetricsConfig) - Static method in class org.apache.iceberg.parquet.ParquetUtil
 
footerMetrics(ParquetMetadata, Stream<FieldMetrics<?>>, MetricsConfig, NameMapping) - Static method in class org.apache.iceberg.parquet.ParquetUtil
 
foreach(I...) - Static method in class org.apache.iceberg.util.Tasks
 
foreach(Iterable<I>) - Static method in class org.apache.iceberg.util.Tasks
 
foreach(Iterator<I>) - Static method in class org.apache.iceberg.util.Tasks
 
foreach(Stream<I>) - Static method in class org.apache.iceberg.util.Tasks