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

A

abort(long, WriterCommitMessage[]) - Method in class org.apache.iceberg.spark.source.StreamingWriter

abortWith(Tasks.Task<I, ?>) - Method in class org.apache.iceberg.util.Tasks.Builder

Accessor<T> - Interface in org.apache.iceberg

accessor() - Method in class org.apache.iceberg.expressions.BoundReference

accessorForField(int) - Method in class org.apache.iceberg.Schema

Return an accessor for retrieving the data from StructLike.

Accessors - Class in org.apache.iceberg

add(D) - Method in interface org.apache.iceberg.io.FileAppender

add(DataFile) - Method in class org.apache.iceberg.ManifestWriter

Add an added entry for a data file.

add(ManifestEntry) - Method in class org.apache.iceberg.ManifestWriter

add(D) - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter

add(int, String, String) - Method in class org.apache.iceberg.PartitionSpec.Builder

addAll(Iterator<D>) - Method in interface org.apache.iceberg.io.FileAppender

addAll(Iterable<D>) - Method in interface org.apache.iceberg.io.FileAppender

addCloseable(Closeable) - Method in class org.apache.iceberg.io.CloseableGroup

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.

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.

ADDED_FILES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

ADDED_RECORDS_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

addedFile(PartitionSpec, DataFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder

addedFiles() - Method in class org.apache.iceberg.ManifestReader

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

addElement(List<E>, E) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader

addElement(I, E) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

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

addFile(DataFile) - Method in class org.apache.iceberg.OverwriteData

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.

addFile(DataFile) - Method in class org.apache.iceberg.ReplacePartitionsOperation

addPair(Map<K, V>, K, V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader

addPair(I, K, V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

addSchema(Schema) - Method in class org.apache.iceberg.data.avro.IcebergDecoder

Adds an Iceberg schema that can be used to decode buffers.

ADJUST_TO_UTC_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil

after(String) - Method in class org.apache.iceberg.FileHistory.Builder

after(long) - Method in class org.apache.iceberg.FileHistory.Builder

after(String) - Method in class org.apache.iceberg.ScanSummary.Builder

after(long) - Method in class org.apache.iceberg.ScanSummary.Builder

aliasToId(String) - Method in class org.apache.iceberg.Schema

Returns the column id for the given column alias.

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

alwaysFalse() - Static method in class org.apache.iceberg.expressions.Expressions

alwaysFalse() - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

alwaysTrue() - Static method in class org.apache.iceberg.expressions.Expressions

alwaysTrue() - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

And - Class in org.apache.iceberg.expressions

and(Expression, Expression) - Static method in class org.apache.iceberg.expressions.Expressions

and(R, R) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

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 the contents of a manifest to the table.

apply(TableMetadata) - Method in class org.apache.iceberg.OverwriteData

apply() - Method in interface org.apache.iceberg.PendingUpdate

Apply the pending changes and return the uncommitted changes for validation.

apply(TableMetadata) - Method in class org.apache.iceberg.ReplaceManifests

apply(TableMetadata) - Method in class org.apache.iceberg.ReplacePartitionsOperation

apply() - Method in class org.apache.iceberg.SetLocation

apply(S) - Method in interface org.apache.iceberg.transforms.Transform

Transforms a value to its corresponding partition value.

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

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

asCombinedScanTask() - Method in interface org.apache.iceberg.CombinedScanTask

asCombinedScanTask() - Method in interface org.apache.iceberg.ScanTask

asFileScanTask() - Method in interface org.apache.iceberg.FileScanTask

asFileScanTask() - Method in interface org.apache.iceberg.ScanTask

asListType() - Method in interface org.apache.iceberg.types.Type

asListType() - Method in class org.apache.iceberg.types.Types.ListType

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 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.

asPrimitiveType() - Method in interface org.apache.iceberg.types.Type

asPrimitiveType() - Method in class org.apache.iceberg.types.Type.PrimitiveType

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.

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.

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.

asStructType() - Method in interface org.apache.iceberg.types.Type

asStructType() - Method in class org.apache.iceberg.types.Types.StructType

Avro - Class in org.apache.iceberg.avro

Avro.ReadBuilder - Class in org.apache.iceberg.avro

Avro.WriteBuilder - Class in org.apache.iceberg.avro

AVRO_COMPRESSION - Static variable in class org.apache.iceberg.TableProperties

AVRO_COMPRESSION_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

AvroIterable<D> - 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

B

BaseCombinedScanTask - Class in org.apache.iceberg

BaseCombinedScanTask(FileScanTask...) - Constructor for class org.apache.iceberg.BaseCombinedScanTask

BaseCombinedScanTask(List<FileScanTask>) - Constructor for class org.apache.iceberg.BaseCombinedScanTask

BaseMetastoreCatalog - Class in org.apache.iceberg

BaseMetastoreCatalog(Configuration) - Constructor for class org.apache.iceberg.BaseMetastoreCatalog

BaseMetastoreTableOperations - Class in org.apache.iceberg

BaseMetastoreTableOperations(Configuration) - Constructor for class org.apache.iceberg.BaseMetastoreTableOperations

BaseMetastoreTables - Class in org.apache.iceberg

BaseMetastoreTables(Configuration) - Constructor for class org.apache.iceberg.BaseMetastoreTables

BaseTable - Class in org.apache.iceberg

Base Table implementation.

BaseTable(TableOperations, String) - Constructor for class org.apache.iceberg.BaseTable

before(String) - Method in class org.apache.iceberg.FileHistory.Builder

before(long) - Method in class org.apache.iceberg.FileHistory.Builder

before(String) - Method in class org.apache.iceberg.ScanSummary.Builder

before(long) - Method in class org.apache.iceberg.ScanSummary.Builder

beginCreate(Schema, PartitionSpec, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

beginCreate(Schema, PartitionSpec, Map<String, String>, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

beginReplace(Schema, PartitionSpec, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

beginReplace(Schema, PartitionSpec, Map<String, String>, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

BinaryAsDecimalReader(ColumnDescriptor, int) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.BinaryAsDecimalReader

BinaryType() - Constructor for class org.apache.iceberg.types.Types.BinaryType

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, 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.

bind(Types.StructType, boolean) - Method in class org.apache.iceberg.expressions.UnboundPredicate

Bind this UnboundPredicate.

Binder - Class in org.apache.iceberg.expressions

Rewrites expressions by replacing unbound named references with references to fields in a struct schema.

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

booleans() - Static method in class org.apache.iceberg.avro.ValueReaders

booleans() - Static method in class org.apache.iceberg.avro.ValueWriters

BooleanType() - Constructor for class org.apache.iceberg.types.Types.BooleanType

BoundExpressionVisitor() - Constructor for class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

BoundPredicate<T> - Class in org.apache.iceberg.expressions

BoundReference<T> - Class in org.apache.iceberg.expressions

boundReferences(Types.StructType, List<Expression>, boolean) - Static method in class org.apache.iceberg.expressions.Binder

bucket(String, int) - Method in class org.apache.iceberg.PartitionSpec.Builder

bucket(String, int, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

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.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(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() - 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(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.

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.FileHistory.Builder

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.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

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(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() - 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.DynMethods.Builder

Returns the first valid implementation as a BoundMethod or throws a NoSuchMethodException if there is none.

builder() - Static method in class org.apache.iceberg.common.DynClasses

Builder() - Constructor for class org.apache.iceberg.common.DynClasses.Builder

builder() - Static method in class org.apache.iceberg.common.DynConstructors

builder(Class<?>) - Static method in class org.apache.iceberg.common.DynConstructors

Builder(Class<?>) - Constructor for class org.apache.iceberg.common.DynConstructors.Builder

Builder() - Constructor for class org.apache.iceberg.common.DynConstructors.Builder

builder() - Static method in class org.apache.iceberg.common.DynFields

Builder() - Constructor for class org.apache.iceberg.common.DynFields.Builder

builder(String) - Static method in class org.apache.iceberg.common.DynMethods

Constructs a new builder for calling methods dynamically.

Builder(String) - Constructor for class org.apache.iceberg.common.DynMethods.Builder

builder(PartitionSpec) - Static method in class org.apache.iceberg.DataFiles

Builder() - Constructor for class org.apache.iceberg.DataFiles.Builder

Builder(PartitionSpec) - Constructor for class org.apache.iceberg.DataFiles.Builder

Builder(Table) - Constructor for class org.apache.iceberg.FileHistory.Builder

Builder(TableScan) - Constructor for class org.apache.iceberg.ScanSummary.Builder

builder() - Static method in class org.apache.iceberg.SnapshotSummary

Builder() - Constructor for class org.apache.iceberg.SnapshotSummary.Builder

Builder(Iterable<I>) - Constructor for class org.apache.iceberg.util.Tasks.Builder

builderFor(Schema) - Static method in class org.apache.iceberg.PartitionSpec

Creates a new partition spec builder for the given Schema.

buildList(List<E>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader

buildList(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

buildMap(Map<K, V>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader

buildMap(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.data.parquet.GenericParquetReaders

buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.parquet.ParquetAvroValueReaders

buildReader(MessageType, Schema, Map<Integer, Object>) - Static method in class org.apache.iceberg.pig.PigParquetReader

buildReader(Schema, MessageType) - Static method in class org.apache.iceberg.spark.data.SparkParquetReaders

buildReplacement(Schema, PartitionSpec, Map<String, String>) - Method in class org.apache.iceberg.TableMetadata

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

buildWriter(MessageType) - Static method in class org.apache.iceberg.data.parquet.GenericParquetWriter

buildWriter(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetAvroWriter

buildWriter(Schema, MessageType) - Static method in class org.apache.iceberg.spark.data.SparkParquetWriters

byteBuffers() - Static method in class org.apache.iceberg.avro.ValueReaders

byteBuffers() - Static method in class org.apache.iceberg.avro.ValueWriters

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

BytesReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.BytesReader

C

callInit() - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

canTransform(Type) - Method in interface org.apache.iceberg.transforms.Transform

Checks whether this function can be applied to the give Type.

caseInsensitive() - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder

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 name

caseInsensitiveSelect(Collection<String>) - Method in class org.apache.iceberg.Schema

Creates a projection schema for a subset of columns, selected by case insensitive name

caseSensitive(boolean) - Method in class org.apache.iceberg.ManifestReader

Returns a new ManifestReader that, if filtered via ManifestReader.select(java.util.Collection), ManifestReader.filterPartitions(Expression) or ManifestReader.filterRows(Expression), will apply the specified case sensitivity for column name matching.

caseSensitive(boolean) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder

caseSensitive(boolean) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

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.

Catalog - Interface in org.apache.iceberg.catalog

A Catalog API for table create, drop, and load operations.

CHANGED_PARTITION_COUNT_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

charSequences() - Static method in class org.apache.iceberg.types.Comparators

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.ValidationException

checkCompatibility(PartitionSpec, Schema) - Static method in class org.apache.iceberg.PartitionSpec

CheckCompatibility - Class in org.apache.iceberg.types

child() - Method in class org.apache.iceberg.expressions.Not

cleanUncommitted(Set<ManifestFile>) - Method in class org.apache.iceberg.ReplaceManifests

clear() - Method in class org.apache.iceberg.DataFiles.Builder

clear() - Method in class org.apache.iceberg.orc.ColumnIdMap

clear() - Method in class org.apache.iceberg.SnapshotSummary.Builder

close() - Method in class org.apache.iceberg.FilteredManifest

close() - Method in class org.apache.iceberg.hive.HiveCatalog

close() - Method in class org.apache.iceberg.hive.HiveTables

close() - Method in class org.apache.iceberg.io.CloseableGroup

close() - Method in class org.apache.iceberg.ManifestWriter

close() - Method in class org.apache.iceberg.orc.VectorizedRowBatchIterator

close() - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter

close() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

CloseableGroup - Class in org.apache.iceberg.io

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

clusterBy(Function<DataFile, Object>) - Method in class org.apache.iceberg.ReplaceManifests

clusterBy(Function<DataFile, Object>) - Method in interface org.apache.iceberg.RewriteManifests

Groups an existing DataFile by a cluster key produced by a function.

collections(int, int, ParquetValueWriter<E>) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters

column() - Method in interface org.apache.iceberg.parquet.ParquetValueReader

column - Variable in class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader

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 - Variable in class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter

ColumnIdMap - Class in org.apache.iceberg.orc

The mapping from ORC's TypeDescription to the Iceberg column ids.

ColumnIdMap() - Constructor for class org.apache.iceberg.orc.ColumnIdMap

ColumnIterator<T> - Class in org.apache.iceberg.parquet

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

columnSizes() - Method in interface org.apache.iceberg.DataFile

columnSizes() - Method in class org.apache.iceberg.Metrics

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.

commit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

commit(TableMetadata, TableMetadata) - Method in class org.apache.iceberg.hive.HiveTableOperations

commit() - Method in interface org.apache.iceberg.PendingUpdate

Apply the pending changes and commit.

commit() - Method in class org.apache.iceberg.SetLocation

commit(long, WriterCommitMessage[]) - Method in class org.apache.iceberg.spark.source.StreamingWriter

commit(TableMetadata, TableMetadata) - Method in interface org.apache.iceberg.TableOperations

Replace the base table metadata with a new version.

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_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

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

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.Literal

Return a Comparator for values.

Comparators - Class in org.apache.iceberg.types

compatibleWith(PartitionSpec) - Method in class org.apache.iceberg.PartitionSpec

Returns true if this spec is equivalent to the other, with field names ignored.

COMPRESS_METADATA - Static variable in class org.apache.iceberg.ConfigProperties

COMPRESS_METADATA_DEFAULT - Static variable in class org.apache.iceberg.ConfigProperties

concat(Iterable<CloseableIterable<E>>) - Static method in interface org.apache.iceberg.io.CloseableIterable

config(String, String) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder

config(String, String) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder

ConfigProperties - Class in org.apache.iceberg

containsKey(Object) - Method in class org.apache.iceberg.orc.ColumnIdMap

containsNull() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

containsNull() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary

containsValue(Object) - Method in class org.apache.iceberg.orc.ColumnIdMap

Conversions - Class in org.apache.iceberg.types

convert(Schema, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Schema, Map<Types.StructType, String>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Type) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Types.StructType, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Type, Map<Types.StructType, String>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

convert(Type) - Static method in class org.apache.iceberg.hive.HiveTypeConverter

convert(Schema, String) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil

convert(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil

convert(Schema, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType

convert(Schema) - Static method in class org.apache.iceberg.pig.SchemaUtil

convert(Filter) - Static method in class org.apache.iceberg.spark.SparkFilters

convert(Schema) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Convert a Schema to a Spark type.

convert(Type) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Convert a Type to a Spark type.

convert(StructType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Convert a Spark struct to a Schema with new field ids.

convert(DataType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Convert a Spark struct to a Type with new field ids.

convert(Schema, StructType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Convert a Spark struct to a Schema based on the given schema.

convertTypes(Types.StructType, String) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

copy() - Method in class org.apache.iceberg.data.GenericRecord

copy(Map<String, Object>) - Method in class org.apache.iceberg.data.GenericRecord

copy() - Method in interface org.apache.iceberg.data.Record

copy(Map<String, Object>) - Method in interface org.apache.iceberg.data.Record

copy() - Method in interface org.apache.iceberg.DataFile

Copies this data file.

copy(DataFile) - Method in class org.apache.iceberg.DataFiles.Builder

copy(PartitionSpec, StructLike) - Static method in class org.apache.iceberg.DataFiles

copy() - Method in interface org.apache.iceberg.encryption.EncryptionKeyMetadata

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(ByteBuffer) - Static method in class org.apache.iceberg.util.ByteBuffers

copyWithoutStats() - Method in interface org.apache.iceberg.DataFile

Copies this data file without file stats.

create(Schema, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

create(Schema, PartitionSpec, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

create(Schema, PartitionSpec, Map<String, String>, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

create(Schema) - Static method in class org.apache.iceberg.data.avro.DataReader

create(Schema) - Static method in class org.apache.iceberg.data.avro.DataWriter

create(Schema) - Static method in class org.apache.iceberg.data.GenericRecord

create(Types.StructType) - Static method in class org.apache.iceberg.data.GenericRecord

create() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

create(Schema, PartitionSpec, Map<String, String>, String) - Method in class org.apache.iceberg.hadoop.HadoopTables

Create a table using the FileSystem implementation resolve from location.

create(Schema, String) - Method in class org.apache.iceberg.hive.HiveTables

create(Schema, PartitionSpec, Map<String, String>, String) - Method in class org.apache.iceberg.hive.HiveTables

create() - Method in interface org.apache.iceberg.io.OutputFile

Create a new file and return a PositionOutputStream to it.

create(Schema, String) - Method in interface org.apache.iceberg.Tables

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

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.

createReader(DataSourceOptions) - Method in class org.apache.iceberg.spark.source.IcebergSource

createReaderFunc(Function<Schema, DatumReader<?>>) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

createReaderFunc(Function<Schema, OrcValueReader<?>>) - 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.pig.IcebergPigInputFormat

createStreamWriter(String, StructType, OutputMode, DataSourceOptions) - Method in class org.apache.iceberg.spark.source.IcebergSource

createTable(TableIdentifier, Schema, PartitionSpec, String, Map<String, String>) - Method in class org.apache.iceberg.BaseMetastoreCatalog

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(TableIdentifier, Schema, PartitionSpec) - Method in interface org.apache.iceberg.catalog.Catalog

Create a table.

createTable(TableIdentifier, Schema) - Method in interface org.apache.iceberg.catalog.Catalog

Create an unpartitioned table.

createTable(TableIdentifier, Schema, PartitionSpec, String, Map<String, String>) - Method in class org.apache.iceberg.hive.HiveCatalog

createTableTransaction(TableOperations, TableMetadata) - Static method in class org.apache.iceberg.Transactions

createWriter(String, StructType, SaveMode, DataSourceOptions) - Method in class org.apache.iceberg.spark.source.IcebergSource

createWriterFunc(Function<Schema, DatumWriter<?>>) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

createWriterFunc(Function<TypeDescription, OrcValueWriter<?>>) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder

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 interface org.apache.iceberg.TableOperations

Return the currently loaded table metadata, without checking for updates.

currentDefinitionLevel() - Method in class org.apache.iceberg.parquet.ColumnIterator

currentMetadataLocation() - Method in class org.apache.iceberg.BaseMetastoreTableOperations

currentRepetitionLevel() - Method in class org.apache.iceberg.parquet.ColumnIterator

currentSnapshot() - Method in class org.apache.iceberg.BaseTable

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

CustomOrderSchemaVisitor() - Constructor for class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

D

data(PartitionSpec, String) - Static method in class org.apache.iceberg.DataFiles

DataFile - Interface in org.apache.iceberg

Interface for files listed in a table manifest.

DataFiles - Class in org.apache.iceberg

DataFiles.Builder - Class in org.apache.iceberg

DataOperations - Class in org.apache.iceberg

Data operations that produce snapshots.

DataReader<T> - Class in org.apache.iceberg.data.avro

dataTimestampMillis() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics

DataWriter<T> - Class in org.apache.iceberg.data.avro

DateType() - Constructor for class org.apache.iceberg.types.Types.DateType

day(String) - Method in class org.apache.iceberg.PartitionSpec.Builder

day(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

day(Type) - Static method in class org.apache.iceberg.transforms.Transforms

Returns a day Transform for date or timestamp types.

decimal(ValueReader<byte[]>, int) - Static method in class org.apache.iceberg.avro.ValueReaders

decimal(int, int) - Static method in class org.apache.iceberg.avro.ValueWriters

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

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

decimalRequriedBytes(int) - Static method in class org.apache.iceberg.types.TypeUtil

decode(InputStream, D) - Method in class org.apache.iceberg.data.avro.IcebergDecoder

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(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 class org.apache.iceberg.encryption.PlaintextEncryptionManager

DEFAULT_FILE_FORMAT - Static variable in class org.apache.iceberg.TableProperties

DEFAULT_FILE_FORMAT_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.

defaultFormat(FileFormat) - Method in interface org.apache.iceberg.UpdateProperties

Set the default file format for the table.

defaultSpecId() - Method in class org.apache.iceberg.TableMetadata

defaultWarehouseLocation(Configuration, TableIdentifier) - Method in class org.apache.iceberg.BaseMetastoreCatalog

defaultWarehouseLocation(Configuration, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

defaultWarehouseLocation(Configuration, TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog

DelegatingInputStream - Interface in org.apache.iceberg.io

DelegatingOutputStream - Interface in org.apache.iceberg.io

DELETE - Static variable in class org.apache.iceberg.DataOperations

Data is deleted from the table and no data is added.

delete(DataFile) - Method in class org.apache.iceberg.ManifestWriter

Add a delete entry for a data file.

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_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

DELETED_RECORDS_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

deletedFile(PartitionSpec, DataFile) - Method in class org.apache.iceberg.SnapshotSummary.Builder

deletedFiles() - Method in class org.apache.iceberg.ManifestReader

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

deleteFile(CharSequence) - Method in interface org.apache.iceberg.DeleteFiles

Delete a file path from the underlying table.

deleteFile(DataFile) - Method in interface org.apache.iceberg.DeleteFiles

Delete a file tracked by a DataFile from the underlying table.

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(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.

DeleteFiles - Interface in org.apache.iceberg

API for deleting files from a table.

deleteFromRowFilter(Expression) - Method in interface org.apache.iceberg.DeleteFiles

Delete files that match an Expression on data rows from the table.

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.

deserialize(TypeDescription, ByteBuffer) - Static method in class org.apache.iceberg.orc.ColumnIdMap

doc() - Method in class org.apache.iceberg.types.Types.NestedField

doubles() - Static method in class org.apache.iceberg.avro.ValueReaders

doubles() - Static method in class org.apache.iceberg.avro.ValueWriters

DoubleType() - Constructor for class org.apache.iceberg.types.Types.DoubleType

dropTable(TableIdentifier) - Method in interface org.apache.iceberg.catalog.Catalog

Drop a table.

dropTable(TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog

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

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.catalog.Namespace

EMPTY - Static variable in interface org.apache.iceberg.encryption.EncryptionKeyMetadata

empty() - Static method in interface org.apache.iceberg.encryption.EncryptionKeyMetadata

empty() - Static method in interface org.apache.iceberg.io.CloseableIterable

encode(D) - Method in class org.apache.iceberg.data.avro.IcebergEncoder

encode(D, OutputStream) - Method in class org.apache.iceberg.data.avro.IcebergEncoder

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(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 class org.apache.iceberg.encryption.PlaintextEncryptionManager

EncryptedFiles - Class in org.apache.iceberg.encryption

encryptedInput(InputFile, EncryptionKeyMetadata) - Static method in class org.apache.iceberg.encryption.EncryptedFiles

encryptedInput(InputFile, ByteBuffer) - Static method in class org.apache.iceberg.encryption.EncryptedFiles

encryptedInput(InputFile, byte[]) - Static method in class org.apache.iceberg.encryption.EncryptedFiles

EncryptedInputFile - Interface in org.apache.iceberg.encryption

Thin wrapper around an InputFile instance that is encrypted.

encryptedInputFile() - Method in interface org.apache.iceberg.encryption.EncryptedInputFile

The InputFile that is reading raw encrypted bytes from the underlying file system.

encryptedOutput(OutputFile, EncryptionKeyMetadata) - Static method in class org.apache.iceberg.encryption.EncryptedFiles

encryptedOutput(OutputFile, ByteBuffer) - Static method in class org.apache.iceberg.encryption.EncryptedFiles

encryptedOutput(OutputFile, byte[]) - 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 interface org.apache.iceberg.Table

encryption() - Method in interface org.apache.iceberg.TableOperations

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 - Interface in org.apache.iceberg.encryption

Module for encrypting and decrypting table data files.

entrySet() - Method in class org.apache.iceberg.orc.ColumnIdMap

eq(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

equal(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

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.PartitionField

equals(Object) - Method in class org.apache.iceberg.PartitionSpec

equals(Object) - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry

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.StructLikeWrapper

eval(StructLike) - Method in class org.apache.iceberg.expressions.Evaluator

eval(ManifestFile) - Method in class org.apache.iceberg.expressions.InclusiveManifestEvaluator

Test whether the file may contain records that match the expression.

eval(DataFile) - Method in class org.apache.iceberg.expressions.InclusiveMetricsEvaluator

Test whether the file may contain records that match the expression.

eval(DataFile) - Method in class org.apache.iceberg.expressions.StrictMetricsEvaluator

Test whether the file may contain records that match the expression.

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

executeWith(ExecutorService) - Method in class org.apache.iceberg.util.Tasks.Builder

existing(DataFile, long) - Method in class org.apache.iceberg.ManifestWriter

Add an existing entry for a data file.

existingFilesCount() - Method in class org.apache.iceberg.GenericManifestFile

existingFilesCount() - Method in interface org.apache.iceberg.ManifestFile

exists() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

exists() - Method in interface org.apache.iceberg.io.InputFile

Checks whether the file exists.

expireOlderThan(long) - Method in interface org.apache.iceberg.ExpireSnapshots

Expires all snapshots older than the given timestamp.

expireSnapshotId(long) - Method in interface org.apache.iceberg.ExpireSnapshots

Expires a specific Snapshot identified by id.

expireSnapshots() - Method in class org.apache.iceberg.BaseTable

ExpireSnapshots - Interface in org.apache.iceberg

API for removing old snapshots from a table.

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.

exponentialBackoff(long, long, long, double) - Method in class org.apache.iceberg.util.Tasks.Builder

Expression - Interface in org.apache.iceberg.expressions

Represents a boolean expression tree.

Expression.Operation - Enum in org.apache.iceberg.expressions

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.ExpressionVisitor<R> - Class in org.apache.iceberg.expressions

F

factory() - Static method in class org.apache.iceberg.util.JsonUtil

False - Class in org.apache.iceberg.expressions

An expression that is always false.

field(Types.NestedField) - Method in class org.apache.iceberg.parquet.TypeToMessageType

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<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility

field(Types.NestedField, Map<String, Integer>) - Method in class org.apache.iceberg.types.IndexByName

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(String) - Method in class org.apache.iceberg.types.Types.StructType

field(int) - Method in class org.apache.iceberg.types.Types.StructType

field(Types.NestedField, Supplier<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

field(Types.NestedField, T) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

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.types.Types.NestedField

fieldIds() - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

fieldNames - Variable in class org.apache.iceberg.parquet.ParquetTypeVisitor

fieldNames - Variable in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

fieldNames() - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

fields() - Method in class org.apache.iceberg.PartitionSpec

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

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

FileAppender<D> - Interface in org.apache.iceberg.io

fileCount() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics

FileFormat - Enum in org.apache.iceberg

Enum of supported file formats.

FileHistory - Class in org.apache.iceberg

FileHistory.Builder - Class in org.apache.iceberg

FileIO - Interface in org.apache.iceberg.io

Pluggable module for reading, writing, and deleting files.

fileMetrics(InputFile) - Static method in class org.apache.iceberg.parquet.ParquetUtil

fileOrdinal() - Method in interface org.apache.iceberg.DataFile

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

FileScanTask - Interface in org.apache.iceberg

A scan task over a range of a single file.

fileSizeInBytes() - Method in interface org.apache.iceberg.DataFile

filter() - Method in class org.apache.iceberg.events.ScanEvent

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() - Method in interface org.apache.iceberg.TableScan

Returns this scan's filter Expression.

Filterable<T extends Filterable<T>> - Interface in org.apache.iceberg

Methods to filter files in a snapshot or manifest when reading.

FilteredManifest - Class in org.apache.iceberg

filterPartitions(Expression) - Method in interface org.apache.iceberg.Filterable

Adds a filter expression on partition data for matching files.

filterPartitions(Expression) - Method in class org.apache.iceberg.FilteredManifest

filterPartitions(Expression) - Method in class org.apache.iceberg.ManifestReader

filterRecords(boolean) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

filterRows(Expression) - Method in interface org.apache.iceberg.Filterable

Adds a filter expression on data rows for matching files.

filterRows(Expression) - Method in class org.apache.iceberg.FilteredManifest

filterRows(Expression) - Method in class org.apache.iceberg.ManifestReader

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.

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.

findTable(DataSourceOptions, Configuration) - Method in class org.apache.iceberg.spark.source.IcebergSource

findType(String) - Method in class org.apache.iceberg.Schema

findType(int) - Method in class org.apache.iceberg.Schema

Returns the Type of a sub-field identified by the field id.

first() - Method in class org.apache.iceberg.util.Pair

fixed(int) - Static method in class org.apache.iceberg.avro.ValueReaders

fixed(Schema) - Static method in class org.apache.iceberg.avro.ValueReaders

fixed(int) - Static method in class org.apache.iceberg.avro.ValueWriters

flipLR() - Method in enum org.apache.iceberg.expressions.Expression.Operation

FloatAsDoubleReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.FloatAsDoubleReader

floats() - Static method in class org.apache.iceberg.avro.ValueReaders

floats() - Static method in class org.apache.iceberg.avro.ValueWriters

FloatType() - Constructor for class org.apache.iceberg.types.Types.FloatType

footerMetrics(ParquetMetadata) - Static method in class org.apache.iceberg.parquet.ParquetUtil

foreach(Iterable<I>) - Static method in class org.apache.iceberg.util.Tasks

foreach(I...) - Static method in class org.apache.iceberg.util.Tasks

format() - Method in interface org.apache.iceberg.DataFile

forTable(Table) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

forType(Type.PrimitiveType) - Static method in class org.apache.iceberg.types.Comparators

fromByteBuffer(Type, ByteBuffer) - Static method in class org.apache.iceberg.types.Conversions

fromEncryptedOutputFile(EncryptedOutputFile, PartitionData, Metrics, List<Long>) - Static method in class org.apache.iceberg.DataFiles

fromFileName(CharSequence) - Static method in enum org.apache.iceberg.FileFormat

fromFixed(GenericFixed, Schema, LogicalType) - Method in class org.apache.iceberg.avro.UUIDConversion

fromInputFile(InputFile, PartitionData, long) - Static method in class org.apache.iceberg.DataFiles

fromInputFile(InputFile, long) - Static method in class org.apache.iceberg.DataFiles

fromInputFile(InputFile) - Static method in class org.apache.iceberg.orc.OrcMetrics

fromInputFile(InputFile, Configuration) - Static method in class org.apache.iceberg.orc.OrcMetrics

fromJson(Schema, JsonNode) - Static method in class org.apache.iceberg.PartitionSpecParser

fromJson(Schema, String) - Static method in class org.apache.iceberg.PartitionSpecParser

fromJson(JsonNode) - Static method in class org.apache.iceberg.SchemaParser

fromJson(String) - Static method in class org.apache.iceberg.SchemaParser

fromJson(TableOperations, String) - Static method in class org.apache.iceberg.SnapshotParser

fromLocation(CharSequence, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopInputFile

fromLocation(CharSequence, long, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopInputFile

fromOrc(TypeDescription, ColumnIdMap) - Method in class org.apache.iceberg.orc.TypeConversion

Convert an ORC schema to an Iceberg schema.

fromPartitionString(Type, String) - Static method in class org.apache.iceberg.types.Conversions

fromPath(Path, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopInputFile

fromPath(Path, long, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopInputFile

fromPath(Path, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopOutputFile

fromPrimitiveString(String) - Static method in class org.apache.iceberg.types.Types

fromStat(FileStatus, long) - Static method in class org.apache.iceberg.DataFiles

fromStat(FileStatus, PartitionData, long) - Static method in class org.apache.iceberg.DataFiles

fromStat(FileStatus, PartitionData, Metrics, EncryptionKeyMetadata, List<Long>) - Static method in class org.apache.iceberg.DataFiles

fromStatus(FileStatus, Configuration) - Static method in class org.apache.iceberg.hadoop.HadoopInputFile

fromString(Type, String) - Static method in class org.apache.iceberg.transforms.Transforms

G

genericFixed(int) - Static method in class org.apache.iceberg.avro.ValueWriters

GenericManifestFile - Class in org.apache.iceberg

GenericManifestFile(Schema) - Constructor for class org.apache.iceberg.GenericManifestFile

Used by Avro reflection to instantiate this class when reading manifest files.

GenericManifestFile(String, long, int, long, int, int, int, List<ManifestFile.PartitionFieldSummary>) - Constructor for class org.apache.iceberg.GenericManifestFile

GenericParquetReaders - Class in org.apache.iceberg.data.parquet

GenericParquetWriter - Class in org.apache.iceberg.data.parquet

GenericPartitionFieldSummary - Class in org.apache.iceberg

GenericPartitionFieldSummary(Schema) - Constructor for class org.apache.iceberg.GenericPartitionFieldSummary

Used by Avro reflection to instantiate this class when reading manifest files.

GenericPartitionFieldSummary(boolean, ByteBuffer, ByteBuffer) - Constructor for class org.apache.iceberg.GenericPartitionFieldSummary

GenericRecord - Class in org.apache.iceberg.data

get(T) - Method in interface org.apache.iceberg.Accessor

get(S, int) - Method in class org.apache.iceberg.avro.ValueReaders.StructReader

get(S, int) - Method in class org.apache.iceberg.avro.ValueWriters.StructWriter

get() - Method in class org.apache.iceberg.common.DynFields.BoundField

get() - Method in class org.apache.iceberg.common.DynFields.StaticField

get(Object) - Method in class org.apache.iceberg.common.DynFields.UnboundField

get(int) - Method in class org.apache.iceberg.data.GenericRecord

get(int, Class<T>) - Method in class org.apache.iceberg.data.GenericRecord

get(int) - Method in interface org.apache.iceberg.data.Record

get(StructLike) - Method in class org.apache.iceberg.expressions.BoundReference

get(int, Class<T>) - Method in class org.apache.iceberg.GenericManifestFile

get(int) - Method in class org.apache.iceberg.GenericManifestFile

get(int, Class<T>) - Method in class org.apache.iceberg.GenericPartitionFieldSummary

get(int) - Method in class org.apache.iceberg.GenericPartitionFieldSummary

get() - Method in class org.apache.iceberg.hadoop.SerializableConfiguration

get(Object) - Method in class org.apache.iceberg.orc.ColumnIdMap

get(S, int) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.StructWriter

get(int, Class<T>) - Method in interface org.apache.iceberg.StructLike

get() - Static method in class org.apache.iceberg.types.Types.BinaryType

get() - Static method in class org.apache.iceberg.types.Types.BooleanType

get() - Static method in class org.apache.iceberg.types.Types.DateType

get() - Static method in class org.apache.iceberg.types.Types.DoubleType

get() - Static method in class org.apache.iceberg.types.Types.FloatType

get() - Static method in class org.apache.iceberg.types.Types.IntegerType

get() - Static method in class org.apache.iceberg.types.Types.LongType

get() - Static method in class org.apache.iceberg.types.Types.StringType

get() - Static method in class org.apache.iceberg.types.Types.TimeType

get() - Static method in class org.apache.iceberg.types.Types.UUIDType

get() - Method in interface org.apache.iceberg.types.TypeUtil.NextID

get() - Method in class org.apache.iceberg.util.CharSequenceWrapper

get(int) - Method in class org.apache.iceberg.util.Pair

getAliases() - Method in class org.apache.iceberg.Schema

Returns an alias map for this schema, if set.

getBool(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getConf() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

getConf() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

getConf() - Method in class org.apache.iceberg.hadoop.HadoopTables

getConstructedClass() - Method in class org.apache.iceberg.common.DynConstructors.Ctor

getConvertedType() - Method in class org.apache.iceberg.avro.UUIDConversion

getCurrentKey() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

getCurrentValue() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

getDelegate() - Method in interface org.apache.iceberg.io.DelegatingInputStream

getDelegate() - Method in interface org.apache.iceberg.io.DelegatingOutputStream

getElement(List<E>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader

getElement(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

getElementId(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

getFeatures() - Method in class org.apache.iceberg.pig.IcebergStorage

getField(String) - Method in class org.apache.iceberg.data.GenericRecord

getField(String) - Method in interface org.apache.iceberg.data.Record

getField(I, int) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

getFieldId(Schema.Field) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

getFieldsBySourceId(int) - Method in class org.apache.iceberg.PartitionSpec

getFileExtension(Configuration) - Static method in class org.apache.iceberg.TableMetadataParser

getFileSystem(Path, Configuration) - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

getFromUDFContext(String, Class<T>) - Method in class org.apache.iceberg.pig.IcebergStorage

getInputFormat() - Method in class org.apache.iceberg.pig.IcebergStorage

getInt(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getKey() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ReusableEntry

getKeyId(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

getLength() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

getLength() - Method in interface org.apache.iceberg.io.InputFile

getLogicalTypeName() - Method in class org.apache.iceberg.avro.UUIDConversion

getLong(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getMetadata() - Method in class org.apache.iceberg.avro.AvroIterable

getNext() - Method in class org.apache.iceberg.pig.IcebergStorage

getPair(Map<K, V>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader

getPair(I) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

getPartitionKeys(String, Job) - Method in class org.apache.iceberg.pig.IcebergStorage

getPath() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

getPos() - Method in class org.apache.iceberg.io.PositionOutputStream

Return the current position in the OutputStream.

getPos() - Method in class org.apache.iceberg.io.SeekableInputStream

Return the current position in the InputStream.

getPredicateFields(String, Job) - Method in class org.apache.iceberg.pig.IcebergStorage

getProgress() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

getProjectedIds(Schema) - Static method in class org.apache.iceberg.types.TypeUtil

getProjectedIds(Type) - Static method in class org.apache.iceberg.types.TypeUtil

getResultType(Type) - Method in interface org.apache.iceberg.transforms.Transform

Returns the Type produced by this transform given a source type.

getSchema() - Method in class org.apache.iceberg.GenericManifestFile

getSchema() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

getSchema(String, Job) - Method in class org.apache.iceberg.pig.IcebergStorage

getSchema() - Method in class org.apache.iceberg.util.Pair

getSplitOffsets(ParquetMetadata) - Static method in class org.apache.iceberg.parquet.ParquetUtil

getSplits(JobContext) - Method in class org.apache.iceberg.pig.IcebergPigInputFormat

getStat() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

getStatistics(String, Job) - Method in class org.apache.iceberg.pig.IcebergStorage

getString(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getStringList(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getStringMap(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getStringOrNull(String, JsonNode) - Static method in class org.apache.iceberg.util.JsonUtil

getSupportedExpressionTypes() - Method in class org.apache.iceberg.pig.IcebergStorage

getType(Types.StructType) - Static method in interface org.apache.iceberg.DataFile

getType() - Static method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary

getValue() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ReusableEntry

getValueId(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

getWorkerPool() - Static method in class org.apache.iceberg.util.ThreadPools

Return an ExecutorService that uses the "worker" thread-pool.

greaterThan(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

greaterThanOrEqual(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

gt(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

gtEq(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

H

HadoopFileIO - Class in org.apache.iceberg.hadoop

HadoopFileIO(Configuration) - Constructor for class org.apache.iceberg.hadoop.HadoopFileIO

HadoopInputFile - Class in org.apache.iceberg.hadoop

InputFile implementation using the Hadoop FileSystem API.

HadoopOutputFile - Class in org.apache.iceberg.hadoop

OutputFile implementation using the Hadoop FileSystem API.

HadoopTableOperations - Class in org.apache.iceberg.hadoop

TableOperations implementation for file systems that support atomic rename.

HadoopTableOperations(Path, Configuration) - Constructor for class org.apache.iceberg.hadoop.HadoopTableOperations

HadoopTables - Class in org.apache.iceberg.hadoop

Implementation of Iceberg tables that uses the Hadoop FileSystem to store metadata and manifests.

HadoopTables() - Constructor for class org.apache.iceberg.hadoop.HadoopTables

HadoopTables(Configuration) - Constructor for class org.apache.iceberg.hadoop.HadoopTables

hashCode() - Method in class org.apache.iceberg.data.GenericRecord

hashCode() - Method in class org.apache.iceberg.GenericManifestFile

hashCode() - Method in class org.apache.iceberg.PartitionField

hashCode() - Method in class org.apache.iceberg.PartitionSpec

hashCode() - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry

hashCode() - Method in class org.apache.iceberg.types.Types.DecimalType

hashCode() - Method in class org.apache.iceberg.types.Types.FixedType

hashCode() - Method in class org.apache.iceberg.types.Types.ListType

hashCode() - Method in class org.apache.iceberg.types.Types.MapType

hashCode() - Method in class org.apache.iceberg.types.Types.NestedField

hashCode() - Method in class org.apache.iceberg.types.Types.StructType

hashCode() - Method in class org.apache.iceberg.types.Types.TimestampType

hashCode() - Method in class org.apache.iceberg.util.CharSequenceWrapper

hashCode() - Method in class org.apache.iceberg.util.Pair

hashCode() - Method in class org.apache.iceberg.util.StructLikeWrapper

hasIds(MessageType) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil

hasNamespace() - Method in class org.apache.iceberg.catalog.TableIdentifier

Whether the namespace is empty.

hasNext() - Method in class org.apache.iceberg.orc.VectorizedRowBatchIterator

hasNext() - Method in class org.apache.iceberg.parquet.ColumnIterator

HasTableOperations - Interface in org.apache.iceberg

Used to expose a table's TableOperations.

hiddenImpl(Class<?>...) - Method in class org.apache.iceberg.common.DynConstructors.Builder

hiddenImpl(String, Class<?>...) - Method in class org.apache.iceberg.common.DynConstructors.Builder

hiddenImpl(Class<T>, Class<?>...) - Method in class org.apache.iceberg.common.DynConstructors.Builder

hiddenImpl(String, String) - Method in class org.apache.iceberg.common.DynFields.Builder

Checks for a hidden implementation, first finding the class by name.

hiddenImpl(Class<?>, String) - Method in class org.apache.iceberg.common.DynFields.Builder

Checks for a hidden implementation.

hiddenImpl(String, String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for an implementation, first finding the given class by name.

hiddenImpl(String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for an implementation, first finding the given class by name.

hiddenImpl(Class<?>, String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for a method implementation.

hiddenImpl(Class<?>, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for a method implementation.

Hive - Class in org.apache.iceberg.spark.hacks

HiveCatalog - Class in org.apache.iceberg.hive

HiveCatalog(Configuration) - Constructor for class org.apache.iceberg.hive.HiveCatalog

HiveCatalogs - Class in org.apache.iceberg.hive

HiveTableOperations - Class in org.apache.iceberg.hive

TODO we should be able to extract some more commonalities to BaseMetastoreTableOperations to avoid code duplication between this class and Metacat Tables.

HiveTableOperations(Configuration, HiveClientPool, String, String) - Constructor for class org.apache.iceberg.hive.HiveTableOperations

HiveTables - Class in org.apache.iceberg.hive

HiveTables(Configuration) - Constructor for class org.apache.iceberg.hive.HiveTables

HiveTypeConverter - Class in org.apache.iceberg.hive

hour(String) - Method in class org.apache.iceberg.PartitionSpec.Builder

hour(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

hour(Type) - Static method in class org.apache.iceberg.transforms.Transforms

Returns a hour Transform for timestamps.

I

ICEBERG_FIELD_NAME_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil

ICEBERG_TABLE_TYPE_VALUE - Static variable in class org.apache.iceberg.BaseMetastoreTableOperations

IcebergDecoder<D> - Class in org.apache.iceberg.data.avro

IcebergDecoder(Schema) - Constructor for class org.apache.iceberg.data.avro.IcebergDecoder

Creates a new decoder that constructs datum instances described by an Iceberg schema.

IcebergDecoder(Schema, SchemaStore) - Constructor for class org.apache.iceberg.data.avro.IcebergDecoder

Creates a new decoder that constructs datum instances described by an Iceberg schema.

IcebergEncoder<D> - Class in org.apache.iceberg.data.avro

IcebergEncoder(Schema) - Constructor for class org.apache.iceberg.data.avro.IcebergEncoder

Creates a new MessageEncoder that will deconstruct datum instances described by the schema.

IcebergEncoder(Schema, boolean) - Constructor for class org.apache.iceberg.data.avro.IcebergEncoder

Creates a new MessageEncoder that will deconstruct datum instances described by the schema.

IcebergGenerics - Class in org.apache.iceberg.data

IcebergGenerics.ScanBuilder - Class in org.apache.iceberg.data

IcebergPigInputFormat<T> - Class in org.apache.iceberg.pig

IcebergPigInputFormat.IcebergRecordReader<T> - Class in org.apache.iceberg.pig

IcebergRecordReader() - Constructor for class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

IcebergSource - Class in org.apache.iceberg.spark.source

IcebergSource() - Constructor for class org.apache.iceberg.spark.source.IcebergSource

IcebergStorage - Class in org.apache.iceberg.pig

IcebergStorage() - Constructor for class org.apache.iceberg.pig.IcebergStorage

identity(String) - Method in class org.apache.iceberg.PartitionSpec.Builder

identity(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

identity(Type) - Static method in class org.apache.iceberg.transforms.Transforms

Returns an identity Transform that can be used for any type.

identitySourceIds() - Method in class org.apache.iceberg.PartitionSpec

Returns the source field ids for identity partitions.

idToAlias(Integer) - Method in class org.apache.iceberg.Schema

Returns the column id for the given column alias.

impl(String) - Method in class org.apache.iceberg.common.DynClasses.Builder

Checks for an implementation of the class by name.

impl(String, Class<?>...) - Method in class org.apache.iceberg.common.DynConstructors.Builder

impl(Class<T>, Class<?>...) - Method in class org.apache.iceberg.common.DynConstructors.Builder

impl(String, String) - Method in class org.apache.iceberg.common.DynFields.Builder

Checks for an implementation, first finding the class by name.

impl(Class<?>, String) - Method in class org.apache.iceberg.common.DynFields.Builder

Checks for an implementation.

impl(String, String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for an implementation, first finding the given class by name.

impl(String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for an implementation, first finding the given class by name.

impl(Class<?>, String, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for a method implementation.

impl(Class<?>, Class<?>...) - Method in class org.apache.iceberg.common.DynMethods.Builder

Checks for a method implementation.

in(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

includeColumnStats() - Method in interface org.apache.iceberg.TableScan

Create a new TableScan from this that loads the column stats with each data file.

inclusive(PartitionSpec) - Static method in class org.apache.iceberg.expressions.Projections

Creates an inclusive ProjectionEvaluator for the spec, defaulting to case sensitive mode.

inclusive(PartitionSpec, boolean) - Static method in class org.apache.iceberg.expressions.Projections

Creates an inclusive ProjectionEvaluator for the spec.

InclusiveManifestEvaluator - Class in org.apache.iceberg.expressions

Evaluates an Expression on a ManifestFile to test whether the file contains matching partitions.

InclusiveManifestEvaluator(PartitionSpec, Expression) - Constructor for class org.apache.iceberg.expressions.InclusiveManifestEvaluator

InclusiveManifestEvaluator(PartitionSpec, Expression, boolean) - Constructor for class org.apache.iceberg.expressions.InclusiveManifestEvaluator

InclusiveMetricsEvaluator - Class in org.apache.iceberg.expressions

Evaluates an Expression on a DataFile to test whether rows in the file may match.

InclusiveMetricsEvaluator(Schema, Expression, boolean) - Constructor for class org.apache.iceberg.expressions.InclusiveMetricsEvaluator

incrementDuplicateDeletes() - Method in class org.apache.iceberg.SnapshotSummary.Builder

indexById(Types.StructType) - Static method in class org.apache.iceberg.types.TypeUtil

indexByLowerCaseName(Types.StructType) - Static method in class org.apache.iceberg.types.TypeUtil

IndexByName - Class in org.apache.iceberg.types

IndexByName() - Constructor for class org.apache.iceberg.types.IndexByName

indexByName(Types.StructType) - Static method in class org.apache.iceberg.types.TypeUtil

initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

InputFile - Interface in org.apache.iceberg.io

An interface used to read input files using SeekableInputStream instances.

IntAsLongReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.IntAsLongReader

IntegerAsDecimalReader(ColumnDescriptor, int) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.IntegerAsDecimalReader

IntegerType() - Constructor for class org.apache.iceberg.types.Types.IntegerType

ints() - Static method in class org.apache.iceberg.avro.ValueReaders

ints() - Static method in class org.apache.iceberg.avro.ValueWriters

invoke(Object, Object...) - Method in class org.apache.iceberg.common.DynConstructors.Ctor

invoke(Object...) - Method in class org.apache.iceberg.common.DynMethods.BoundMethod

invoke(Object...) - Method in class org.apache.iceberg.common.DynMethods.StaticMethod

invoke(Object, Object...) - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod

invokeChecked(Object, Object...) - Method in class org.apache.iceberg.common.DynConstructors.Ctor

invokeChecked(Object...) - Method in class org.apache.iceberg.common.DynMethods.BoundMethod

invokeChecked(Object...) - Method in class org.apache.iceberg.common.DynMethods.StaticMethod

invokeChecked(Object, Object...) - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod

io() - Method in class org.apache.iceberg.BaseMetastoreTableOperations

io() - Method in class org.apache.iceberg.BaseTable

io() - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

io() - Method in interface org.apache.iceberg.Table

io() - Method in interface org.apache.iceberg.TableOperations

isAlwaysNull() - Method in class org.apache.iceberg.common.DynFields.UnboundField

isCaseSensitive() - Method in interface org.apache.iceberg.TableScan

Returns whether this scan should apply column name case sensitiveness as per TableScan.caseSensitive(boolean).

isElementOptional() - Method in class org.apache.iceberg.types.Types.ListType

isElementRequired() - Method in class org.apache.iceberg.types.Types.ListType

isEmpty() - Method in class org.apache.iceberg.catalog.Namespace

isEmpty() - Method in class org.apache.iceberg.orc.ColumnIdMap

isFileScanTask() - Method in interface org.apache.iceberg.FileScanTask

isFileScanTask() - Method in interface org.apache.iceberg.ScanTask

isListType() - Method in interface org.apache.iceberg.types.Type

isListType() - Method in class org.apache.iceberg.types.Types.ListType

isMapType() - Method in interface org.apache.iceberg.types.Type

isMapType() - Method in class org.apache.iceberg.types.Types.MapType

isNestedType() - Method in interface org.apache.iceberg.types.Type

isNestedType() - Method in class org.apache.iceberg.types.Type.NestedType

isNoop() - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod

isNull(String) - Static method in class org.apache.iceberg.expressions.Expressions

isNull(BoundReference<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

isOptional() - Method in class org.apache.iceberg.types.Types.NestedField

isPrimitiveType() - Method in interface org.apache.iceberg.types.Type

isPrimitiveType() - Method in class org.apache.iceberg.types.Type.PrimitiveType

isPromotionAllowed(Type, Type.PrimitiveType) - Static method in class org.apache.iceberg.types.TypeUtil

isRequired() - Method in class org.apache.iceberg.types.Types.NestedField

isSplittable() - Method in enum org.apache.iceberg.FileFormat

isStatic() - Method in class org.apache.iceberg.common.DynConstructors.Ctor

isStatic() - Method in class org.apache.iceberg.common.DynFields.UnboundField

isStatic() - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod

isStructType() - Method in interface org.apache.iceberg.types.Type

isStructType() - Method in class org.apache.iceberg.types.Types.StructType

isTimestamptz(Schema) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

isValueOptional() - Method in class org.apache.iceberg.types.Types.MapType

isValueRequired() - Method in class org.apache.iceberg.types.Types.MapType

iterator() - Method in class org.apache.iceberg.avro.AvroIterable

iterator() - Method in class org.apache.iceberg.FilteredManifest

iterator() - Method in class org.apache.iceberg.io.CloseableIterable.ConcatCloseableIterable

iterator() - Method in class org.apache.iceberg.ManifestReader

iterator() - Method in class org.apache.iceberg.parquet.ParquetIterable

iterator() - Method in class org.apache.iceberg.parquet.ParquetReader

iterator() - Method in class org.apache.iceberg.util.BinPacking.PackingIterable

iterator() - Method in class org.apache.iceberg.util.ParallelIterable

J

javaClass() - Method in enum org.apache.iceberg.types.Type.TypeID

javaClasses() - Method in class org.apache.iceberg.PartitionSpec

join(Schema, Schema) - Static method in class org.apache.iceberg.types.TypeUtil

JsonUtil - Class in org.apache.iceberg.util

K

KEY_ID_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil

keyId() - Method in class org.apache.iceberg.types.Types.MapType

keyMetadata() - Method in interface org.apache.iceberg.DataFile

keyMetadata() - Method in interface org.apache.iceberg.encryption.EncryptedInputFile

Metadata pointing to some encryption key that would be used to decrypt the input file provided by EncryptedInputFile.encryptedInputFile().

keyMetadata() - Method in interface org.apache.iceberg.encryption.EncryptedOutputFile

Metadata about the encryption key that is being used to encrypt the associated EncryptedOutputFile.encryptingOutputFile().

keySet() - Method in class org.apache.iceberg.orc.ColumnIdMap

keyType() - Method in class org.apache.iceberg.types.Types.MapType

L

lastColumnId() - Method in class org.apache.iceberg.TableMetadata

lastUpdatedMillis() - Method in class org.apache.iceberg.TableMetadata

lazyLength() - Method in class org.apache.iceberg.GenericManifestFile

left() - Method in class org.apache.iceberg.expressions.And

left() - Method in class org.apache.iceberg.expressions.Or

length() - Method in interface org.apache.iceberg.FileScanTask

The number of bytes to scan from the FileScanTask.start() position in the file.

length() - Method in class org.apache.iceberg.GenericManifestFile

length() - Method in interface org.apache.iceberg.io.FileAppender

length() - Method in interface org.apache.iceberg.ManifestFile

length() - Method in class org.apache.iceberg.ManifestWriter

length() - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter

length() - Method in class org.apache.iceberg.types.Types.FixedType

lessThan(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

lessThanOrEqual(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

level(int) - Method in class org.apache.iceberg.catalog.Namespace

levels() - Method in class org.apache.iceberg.catalog.Namespace

limit(int) - Method in class org.apache.iceberg.ScanSummary.Builder

list(GroupType, T) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor

list(Types.ListType, Type.Repetition, int, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType

list(Types.ListType, GroupType, T) - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

list(Types.ListType, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering

list(Types.ListType, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering

list(Types.ListType, Supplier<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility

list(Types.ListType, Map<String, Integer>) - Method in class org.apache.iceberg.types.IndexByName

list(Types.ListType, Supplier<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

list(Types.ListType, T) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

Listener<E> - Interface in org.apache.iceberg.events

A listener interface that can receive notifications.

Listeners - Class in org.apache.iceberg.events

Static registration and notification for listeners.

ListPacker(long, int, boolean) - Constructor for class org.apache.iceberg.util.BinPacking.ListPacker

ListReader(int, int, ParquetValueReader<E>) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.ListReader

Literal<T> - Interface in org.apache.iceberg.expressions

Represents a literal fixed value in an expression predicate

literal() - Method in class org.apache.iceberg.expressions.Predicate

load(String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

load(String) - Method in class org.apache.iceberg.hadoop.HadoopTables

Loads the table location from a FileSystem path location.

load(String) - Method in class org.apache.iceberg.hive.HiveTables

load(String) - Method in interface org.apache.iceberg.Tables

loadCatalog(Configuration) - Static method in class org.apache.iceberg.hive.HiveCatalogs

loader(ClassLoader) - Method in class org.apache.iceberg.common.DynClasses.Builder

Set the ClassLoader used to lookup classes by name.

loader(ClassLoader) - Method in class org.apache.iceberg.common.DynConstructors.Builder

Set the ClassLoader used to lookup classes by name.

loader(ClassLoader) - Method in class org.apache.iceberg.common.DynFields.Builder

Set the ClassLoader used to lookup classes by name.

loader(ClassLoader) - Method in class org.apache.iceberg.common.DynMethods.Builder

Set the ClassLoader used to lookup classes by name.

loadTable(TableIdentifier) - Method in class org.apache.iceberg.BaseMetastoreCatalog

loadTable(TableIdentifier) - Method in interface org.apache.iceberg.catalog.Catalog

Load a table.

loadTable(TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog

localInput(File) - Static method in class org.apache.iceberg.Files

localInput(String) - Static method in class org.apache.iceberg.Files

localOutput(File) - Static method in class org.apache.iceberg.Files

localOutput(String) - Static method in class org.apache.iceberg.Files

location() - Method in class org.apache.iceberg.BaseTable

location(String) - Method in class org.apache.iceberg.FileHistory.Builder

location() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

location() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

location() - Method in interface org.apache.iceberg.io.InputFile

The fully-qualified location of the input file as a String.

location() - Method in interface org.apache.iceberg.io.OutputFile

Return the location this output file will create.

location() - Method in interface org.apache.iceberg.Table

Return the table's base location.

location() - Method in class org.apache.iceberg.TableMetadata

locationProvider() - Method in class org.apache.iceberg.BaseMetastoreTableOperations

locationProvider() - Method in class org.apache.iceberg.BaseTable

locationProvider() - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

LocationProvider - Interface in org.apache.iceberg.io

Interface for providing data file locations to write tasks.

locationProvider() - Method in interface org.apache.iceberg.Table

locationProvider() - Method in interface org.apache.iceberg.TableOperations

Returns a LocationProvider that supplies locations for new new data files.

LocationProviders - Class in org.apache.iceberg

locationsFor(String, Map<String, String>) - Static method in class org.apache.iceberg.LocationProviders

LogicalMap - Class in org.apache.iceberg.avro

LongAsDecimalReader(ColumnDescriptor, int) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.LongAsDecimalReader

longs() - Static method in class org.apache.iceberg.avro.ValueReaders

longs() - Static method in class org.apache.iceberg.avro.ValueWriters

LongType() - Constructor for class org.apache.iceberg.types.Types.LongType

lowerBound() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

lowerBound() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary

lowerBounds() - Method in interface org.apache.iceberg.DataFile

lowerBounds() - Method in class org.apache.iceberg.Metrics

lt(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

ltEq(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

M

MANIFEST_LISTS_ENABLED - Static variable in class org.apache.iceberg.TableProperties

MANIFEST_LISTS_ENABLED_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

MANIFEST_MIN_MERGE_COUNT - Static variable in class org.apache.iceberg.TableProperties

MANIFEST_MIN_MERGE_COUNT_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

MANIFEST_TARGET_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties

MANIFEST_TARGET_SIZE_BYTES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

ManifestFile - Interface in org.apache.iceberg

Represents a manifest file that can be scanned to find data files in a table.

ManifestFile.PartitionFieldSummary - Interface in org.apache.iceberg

Summarizes the values of one partition field stored in a manifest file.

manifestListLocation() - Method in interface org.apache.iceberg.Snapshot

Return the location of this snapshot's manifest list, or null if it is not separate.

ManifestReader - Class in org.apache.iceberg

Reader for manifest files.

manifests() - Method in interface org.apache.iceberg.Snapshot

Return the location of all manifests in this snapshot.

ManifestWriter - Class in org.apache.iceberg

Writer for manifest files.

map(Schema, T) - Method in class org.apache.iceberg.avro.AvroSchemaVisitor

map(ValueReader<K>, ValueReader<V>) - Static method in class org.apache.iceberg.avro.ValueReaders

map(ValueWriter<K>, ValueWriter<V>) - Static method in class org.apache.iceberg.avro.ValueWriters

map(GroupType, T, T) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor

map(Types.MapType, Type.Repetition, int, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType

map(Types.MapType, GroupType, T, T) - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

map(Types.MapType, Supplier<Type>, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering

map(Types.MapType, Supplier<Type>, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering

map(Types.MapType, Supplier<List<String>>, Supplier<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility

map(Types.MapType, Map<String, Integer>, Map<String, Integer>) - Method in class org.apache.iceberg.types.IndexByName

map(Types.MapType, Supplier<T>, Supplier<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

map(Types.MapType, T, T) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

mapper() - Static method in class org.apache.iceberg.util.JsonUtil

MapReader(int, int, ParquetValueReader<K>, ParquetValueReader<V>) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.MapReader

maps(int, int, ParquetValueWriter<K>, ParquetValueWriter<V>) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters

message(MessageType, List<T>) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor

message(Types.StructType, MessageType, List<T>) - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

meta(String, String) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

meta(Map<String, String>) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

meta(String, String) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

metadata(String, String) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder

METADATA_LOCATION_PROP - Static variable in class org.apache.iceberg.BaseMetastoreTableOperations

metadataFileLocation(String) - Method in class org.apache.iceberg.BaseMetastoreTableOperations

metadataFileLocation(String) - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

metadataFileLocation(String) - Method in interface org.apache.iceberg.TableOperations

Given the name of a metadata file, obtain the full path of that file using an appropriate base location of the implementation's choosing.

metrics() - Method in interface org.apache.iceberg.io.FileAppender

metrics() - Method in class org.apache.iceberg.ManifestWriter

Metrics - Class in org.apache.iceberg

Metrics() - Constructor for class org.apache.iceberg.Metrics

Metrics(Long, Map<Integer, Long>, Map<Integer, Long>, Map<Integer, Long>) - Constructor for class org.apache.iceberg.Metrics

Metrics(Long, Map<Integer, Long>, Map<Integer, Long>, Map<Integer, Long>, Map<Integer, ByteBuffer>, Map<Integer, ByteBuffer>) - Constructor for class org.apache.iceberg.Metrics

metrics() - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter

month(String) - Method in class org.apache.iceberg.PartitionSpec.Builder

month(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

month(Type) - Static method in class org.apache.iceberg.transforms.Transforms

Returns a month Transform for date or timestamp types.

N

name() - Method in class org.apache.iceberg.catalog.TableIdentifier

name() - Method in class org.apache.iceberg.expressions.NamedReference

name() - Method in class org.apache.iceberg.PartitionField

name() - Method in class org.apache.iceberg.types.Types.NestedField

named(String) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

named(String) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

NamedReference - Class in org.apache.iceberg.expressions

Namespace - Class in org.apache.iceberg.catalog

A namespace in a Catalog.

namespace() - Method in class org.apache.iceberg.catalog.TableIdentifier

negate() - Method in class org.apache.iceberg.expressions.And

negate() - Method in class org.apache.iceberg.expressions.BoundPredicate

negate() - Method in interface org.apache.iceberg.expressions.Expression

negate() - Method in enum org.apache.iceberg.expressions.Expression.Operation

negate() - Method in class org.apache.iceberg.expressions.False

negate() - Method in class org.apache.iceberg.expressions.Not

negate() - Method in class org.apache.iceberg.expressions.Or

negate() - Method in class org.apache.iceberg.expressions.True

negate() - Method in class org.apache.iceberg.expressions.UnboundPredicate

NestedType() - Constructor for class org.apache.iceberg.types.Type.NestedType

newAppend() - Method in class org.apache.iceberg.BaseTable

newAppend() - Method in interface org.apache.iceberg.Table

Create a new append API to add files to this table and commit.

newAppend() - Method in interface org.apache.iceberg.Transaction

Create a new append API to add files to this table.

newDataLocation(String) - Method in interface org.apache.iceberg.io.LocationProvider

Return a fully-qualified data file location for the given filename.

newDataLocation(PartitionSpec, StructLike, String) - Method in interface org.apache.iceberg.io.LocationProvider

Return a fully-qualified data file location for the given partition and filename.

newDelete() - Method in class org.apache.iceberg.BaseTable

newDelete() - Method in interface org.apache.iceberg.Table

Create a new delete API to replace files in this table and commit.

newDelete() - Method in interface org.apache.iceberg.Transaction

Create a new delete API to replace files in this table.

newFastAppend() - Method in class org.apache.iceberg.BaseTable

newFastAppend() - Method in interface org.apache.iceberg.Table

Create a new append API to add files to this table and commit.

newFastAppend() - Method in interface org.apache.iceberg.Transaction

Create a new append API to add files to this table.

newInputFile(String) - Method in class org.apache.iceberg.hadoop.HadoopFileIO

newInputFile(String) - Method in interface org.apache.iceberg.io.FileIO

Get a InputFile instance to read bytes from the file at the given path.

newInstance(Object...) - Method in class org.apache.iceberg.common.DynConstructors.Ctor

newInstanceChecked(Object...) - Method in class org.apache.iceberg.common.DynConstructors.Ctor

newListData(List<E>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ListReader

newListData(T) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

newMapData(Map<K, V>) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.MapReader

newMapData(M) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

newOutputFile(String) - Method in class org.apache.iceberg.hadoop.HadoopFileIO

newOutputFile(String) - Method in interface org.apache.iceberg.io.FileIO

Get a OutputFile instance to write bytes to the file at the given path.

newOverwrite() - Method in class org.apache.iceberg.BaseTable

newOverwrite() - Method in interface org.apache.iceberg.Table

Create a new overwrite API to overwrite files by a filter expression.

newOverwrite() - Method in interface org.apache.iceberg.Transaction

Create a new overwrite API to overwrite files by a filter expression.

newReplacePartitions() - Method in class org.apache.iceberg.BaseTable

newReplacePartitions() - Method in interface org.apache.iceberg.Table

Not recommended: Create a new replace partitions API to dynamically overwrite partitions in the table with new data.

newReplacePartitions() - Method in interface org.apache.iceberg.Transaction

Not recommended: Create a new replace partitions API to dynamically overwrite partitions in the table with new data.

newRewrite() - Method in class org.apache.iceberg.BaseTable

newRewrite() - Method in interface org.apache.iceberg.Table

Create a new rewrite API to replace files in this table and commit.

newRewrite() - Method in interface org.apache.iceberg.Transaction

Create a new rewrite API to replace files in this table.

newScan() - Method in class org.apache.iceberg.BaseTable

newScan() - Method in interface org.apache.iceberg.Table

Create a new scan for this table.

newSnapshotId() - Method in interface org.apache.iceberg.TableOperations

Create a new ID for a Snapshot

newStream() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

newStream() - Method in interface org.apache.iceberg.io.InputFile

Opens a new SeekableInputStream for the underlying data file

newStructData(T) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

newTableMetadata(TableOperations, Schema, PartitionSpec, String) - Static method in class org.apache.iceberg.TableMetadata

newTableMetadata(TableOperations, Schema, PartitionSpec, String, Map<String, String>) - Static method in class org.apache.iceberg.TableMetadata

newTableOps(Configuration, TableIdentifier) - Method in class org.apache.iceberg.BaseMetastoreCatalog

newTableOps(Configuration, String, String) - Method in class org.apache.iceberg.BaseMetastoreTables

newTableOps(Configuration, TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog

newTableOps(Configuration, String, String) - Method in class org.apache.iceberg.hive.HiveTables

newTransaction() - Method in class org.apache.iceberg.BaseTable

newTransaction() - Method in interface org.apache.iceberg.Table

Create a new transaction API to commit multiple table operations at once.

newTransaction(TableOperations) - Static method in class org.apache.iceberg.Transactions

next() - Method in class org.apache.iceberg.orc.VectorizedRowBatchIterator

nextBinary() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextBoolean() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextDouble() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextFloat() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextInteger() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextKeyValue() - Method in class org.apache.iceberg.pig.IcebergPigInputFormat.IcebergRecordReader

nextLong() - Method in class org.apache.iceberg.parquet.ColumnIterator

nextNull() - Method in class org.apache.iceberg.parquet.ColumnIterator

noRetry() - Method in class org.apache.iceberg.util.Tasks.Builder

NoSuchTableException - Exception in org.apache.iceberg.exceptions

Exception raised when attempting to load a table that does not exist.

NoSuchTableException(String, Object...) - Constructor for exception org.apache.iceberg.exceptions.NoSuchTableException

NoSuchTableException(Throwable, String, Object...) - Constructor for exception org.apache.iceberg.exceptions.NoSuchTableException

not(Expression) - Static method in class org.apache.iceberg.expressions.Expressions

not(R) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

Not - Class in org.apache.iceberg.expressions

notEq(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

notEqual(String, T) - Static method in class org.apache.iceberg.expressions.Expressions

notify(E) - Method in interface org.apache.iceberg.events.Listener

notifyAll(E) - Static method in class org.apache.iceberg.events.Listeners

notIn(BoundReference<T>, Literal<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

notNull(String) - Static method in class org.apache.iceberg.expressions.Expressions

notNull(BoundReference<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

nulls() - Static method in class org.apache.iceberg.avro.ValueReaders

nulls() - Static method in class org.apache.iceberg.avro.ValueWriters

nulls() - Static method in class org.apache.iceberg.parquet.ParquetValueReaders

nullsFirst() - Static method in class org.apache.iceberg.types.Comparators

nullsLast() - Static method in class org.apache.iceberg.types.Comparators

nullValueCounts() - Method in interface org.apache.iceberg.DataFile

nullValueCounts() - Method in class org.apache.iceberg.Metrics

O

OBJECT_STORE_ENABLED - Static variable in class org.apache.iceberg.TableProperties

OBJECT_STORE_ENABLED_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

OBJECT_STORE_PATH - Static variable in class org.apache.iceberg.TableProperties

of(String...) - Static method in class org.apache.iceberg.catalog.Namespace

of(String...) - Static method in class org.apache.iceberg.catalog.TableIdentifier

of(Namespace, String) - Static method in class org.apache.iceberg.catalog.TableIdentifier

of(ByteBuffer) - Static method in class org.apache.iceberg.encryption.EncryptionKeyMetadatas

of(byte[]) - Static method in class org.apache.iceberg.encryption.EncryptionKeyMetadatas

of(boolean) - Static method in interface org.apache.iceberg.expressions.Literal

of(int) - Static method in interface org.apache.iceberg.expressions.Literal

of(long) - Static method in interface org.apache.iceberg.expressions.Literal

of(float) - Static method in interface org.apache.iceberg.expressions.Literal

of(double) - Static method in interface org.apache.iceberg.expressions.Literal

of(CharSequence) - Static method in interface org.apache.iceberg.expressions.Literal

of(UUID) - Static method in interface org.apache.iceberg.expressions.Literal

of(byte[]) - Static method in interface org.apache.iceberg.expressions.Literal

of(ByteBuffer) - Static method in interface org.apache.iceberg.expressions.Literal

of(BigDecimal) - Static method in interface org.apache.iceberg.expressions.Literal

of(TableScan) - Static method in class org.apache.iceberg.ScanSummary

Create a scan summary builder for a table scan.

of(int, int) - Static method in class org.apache.iceberg.types.Types.DecimalType

of(Types.NestedField...) - Static method in class org.apache.iceberg.types.Types.StructType

of(List<Types.NestedField>) - Static method in class org.apache.iceberg.types.Types.StructType

of(X, Y) - Static method in class org.apache.iceberg.util.Pair

ofLength(int) - Static method in class org.apache.iceberg.types.Types.FixedType

ofOptional(int, Type) - Static method in class org.apache.iceberg.types.Types.ListType

ofOptional(int, int, Type, Type) - Static method in class org.apache.iceberg.types.Types.MapType

ofRequired(int, Type) - Static method in class org.apache.iceberg.types.Types.ListType

ofRequired(int, int, Type, Type) - Static method in class org.apache.iceberg.types.Types.MapType

onFailure(Tasks.FailureTask<I, ?>) - Method in class org.apache.iceberg.util.Tasks.Builder

onlyRetryOn(Class<? extends Exception>) - Method in class org.apache.iceberg.util.Tasks.Builder

onlyRetryOn(Class<? extends Exception>...) - Method in class org.apache.iceberg.util.Tasks.Builder

op() - Method in class org.apache.iceberg.expressions.And

op() - Method in interface org.apache.iceberg.expressions.Expression

op() - Method in class org.apache.iceberg.expressions.False

op() - Method in class org.apache.iceberg.expressions.Not

op() - Method in class org.apache.iceberg.expressions.Or

op() - Method in class org.apache.iceberg.expressions.Predicate

op() - Method in class org.apache.iceberg.expressions.True

operation() - Method in class org.apache.iceberg.OverwriteData

operation() - Method in class org.apache.iceberg.ReplaceManifests

operation() - Method in class org.apache.iceberg.ReplacePartitionsOperation

operation() - Method in interface org.apache.iceberg.Snapshot

Return the name of the data operation that produced this snapshot.

operations() - Method in class org.apache.iceberg.BaseTable

operations() - Method in interface org.apache.iceberg.HasTableOperations

option(int, ValueWriter<T>) - Static method in class org.apache.iceberg.avro.ValueWriters

option(Type, int, ParquetValueReader<T>) - Static method in class org.apache.iceberg.parquet.ParquetValueReaders

option(Type, int, ParquetValueWriter<T>) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters

optional(int, String, Type) - Static method in class org.apache.iceberg.types.Types.NestedField

optional(int, String, Type, String) - Static method in class org.apache.iceberg.types.Types.NestedField

or(Expression, Expression) - Static method in class org.apache.iceberg.expressions.Expressions

or(R, R) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

Or - Class in org.apache.iceberg.expressions

ORC - Class in org.apache.iceberg.orc

ORC.ReadBuilder - Class in org.apache.iceberg.orc

ORC.WriteBuilder - Class in org.apache.iceberg.orc

OrcMetrics - Class in org.apache.iceberg.orc

OrcValueReader<T> - Interface in org.apache.iceberg.orc

Used for implementing ORC value readers.

OrcValueWriter<T> - Interface in org.apache.iceberg.orc

Write data value of a schema.

org.apache.iceberg - package org.apache.iceberg

org.apache.iceberg.avro - package org.apache.iceberg.avro

org.apache.iceberg.catalog - package org.apache.iceberg.catalog

org.apache.iceberg.common - package org.apache.iceberg.common

org.apache.iceberg.data - package org.apache.iceberg.data

org.apache.iceberg.data.avro - package org.apache.iceberg.data.avro

org.apache.iceberg.data.parquet - package org.apache.iceberg.data.parquet

org.apache.iceberg.encryption - package org.apache.iceberg.encryption

org.apache.iceberg.events - package org.apache.iceberg.events

org.apache.iceberg.exceptions - package org.apache.iceberg.exceptions

org.apache.iceberg.expressions - package org.apache.iceberg.expressions

org.apache.iceberg.hadoop - package org.apache.iceberg.hadoop

org.apache.iceberg.hive - package org.apache.iceberg.hive

org.apache.iceberg.io - package org.apache.iceberg.io

org.apache.iceberg.orc - package org.apache.iceberg.orc

org.apache.iceberg.parquet - package org.apache.iceberg.parquet

org.apache.iceberg.pig - package org.apache.iceberg.pig

org.apache.iceberg.spark - package org.apache.iceberg.spark

org.apache.iceberg.spark.data - package org.apache.iceberg.spark.data

org.apache.iceberg.spark.hacks - package org.apache.iceberg.spark.hacks

org.apache.iceberg.spark.source - package org.apache.iceberg.spark.source

org.apache.iceberg.transforms - package org.apache.iceberg.transforms

org.apache.iceberg.types - package org.apache.iceberg.types

org.apache.iceberg.util - package org.apache.iceberg.util

orNoop() - Method in class org.apache.iceberg.common.DynMethods.Builder

If no implementation has been found, adds a NOOP method.

orNull() - Method in class org.apache.iceberg.common.DynClasses.Builder

Instructs this builder to return null if no class is found, rather than throwing an Exception.

OutputFile - Interface in org.apache.iceberg.io

An interface used to create output files using PositionOutputStream instances.

OVERWRITE - Static variable in class org.apache.iceberg.DataOperations

New data is added to overwrite existing data.

overwriteByRowFilter(Expression) - Method in class org.apache.iceberg.OverwriteData

overwriteByRowFilter(Expression) - Method in interface org.apache.iceberg.OverwriteFiles

Delete files that match an Expression on data rows from the table.

OverwriteData - Class in org.apache.iceberg

OverwriteData(TableOperations) - Constructor for class org.apache.iceberg.OverwriteData

OverwriteFiles - Interface in org.apache.iceberg

API for overwriting files in a table by filter expression.

P

pack(Iterable<T>, Function<T, Long>) - Method in class org.apache.iceberg.util.BinPacking.ListPacker

packEnd(List<T>, Function<T, Long>) - Method in class org.apache.iceberg.util.BinPacking.ListPacker

PackingIterable(Iterable<T>, long, int, Function<T, Long>, boolean) - Constructor for class org.apache.iceberg.util.BinPacking.PackingIterable

Pair<X,Y> - Class in org.apache.iceberg.util

pairs(M) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter

ParallelIterable<T> - Class in org.apache.iceberg.util

ParallelIterable(Iterable<? extends Iterable<T>>, ExecutorService) - Constructor for class org.apache.iceberg.util.ParallelIterable

parentId() - Method in interface org.apache.iceberg.Snapshot

Return this snapshot's parent ID or null.

Parquet - Class in org.apache.iceberg.parquet

Parquet.ReadBuilder - Class in org.apache.iceberg.parquet

Parquet.WriteBuilder - Class in org.apache.iceberg.parquet

PARQUET_COMPRESSION - Static variable in class org.apache.iceberg.TableProperties

PARQUET_COMPRESSION_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

PARQUET_DICT_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties

PARQUET_DICT_SIZE_BYTES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

PARQUET_PAGE_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties

PARQUET_PAGE_SIZE_BYTES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

PARQUET_ROW_GROUP_SIZE_BYTES - Static variable in class org.apache.iceberg.TableProperties

PARQUET_ROW_GROUP_SIZE_BYTES_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

ParquetAvroReader - Class in org.apache.iceberg.parquet

ParquetAvroReader() - Constructor for class org.apache.iceberg.parquet.ParquetAvroReader

ParquetAvroValueReaders - Class in org.apache.iceberg.parquet

ParquetAvroValueReaders.TimeMillisReader - Class in org.apache.iceberg.parquet

ParquetAvroValueReaders.TimestampMillisReader - Class in org.apache.iceberg.parquet

ParquetAvroWriter - Class in org.apache.iceberg.parquet

ParquetDictionaryRowGroupFilter - Class in org.apache.iceberg.parquet

ParquetDictionaryRowGroupFilter(Schema, Expression) - Constructor for class org.apache.iceberg.parquet.ParquetDictionaryRowGroupFilter

ParquetDictionaryRowGroupFilter(Schema, Expression, boolean) - Constructor for class org.apache.iceberg.parquet.ParquetDictionaryRowGroupFilter

ParquetIterable<T> - Class in org.apache.iceberg.parquet

ParquetMetricsRowGroupFilter - Class in org.apache.iceberg.parquet

ParquetMetricsRowGroupFilter(Schema, Expression) - Constructor for class org.apache.iceberg.parquet.ParquetMetricsRowGroupFilter

ParquetMetricsRowGroupFilter(Schema, Expression, boolean) - Constructor for class org.apache.iceberg.parquet.ParquetMetricsRowGroupFilter

ParquetReader<T> - Class in org.apache.iceberg.parquet

ParquetReader(InputFile, Schema, ParquetReadOptions, Function<MessageType, ParquetValueReader<?>>, Expression, boolean, boolean) - Constructor for class org.apache.iceberg.parquet.ParquetReader

ParquetSchemaUtil - Class in org.apache.iceberg.parquet

ParquetSchemaUtil() - Constructor for class org.apache.iceberg.parquet.ParquetSchemaUtil

ParquetTypeVisitor<T> - Class in org.apache.iceberg.parquet

ParquetTypeVisitor() - Constructor for class org.apache.iceberg.parquet.ParquetTypeVisitor

ParquetUtil - Class in org.apache.iceberg.parquet

ParquetValueReader<T> - Interface in org.apache.iceberg.parquet

ParquetValueReaders - Class in org.apache.iceberg.parquet

ParquetValueReaders.BinaryAsDecimalReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.BytesReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.FloatAsDoubleReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.IntAsLongReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.IntegerAsDecimalReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.ListReader<E> - Class in org.apache.iceberg.parquet

ParquetValueReaders.LongAsDecimalReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.MapReader<K,V> - Class in org.apache.iceberg.parquet

ParquetValueReaders.PrimitiveReader<T> - Class in org.apache.iceberg.parquet

ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V> - Class in org.apache.iceberg.parquet

ParquetValueReaders.RepeatedReader<T,I,E> - Class in org.apache.iceberg.parquet

ParquetValueReaders.ReusableEntry<K,V> - Class in org.apache.iceberg.parquet

ParquetValueReaders.StringReader - Class in org.apache.iceberg.parquet

ParquetValueReaders.StructReader<T,I> - Class in org.apache.iceberg.parquet

ParquetValueReaders.UnboxedReader<T> - Class in org.apache.iceberg.parquet

ParquetValueWriter<T> - Interface in org.apache.iceberg.parquet

ParquetValueWriters - Class in org.apache.iceberg.parquet

ParquetValueWriters.PrimitiveWriter<T> - Class in org.apache.iceberg.parquet

ParquetValueWriters.RepeatedKeyValueWriter<M,K,V> - Class in org.apache.iceberg.parquet

ParquetValueWriters.RepeatedWriter<L,E> - Class in org.apache.iceberg.parquet

ParquetValueWriters.StructWriter<S> - Class in org.apache.iceberg.parquet

ParquetWriteAdapter<D> - Class in org.apache.iceberg.parquet

ParquetWriteAdapter(ParquetWriter<D>) - Constructor for class org.apache.iceberg.parquet.ParquetWriteAdapter

parse(String) - Static method in class org.apache.iceberg.catalog.TableIdentifier

partition() - Method in interface org.apache.iceberg.DataFile

PartitionField - Class in org.apache.iceberg

Represents a single field in a PartitionSpec.

PartitionMetrics() - Constructor for class org.apache.iceberg.ScanSummary.PartitionMetrics

partitions() - Method in class org.apache.iceberg.GenericManifestFile

partitions() - Method in interface org.apache.iceberg.ManifestFile

Returns a list of partition field summaries.

partitions(SparkSession, String) - Static method in class org.apache.iceberg.spark.hacks.Hive

PartitionSpec - Class in org.apache.iceberg

Represents how to produce partition data for a table.

PartitionSpec.Builder - Class in org.apache.iceberg

Used to create valid partition specs.

partitionSpecId() - Method in class org.apache.iceberg.GenericManifestFile

partitionSpecId() - Method in interface org.apache.iceberg.ManifestFile

PartitionSpecParser - Class in org.apache.iceberg

PartitionSpecVisitor<T> - Interface in org.apache.iceberg.transforms

partitionToPath(StructLike) - Method in class org.apache.iceberg.PartitionSpec

partitionType() - Method in class org.apache.iceberg.PartitionSpec

path() - Method in interface org.apache.iceberg.DataFile

path() - Method in class org.apache.iceberg.GenericManifestFile

path() - Method in interface org.apache.iceberg.ManifestFile

PendingUpdate<T> - Interface in org.apache.iceberg

API for table metadata changes.

PIG_ICEBERG_TABLES_IMPL - Static variable in class org.apache.iceberg.pig.IcebergStorage

PigParquetReader - Class in org.apache.iceberg.pig

PigParquetReader(Schema, MessageType, Map<Integer, Object>) - Constructor for class org.apache.iceberg.pig.PigParquetReader

PlaintextEncryptionManager - Class in org.apache.iceberg.encryption

PlaintextEncryptionManager() - Constructor for class org.apache.iceberg.encryption.PlaintextEncryptionManager

planFiles() - Method in interface org.apache.iceberg.TableScan

Plan the files that will be read by this scan.

planTasks() - Method in interface org.apache.iceberg.TableScan

Plan the tasks for this scan.

PositionOutputStream - Class in org.apache.iceberg.io

PositionOutputStream() - Constructor for class org.apache.iceberg.io.PositionOutputStream

precision() - Method in class org.apache.iceberg.types.Types.DecimalType

predicate(Expression.Operation, String, T) - Static method in class org.apache.iceberg.expressions.Expressions

predicate(Expression.Operation, String, Literal<T>) - Static method in class org.apache.iceberg.expressions.Expressions

predicate(Expression.Operation, String) - Static method in class org.apache.iceberg.expressions.Expressions

predicate(BoundPredicate<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

predicate(UnboundPredicate<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.BoundExpressionVisitor

predicate(BoundPredicate<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

predicate(UnboundPredicate<T>) - Method in class org.apache.iceberg.expressions.ExpressionVisitors.ExpressionVisitor

Predicate<T,R extends Reference> - Class in org.apache.iceberg.expressions

prepareToRead(RecordReader, PigSplit) - Method in class org.apache.iceberg.pig.IcebergStorage

PREVIOUS_METADATA_LOCATION_PROP - Static variable in class org.apache.iceberg.BaseMetastoreTableOperations

primitive(Schema) - Method in class org.apache.iceberg.avro.AvroSchemaVisitor

primitive(PrimitiveType) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor

primitive(Type.PrimitiveType, Type.Repetition, int, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType

primitive(Type.PrimitiveType, PrimitiveType) - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

primitive(Type.PrimitiveType) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering

primitive(Type.PrimitiveType) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering

primitive(Type.PrimitiveType) - Method in class org.apache.iceberg.types.CheckCompatibility

primitive(Type.PrimitiveType) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

primitive(Type.PrimitiveType) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

PrimitiveReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader

PrimitiveType() - Constructor for class org.apache.iceberg.types.Type.PrimitiveType

PrimitiveWriter(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter

project(Schema) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

project(Expression) - Method in class org.apache.iceberg.expressions.Projections.ProjectionEvaluator

Project the given row expression to a partition expression.

project(Schema) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

project(Schema, List<String>) - Static method in class org.apache.iceberg.pig.SchemaUtil

project(Schema) - Method in interface org.apache.iceberg.TableScan

Create a new TableScan from this with the schema as its projection.

project(String, BoundPredicate<S>) - Method in interface org.apache.iceberg.transforms.Transform

Transforms a predicate to an inclusive predicate on the partition values produced by Transform.apply(Object).

projection() - Method in class org.apache.iceberg.events.ScanEvent

ProjectionDatumReader<D> - Class in org.apache.iceberg.avro

ProjectionDatumReader(Function<Schema, DatumReader<?>>, Schema, Map<String, String>) - Constructor for class org.apache.iceberg.avro.ProjectionDatumReader

ProjectionEvaluator() - Constructor for class org.apache.iceberg.expressions.Projections.ProjectionEvaluator

Projections - Class in org.apache.iceberg.expressions

Utils to project expressions on rows to expressions on partitions.

Projections.ProjectionEvaluator - Class in org.apache.iceberg.expressions

A class that projects expressions for a table's data rows into expressions on the table's partition values, for a table's partition spec.

projectStrict(String, BoundPredicate<S>) - Method in interface org.apache.iceberg.transforms.Transform

Transforms a predicate to a strict predicate on the partition values produced by Transform.apply(Object).

properties() - Method in class org.apache.iceberg.BaseTable

properties() - Method in interface org.apache.iceberg.Table

Return a map of string properties for this table.

properties() - Method in class org.apache.iceberg.TableMetadata

propertyAsBoolean(String, boolean) - Method in class org.apache.iceberg.TableMetadata

propertyAsBoolean(Map<String, String>, String, boolean) - Static method in class org.apache.iceberg.util.PropertyUtil

propertyAsInt(String, int) - Method in class org.apache.iceberg.TableMetadata

propertyAsInt(Map<String, String>, String, int) - Static method in class org.apache.iceberg.util.PropertyUtil

propertyAsLong(String, long) - Method in class org.apache.iceberg.TableMetadata

propertyAsLong(Map<String, String>, String, long) - Static method in class org.apache.iceberg.util.PropertyUtil

PropertyUtil - Class in org.apache.iceberg.util

prune(Schema, StructType) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Prune columns from a Schema using a Spark type projection.

prune(Schema, StructType, List<Expression>) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Prune columns from a Schema using a Spark type projection.

prune(Schema, StructType, Expression, boolean) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Prune columns from a Schema using a Spark type projection.

pruneColumns(Schema, Set<Integer>) - Static method in class org.apache.iceberg.avro.AvroSchemaUtil

pruneColumns(MessageType, Schema) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil

pruneColumnsFallback(MessageType, Schema) - Static method in class org.apache.iceberg.parquet.ParquetSchemaUtil

Prunes columns from a Parquet file schema that was written without field ids.

PruneColumnsWithoutReordering - Class in org.apache.iceberg.spark

PruneColumnsWithReordering - Class in org.apache.iceberg.spark

pushProjection(LoadPushDown.RequiredFieldList) - Method in class org.apache.iceberg.pig.IcebergStorage

put(int, Object) - Method in class org.apache.iceberg.GenericManifestFile

put(int, Object) - Method in class org.apache.iceberg.GenericPartitionFieldSummary

put(TypeDescription, Integer) - Method in class org.apache.iceberg.orc.ColumnIdMap

put(int, Object) - Method in class org.apache.iceberg.util.Pair

putAll(Map<? extends TypeDescription, ? extends Integer>) - Method in class org.apache.iceberg.orc.ColumnIdMap

R

range(int) - Static method in class org.apache.iceberg.util.Tasks

read(InputFile) - Static method in class org.apache.iceberg.avro.Avro

read(D, Decoder) - Method in class org.apache.iceberg.avro.ProjectionDatumReader

read(Decoder, Object) - Method in interface org.apache.iceberg.avro.ValueReader

read(Decoder, Object) - Method in class org.apache.iceberg.avro.ValueReaders.StructReader

read(T, Decoder) - Method in class org.apache.iceberg.data.avro.DataReader

read(Table) - Static method in class org.apache.iceberg.data.IcebergGenerics

Returns a builder to configure a read of the given table that produces generic records.

read(InputFile, Function<Integer, PartitionSpec>) - Static method in class org.apache.iceberg.ManifestReader

Returns a new ManifestReader for an InputFile.

read(InputFile) - Static method in class org.apache.iceberg.orc.ORC

read(VectorizedRowBatch, int) - Method in interface org.apache.iceberg.orc.OrcValueReader

Reads a value in row.

read(InputFile) - Static method in class org.apache.iceberg.parquet.Parquet

read(T) - Method in interface org.apache.iceberg.parquet.ParquetValueReader

read(BigDecimal) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.BinaryAsDecimalReader

read(ByteBuffer) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.BytesReader

read(Double) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.FloatAsDoubleReader

read(Long) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.IntAsLongReader

read(BigDecimal) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.IntegerAsDecimalReader

read(BigDecimal) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.LongAsDecimalReader

read(M) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

read(T) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

read(String) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StringReader

read(T) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

read(T) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

read(InternalRow, Decoder) - Method in class org.apache.iceberg.spark.data.SparkAvroReader

read(VectorizedRowBatch, int) - Method in class org.apache.iceberg.spark.data.SparkOrcReader

read(TableOperations, InputFile) - Static method in class org.apache.iceberg.TableMetadataParser

readBinary() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

readBoolean() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

readCompatibilityErrors(Schema, Schema) - Static method in class org.apache.iceberg.types.CheckCompatibility

Returns a list of compatibility errors for reading with the given read schema.

readDouble() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.FloatAsDoubleReader

readDouble() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

reader(int) - Method in class org.apache.iceberg.avro.ValueReaders.StructReader

readFloat() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

readInteger() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

readLong() - Method in class org.apache.iceberg.parquet.ParquetAvroValueReaders.TimeMillisReader

readLong() - Method in class org.apache.iceberg.parquet.ParquetAvroValueReaders.TimestampMillisReader

readLong() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.IntAsLongReader

readLong() - Method in class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

readSupport(ReadSupport<?>) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

reassignIds(Schema, Schema) - Static method in class org.apache.iceberg.types.TypeUtil

Reassigns ids in a schema from another schema.

record(Schema, List<String>, List<T>) - Method in class org.apache.iceberg.avro.AvroSchemaVisitor

record(List<ValueReader<?>>, Schema) - Static method in class org.apache.iceberg.avro.ValueReaders

record(List<ValueReader<?>>, Class<R>, Schema) - Static method in class org.apache.iceberg.avro.ValueReaders

record(List<ValueWriter<?>>) - Static method in class org.apache.iceberg.avro.ValueWriters

Record - Interface in org.apache.iceberg.data

recordCount() - Method in interface org.apache.iceberg.DataFile

recordCount() - Method in class org.apache.iceberg.Metrics

recordCount() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics

ref() - Method in class org.apache.iceberg.expressions.Predicate

Reference - Interface in org.apache.iceberg.expressions

Represents a variable reference in an expression.

refresh() - Method in class org.apache.iceberg.BaseTable

refresh() - Method in class org.apache.iceberg.hadoop.HadoopTableOperations

refresh() - Method in class org.apache.iceberg.hive.HiveTableOperations

refresh() - Method in interface org.apache.iceberg.Table

Refresh the current table metadata.

refresh() - Method in interface org.apache.iceberg.TableOperations

Return the current table metadata after checking for updates.

refreshFromMetadataLocation(String) - Method in class org.apache.iceberg.BaseMetastoreTableOperations

refreshFromMetadataLocation(String, int) - Method in class org.apache.iceberg.BaseMetastoreTableOperations

register(Listener<E>, Class<E>) - Static method in class org.apache.iceberg.events.Listeners

relativeToAbsolutePath(String, Path) - Method in class org.apache.iceberg.pig.IcebergStorage

remove(Object) - Method in class org.apache.iceberg.orc.ColumnIdMap

remove(String) - Method in interface org.apache.iceberg.UpdateProperties

Remove the given property key from the table.

removeSnapshotLogEntries(Set<Long>) - Method in class org.apache.iceberg.TableMetadata

removeSnapshotsIf(Predicate<Snapshot>) - Method in class org.apache.iceberg.TableMetadata

rename(String, String) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

renameColumn(String, String) - Method in interface org.apache.iceberg.UpdateSchema

Rename a column in the schema.

renameTable(TableIdentifier, TableIdentifier) - Method in interface org.apache.iceberg.catalog.Catalog

Rename a table.

renameTable(TableIdentifier, TableIdentifier) - Method in class org.apache.iceberg.hive.HiveCatalog

RepeatedKeyValueReader(int, int, ParquetValueReader<K>, ParquetValueReader<V>) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

RepeatedKeyValueWriter(int, int, ParquetValueWriter<K>, ParquetValueWriter<V>) - Constructor for class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter

RepeatedReader(int, int, ParquetValueReader<E>) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

RepeatedWriter(int, int, ParquetValueWriter<E>) - Constructor for class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter

REPLACE - Static variable in class org.apache.iceberg.DataOperations

Files are removed and replaced, without changing the data in the table.

replaceCurrentSnapshot(Snapshot) - Method in class org.apache.iceberg.TableMetadata

ReplaceManifests - Class in org.apache.iceberg

ReplacePartitions - Interface in org.apache.iceberg

Not recommended: API for overwriting files in a table by partition.

ReplacePartitionsOperation - Class in org.apache.iceberg

replaceProperties(Map<String, String>) - Method in class org.apache.iceberg.TableMetadata

replaceTableTransaction(TableOperations, TableMetadata) - Static method in class org.apache.iceberg.Transactions

requestRefresh() - Method in class org.apache.iceberg.BaseMetastoreTableOperations

required(int, String, Type) - Static method in class org.apache.iceberg.types.Types.NestedField

required(int, String, Type, String) - Static method in class org.apache.iceberg.types.Types.NestedField

residual() - Method in interface org.apache.iceberg.FileScanTask

Returns the residual expression that should be applied to rows in this file scan.

ResidualEvaluator - Class in org.apache.iceberg.expressions

Finds the residuals for an Expression the partitions in the given PartitionSpec.

ResidualEvaluator(PartitionSpec, Expression, boolean) - Constructor for class org.apache.iceberg.expressions.ResidualEvaluator

residualFor(StructLike) - Method in class org.apache.iceberg.expressions.ResidualEvaluator

Returns a residual expression for the given partition values.

retry(int) - Method in class org.apache.iceberg.util.Tasks.Builder

ReusableEntry() - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.ReusableEntry

reuseContainers() - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

reuseContainers(boolean) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

reuseContainers() - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder

reuseContainers() - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

reuseOrCreate(Object) - Method in class org.apache.iceberg.avro.ValueReaders.StructReader

revertWith(Tasks.Task<I, ?>) - Method in class org.apache.iceberg.util.Tasks.Builder

RewriteFiles - Interface in org.apache.iceberg

API for replacing files in a table.

rewriteFiles(Set<DataFile>, Set<DataFile>) - Method in interface org.apache.iceberg.RewriteFiles

Add a rewrite that replaces one set of files with another set that contains the same data.

rewriteIf(Predicate<ManifestFile>) - Method in class org.apache.iceberg.ReplaceManifests

rewriteIf(Predicate<ManifestFile>) - Method in interface org.apache.iceberg.RewriteManifests

Determines which existing ManifestFile for the table should be rewritten.

rewriteManifests() - Method in class org.apache.iceberg.BaseTable

RewriteManifests - Interface in org.apache.iceberg

API for rewriting manifests for a table.

rewriteManifests() - Method in interface org.apache.iceberg.Table

Create a new rewrite manifests API to replace manifests for this table and commit.

rewriteManifests() - Method in interface org.apache.iceberg.Transaction

Create a new rewrite manifests API to replace manifests for this table.

rewriteNot(Expression) - Static method in class org.apache.iceberg.expressions.Expressions

right() - Method in class org.apache.iceberg.expressions.And

right() - Method in class org.apache.iceberg.expressions.Or

rollback() - Method in class org.apache.iceberg.BaseTable

Rollback - Interface in org.apache.iceberg

API for rolling table data back to the state at an older table snapshot.

rollback() - Method in interface org.apache.iceberg.Table

Create a new rollback API to roll back to a previous snapshot and commit.

rollbackTo(Snapshot) - Method in class org.apache.iceberg.TableMetadata

run(Tasks.Task<I, RuntimeException>) - Method in class org.apache.iceberg.util.Tasks.Builder

run(Tasks.Task<I, E>, Class<E>) - Method in class org.apache.iceberg.util.Tasks.Builder

run(I, Exception) - Method in interface org.apache.iceberg.util.Tasks.FailureTask

run(I) - Method in interface org.apache.iceberg.util.Tasks.Task

RuntimeIOException - Exception in org.apache.iceberg.exceptions

Exception used to wrap IOException as a RuntimeException and add context.

RuntimeIOException(IOException) - Constructor for exception org.apache.iceberg.exceptions.RuntimeIOException

RuntimeIOException(IOException, String, Object...) - Constructor for exception org.apache.iceberg.exceptions.RuntimeIOException

RuntimeIOException(String, Object...) - Constructor for exception org.apache.iceberg.exceptions.RuntimeIOException

RuntimeMetaException - Exception in org.apache.iceberg.hive

Exception used to wrap MetaException as a RuntimeException and add context.

RuntimeMetaException(MetaException) - Constructor for exception org.apache.iceberg.hive.RuntimeMetaException

RuntimeMetaException(MetaException, String, Object...) - Constructor for exception org.apache.iceberg.hive.RuntimeMetaException

S

scale() - Method in class org.apache.iceberg.types.Types.DecimalType

SCAN_THREAD_POOL_ENABLED - Static variable in class org.apache.iceberg.SystemProperties

Whether to use the shared worker pool when planning table scans.

ScanBuilder(Table) - Constructor for class org.apache.iceberg.data.IcebergGenerics.ScanBuilder

ScanEvent - Class in org.apache.iceberg.events

Event sent to listeners when a table scan is planned.

ScanEvent(String, long, Expression, Schema) - Constructor for class org.apache.iceberg.events.ScanEvent

ScanSummary - Class in org.apache.iceberg

ScanSummary.Builder - Class in org.apache.iceberg

ScanSummary.PartitionMetrics - Class in org.apache.iceberg

ScanTask - Interface in org.apache.iceberg

A scan task.

schema(Schema) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

schema() - Method in class org.apache.iceberg.BaseTable

SCHEMA - Static variable in interface org.apache.iceberg.ManifestFile

schema() - Static method in interface org.apache.iceberg.ManifestFile

schema() - Method in class org.apache.iceberg.ManifestReader

schema(Schema) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder

schema(Schema) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder

schema(Schema) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

schema() - Method in class org.apache.iceberg.PartitionSpec

Schema - Class in org.apache.iceberg

The schema of a data table.

Schema(List<Types.NestedField>, Map<String, Integer>) - Constructor for class org.apache.iceberg.Schema

Schema(List<Types.NestedField>) - Constructor for class org.apache.iceberg.Schema

Schema(Types.NestedField...) - Constructor for class org.apache.iceberg.Schema

schema(Schema, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering

schema(Schema, Supplier<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering

schema() - Method in interface org.apache.iceberg.Table

Return the schema for this table.

schema() - Method in class org.apache.iceberg.TableMetadata

schema() - Method in interface org.apache.iceberg.TableScan

Returns this scan's projection Schema.

schema(Schema, Supplier<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility

schema(Schema, Map<String, Integer>) - Method in class org.apache.iceberg.types.IndexByName

schema(Schema, Supplier<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

schema(Schema, T) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

schemaForTable(SparkSession, String) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Returns a Schema for the given table with fresh field ids.

SchemaParser - Class in org.apache.iceberg

SchemaUtil - Class in org.apache.iceberg.pig

SchemaUtil() - Constructor for class org.apache.iceberg.pig.SchemaUtil

SchemaVisitor() - Constructor for class org.apache.iceberg.types.TypeUtil.SchemaVisitor

second() - Method in class org.apache.iceberg.util.Pair

seek(long) - Method in class org.apache.iceberg.io.SeekableInputStream

Seek to a new position in the InputStream.

SeekableInputStream - Class in org.apache.iceberg.io

SeekableInputStream is an interface with the methods needed to read data from a file or Hadoop data stream.

SeekableInputStream() - Constructor for class org.apache.iceberg.io.SeekableInputStream

select(String...) - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder

select(String...) - Method in interface org.apache.iceberg.Filterable

Selects the columns of a file manifest to read.

select(Collection<String>) - Method in interface org.apache.iceberg.Filterable

Selects the columns of a file manifest to read.

select(Collection<String>) - Method in class org.apache.iceberg.FilteredManifest

select(Collection<String>) - Method in class org.apache.iceberg.ManifestReader

select(String...) - Method in class org.apache.iceberg.Schema

Creates a projection schema for a subset of columns, selected by name.

select(Collection<String>) - Method in class org.apache.iceberg.Schema

Creates a projection schema for a subset of columns, selected by name.

select(String...) - Method in interface org.apache.iceberg.TableScan

Create a new TableScan from this that will read the given data columns.

select(Collection<String>) - Method in interface org.apache.iceberg.TableScan

Create a new TableScan from this that will read the given data columns.

select(Schema, Set<Integer>) - Static method in class org.apache.iceberg.types.TypeUtil

selectNot(Schema, Set<Integer>) - Static method in class org.apache.iceberg.types.TypeUtil

self() - Method in class org.apache.iceberg.OverwriteData

self() - Method in class org.apache.iceberg.ReplaceManifests

self() - Method in class org.apache.iceberg.ReplacePartitionsOperation

SerializableConfiguration - Class in org.apache.iceberg.hadoop

Wraps a Configuration object in a Serializable layer.

SerializableConfiguration(Configuration) - Constructor for class org.apache.iceberg.hadoop.SerializableConfiguration

serialize() - Method in class org.apache.iceberg.orc.ColumnIdMap

set(String, String) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

set(S, int, Object) - Method in class org.apache.iceberg.avro.ValueReaders.StructReader

set(T) - Method in class org.apache.iceberg.common.DynFields.BoundField

set(T) - Method in class org.apache.iceberg.common.DynFields.StaticField

set(Object, T) - Method in class org.apache.iceberg.common.DynFields.UnboundField

set(int, T) - Method in class org.apache.iceberg.data.GenericRecord

set(int, T) - Method in class org.apache.iceberg.GenericManifestFile

set(int, T) - Method in class org.apache.iceberg.GenericPartitionFieldSummary

set(String, String) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

set(String, String) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

set(K, V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ReusableEntry

set(I, int, Object) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

Used to set a struct value by position.

set(String, String) - Method in class org.apache.iceberg.ReplaceManifests

set(String, String) - Method in class org.apache.iceberg.SnapshotSummary.Builder

set(String, String) - Method in interface org.apache.iceberg.SnapshotUpdate

Set a summary property in the snapshot produced by this update.

set(int, T) - Method in interface org.apache.iceberg.StructLike

set(String, String) - Method in interface org.apache.iceberg.UpdateProperties

Add a key/value property to the table.

set(CharSequence) - Method in class org.apache.iceberg.util.CharSequenceWrapper

set(StructLike) - Method in class org.apache.iceberg.util.StructLikeWrapper

setAll(Map<String, String>) - Method in class org.apache.iceberg.avro.Avro.WriteBuilder

setAll(Map<String, String>) - Method in class org.apache.iceberg.orc.ORC.WriteBuilder

setAll(Map<String, String>) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

setBoolean(I, int, boolean) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setColumnStore(ColumnWriteStore) - Method in class org.apache.iceberg.parquet.ColumnWriter

setColumnStore(ColumnWriteStore) - Method in interface org.apache.iceberg.parquet.ParquetValueWriter

setColumnStore(ColumnWriteStore) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter

setColumnStore(ColumnWriteStore) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter

setColumnStore(ColumnWriteStore) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter

setColumnStore(ColumnWriteStore) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.StructWriter

setConf(Configuration) - Method in class org.apache.iceberg.hadoop.HadoopTables

setDouble(I, int, double) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setField(String, Object) - Method in class org.apache.iceberg.data.GenericRecord

setField(String, Object) - Method in interface org.apache.iceberg.data.Record

setFloat(I, int, float) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setInteger(I, int, int) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setLocation(String, Job) - Method in class org.apache.iceberg.pig.IcebergStorage

SetLocation - Class in org.apache.iceberg

SetLocation(TableOperations) - Constructor for class org.apache.iceberg.SetLocation

setLocation(String) - Method in class org.apache.iceberg.SetLocation

setLocation(String) - Method in interface org.apache.iceberg.UpdateLocation

Set the table's location.

setLong(I, int, long) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setNull(I, int) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setPageSource(PageReader) - Method in class org.apache.iceberg.parquet.ColumnIterator

setPageSource(PageReadStore) - Method in interface org.apache.iceberg.parquet.ParquetValueReader

setPageSource(PageReadStore) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader

setPageSource(PageReadStore) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

setPageSource(PageReadStore) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader

setPageSource(PageReadStore) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

setPartitionFilter(Expression) - Method in class org.apache.iceberg.pig.IcebergStorage

setPushdownPredicate(Expression) - Method in class org.apache.iceberg.pig.IcebergStorage

setSchema(Schema) - Method in class org.apache.iceberg.avro.ProjectionDatumReader

setSchema(Schema) - Method in class org.apache.iceberg.data.avro.DataReader

setSchema(Schema) - Method in class org.apache.iceberg.data.avro.DataWriter

setSchema(Schema) - Method in class org.apache.iceberg.spark.data.SparkAvroReader

setSchema(Schema) - Method in class org.apache.iceberg.spark.data.SparkAvroWriter

setUDFContextSignature(String) - Method in class org.apache.iceberg.pig.IcebergStorage

setValue(V) - Method in class org.apache.iceberg.parquet.ParquetValueReaders.ReusableEntry

shortName() - Method in class org.apache.iceberg.spark.source.IcebergSource

shouldAdjustToUTC() - Method in class org.apache.iceberg.types.Types.TimestampType

shouldCompress(Configuration) - Static method in class org.apache.iceberg.ConfigProperties

shouldRead(MessageType, BlockMetaData, DictionaryPageReadStore) - Method in class org.apache.iceberg.parquet.ParquetDictionaryRowGroupFilter

Test whether the dictionaries for a row group may contain records that match the expression.

shouldRead(MessageType, BlockMetaData) - Method in class org.apache.iceberg.parquet.ParquetMetricsRowGroupFilter

Test whether the file may contain records that match the expression.

signedBytes() - Static method in class org.apache.iceberg.types.Comparators

size() - Method in class org.apache.iceberg.data.GenericRecord

size() - Method in class org.apache.iceberg.GenericManifestFile

size() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

size() - Method in class org.apache.iceberg.orc.ColumnIdMap

size() - Method in interface org.apache.iceberg.StructLike

snapshot(long) - Method in class org.apache.iceberg.BaseTable

Snapshot - Interface in org.apache.iceberg

A snapshot of the data in a table at a point in time.

snapshot(long) - Method in interface org.apache.iceberg.Table

Get the snapshot of this table with the given id, or null if there is no matching snapshot.

snapshot(long) - Method in class org.apache.iceberg.TableMetadata

snapshotId() - Method in class org.apache.iceberg.events.ScanEvent

snapshotId() - Method in class org.apache.iceberg.GenericManifestFile

snapshotId() - Method in interface org.apache.iceberg.ManifestFile

snapshotId() - Method in interface org.apache.iceberg.Snapshot

Return this snapshot's ID.

snapshotId() - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry

snapshotLog() - Method in class org.apache.iceberg.TableMetadata

SnapshotParser - Class in org.apache.iceberg

snapshots() - Method in class org.apache.iceberg.BaseTable

snapshots() - Method in interface org.apache.iceberg.Table

Get the snapshots of this table.

snapshots() - Method in class org.apache.iceberg.TableMetadata

SnapshotSummary - Class in org.apache.iceberg

SnapshotSummary.Builder - Class in org.apache.iceberg

SnapshotUpdate<ThisT> - Interface in org.apache.iceberg

API for table changes that produce snapshots.

sortColumns() - Method in interface org.apache.iceberg.DataFile

sourceId() - Method in class org.apache.iceberg.PartitionField

SparkAvroReader - Class in org.apache.iceberg.spark.data

SparkAvroReader(Schema) - Constructor for class org.apache.iceberg.spark.data.SparkAvroReader

SparkAvroWriter - Class in org.apache.iceberg.spark.data

SparkAvroWriter(Schema) - Constructor for class org.apache.iceberg.spark.data.SparkAvroWriter

SparkFilters - Class in org.apache.iceberg.spark

SparkOrcReader - Class in org.apache.iceberg.spark.data

Converts the OrcInterator, which returns ORC's VectorizedRowBatch to a set of Spark's UnsafeRows.

SparkOrcReader(Schema) - Constructor for class org.apache.iceberg.spark.data.SparkOrcReader

SparkOrcWriter - Class in org.apache.iceberg.spark.data

This class acts as an adaptor from an OrcFileAppender to a FileAppender<InternalRow>.

SparkOrcWriter(TypeDescription) - Constructor for class org.apache.iceberg.spark.data.SparkOrcWriter

SparkParquetReaders - Class in org.apache.iceberg.spark.data

SparkParquetWriters - Class in org.apache.iceberg.spark.data

SparkSchemaUtil - Class in org.apache.iceberg.spark

Helper methods for working with Spark/Hive metadata.

SparkValueReaders - Class in org.apache.iceberg.spark.data

SparkValueWriters - Class in org.apache.iceberg.spark.data

spec() - Method in class org.apache.iceberg.BaseTable

spec() - Method in interface org.apache.iceberg.FileScanTask

The spec used to store this file.

spec() - Method in class org.apache.iceberg.ManifestReader

spec() - Method in interface org.apache.iceberg.Table

Return the partition spec for this table.

spec() - Method in class org.apache.iceberg.TableMetadata

spec(int) - Method in class org.apache.iceberg.TableMetadata

specForTable(SparkSession, String) - Static method in class org.apache.iceberg.spark.SparkSchemaUtil

Returns a PartitionSpec for the given table.

specId() - Method in class org.apache.iceberg.PartitionSpec

specs() - Method in class org.apache.iceberg.TableMetadata

split(long, long) - Method in class org.apache.iceberg.avro.Avro.ReadBuilder

Restricts the read to the given range: [start, end = start + length).

split(long) - Method in interface org.apache.iceberg.FileScanTask

Splits this scan task into component scan tasks, each of splitSize size

split(long, long) - Method in class org.apache.iceberg.orc.ORC.ReadBuilder

Restricts the read to the given range: [start, start + length).

split(long, long) - Method in class org.apache.iceberg.parquet.Parquet.ReadBuilder

Restricts the read to the given range: [start, start + length).

SPLIT_LOOKBACK - Static variable in class org.apache.iceberg.TableProperties

SPLIT_LOOKBACK_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

SPLIT_OPEN_FILE_COST - Static variable in class org.apache.iceberg.TableProperties

SPLIT_OPEN_FILE_COST_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

SPLIT_SIZE - Static variable in class org.apache.iceberg.TableProperties

SPLIT_SIZE_DEFAULT - Static variable in class org.apache.iceberg.TableProperties

splitOffsets() - Method in interface org.apache.iceberg.DataFile

splitOffsets() - Method in interface org.apache.iceberg.io.FileAppender

splitOffsets() - Method in class org.apache.iceberg.parquet.ParquetWriteAdapter

start() - Method in interface org.apache.iceberg.FileScanTask

The starting position of this scan range in the file.

stopAbortsOnFailure() - Method in class org.apache.iceberg.util.Tasks.Builder

stopOnFailure() - Method in class org.apache.iceberg.util.Tasks.Builder

stopRetryOn(Class<? extends Exception>...) - Method in class org.apache.iceberg.util.Tasks.Builder

stopRevertsOnFailure() - Method in class org.apache.iceberg.util.Tasks.Builder

StreamingWriter - Class in org.apache.iceberg.spark.source

strict(PartitionSpec) - Static method in class org.apache.iceberg.expressions.Projections

Creates a strict ProjectionEvaluator for the spec, defaulting to case sensitive mode.

strict(PartitionSpec, boolean) - Static method in class org.apache.iceberg.expressions.Projections

Creates a strict ProjectionEvaluator for the spec.

StrictMetricsEvaluator - Class in org.apache.iceberg.expressions

Evaluates an Expression on a DataFile to test whether all rows in the file match.

StrictMetricsEvaluator(Schema, Expression) - Constructor for class org.apache.iceberg.expressions.StrictMetricsEvaluator

StringReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.StringReader

strings() - Static method in class org.apache.iceberg.avro.ValueReaders

strings() - Static method in class org.apache.iceberg.avro.ValueWriters

strings(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters

StringType() - Constructor for class org.apache.iceberg.types.Types.StringType

struct() - Method in class org.apache.iceberg.data.GenericRecord

struct() - Method in interface org.apache.iceberg.data.Record

struct(GroupType, List<T>) - Method in class org.apache.iceberg.parquet.ParquetTypeVisitor

struct(Types.StructType, Type.Repetition, int, String) - Method in class org.apache.iceberg.parquet.TypeToMessageType

struct(Types.StructType, GroupType, List<T>) - Method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

struct(Types.StructType, Iterable<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithoutReordering

struct(Types.StructType, Iterable<Type>) - Method in class org.apache.iceberg.spark.PruneColumnsWithReordering

struct(Types.StructType, Iterable<List<String>>) - Method in class org.apache.iceberg.types.CheckCompatibility

struct(Types.StructType, List<Map<String, Integer>>) - Method in class org.apache.iceberg.types.IndexByName

struct(Types.StructType, Iterable<T>) - Method in class org.apache.iceberg.types.TypeUtil.CustomOrderSchemaVisitor

struct(Types.StructType, List<T>) - Method in class org.apache.iceberg.types.TypeUtil.SchemaVisitor

StructLike - Interface in org.apache.iceberg

Interface for accessing data by position in a schema.

StructLikeWrapper - Class in org.apache.iceberg.util

Wrapper to adapt StructLike for use in maps and sets by implementing equals and hashCode.

StructReader(List<ValueReader<?>>) - Constructor for class org.apache.iceberg.avro.ValueReaders.StructReader

StructReader(List<Type>, List<ParquetValueReader<?>>) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.StructReader

StructWriter(List<ValueWriter<?>>) - Constructor for class org.apache.iceberg.avro.ValueWriters.StructWriter

StructWriter(List<ParquetValueWriter<?>>) - Constructor for class org.apache.iceberg.parquet.ParquetValueWriters.StructWriter

summary() - Method in class org.apache.iceberg.ReplaceManifests

summary() - Method in interface org.apache.iceberg.Snapshot

Return a string map of summary data for the operation that produced this snapshot.

suppressAndThrow(E, Runnable) - Static method in class org.apache.iceberg.util.Exceptions

suppressExceptions(E, Runnable) - Static method in class org.apache.iceberg.util.Exceptions

suppressFailureWhenFinished() - Method in class org.apache.iceberg.util.Tasks.Builder

SystemProperties - Class in org.apache.iceberg

Configuration properties that are controlled by Java system properties.

T

table(Table) - Static method in class org.apache.iceberg.FileHistory

Table - Interface in org.apache.iceberg

Represents a table.

table() - Method in interface org.apache.iceberg.TableScan

Returns the Table from which this scan loads data.

table() - Method in interface org.apache.iceberg.Transaction

Return the Table that this transaction will update.

TABLE_TYPE_PROP - Static variable in class org.apache.iceberg.BaseMetastoreTableOperations

tableExists(TableIdentifier) - Method in interface org.apache.iceberg.catalog.Catalog

Check whether table exists.

TableIdentifier - Class in org.apache.iceberg.catalog

Identifies a table in iceberg catalog.

TableMetadata - Class in org.apache.iceberg

Metadata for a table.

TableMetadata.SnapshotLogEntry - Class in org.apache.iceberg

TableMetadataParser - Class in org.apache.iceberg

tableName() - Method in class org.apache.iceberg.events.ScanEvent

TableOperations - Interface in org.apache.iceberg

SPI interface to abstract table metadata access and updates.

TableProperties - Class in org.apache.iceberg

Tables - Interface in org.apache.iceberg

Generic interface for creating and loading a table implementation.

TableScan - Interface in org.apache.iceberg

API for configuring a table scan.

Tasks - Class in org.apache.iceberg.util

Tasks.Builder<I> - Class in org.apache.iceberg.util

Tasks.FailureTask<I,E extends java.lang.Exception> - Interface in org.apache.iceberg.util

Tasks.Task<I,E extends java.lang.Exception> - Interface in org.apache.iceberg.util

Tasks.UnrecoverableException - Exception in org.apache.iceberg.util

ThreadPools - Class in org.apache.iceberg.util

throwFailureWhenFinished() - Method in class org.apache.iceberg.util.Tasks.Builder

throwFailureWhenFinished(boolean) - Method in class org.apache.iceberg.util.Tasks.Builder

throwIfLimited() - Method in class org.apache.iceberg.ScanSummary.Builder

timestampMillis() - Method in interface org.apache.iceberg.Snapshot

Return this snapshot's timestamp.

timestampMillis() - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry

to(Type) - Method in interface org.apache.iceberg.expressions.Literal

Converts this literal to a literal of the given type.

toByteArray(ByteBuffer) - Static method in class org.apache.iceberg.util.ByteBuffers

toByteBuffer(Type, Object) - Static method in class org.apache.iceberg.types.Conversions

toFixed(UUID, Schema, LogicalType) - Method in class org.apache.iceberg.avro.UUIDConversion

toHumanString(T) - Method in interface org.apache.iceberg.transforms.Transform

Returns a human-readable String representation of a transformed value.

toInputFile() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

toInputFile() - Method in interface org.apache.iceberg.io.OutputFile

Return an InputFile for the location of this output file.

toJson(PartitionSpec, JsonGenerator) - Static method in class org.apache.iceberg.PartitionSpecParser

toJson(PartitionSpec) - Static method in class org.apache.iceberg.PartitionSpecParser

toJson(PartitionSpec, boolean) - Static method in class org.apache.iceberg.PartitionSpecParser

toJson(Schema, JsonGenerator) - Static method in class org.apache.iceberg.SchemaParser

toJson(Schema) - Static method in class org.apache.iceberg.SchemaParser

toJson(Schema, boolean) - Static method in class org.apache.iceberg.SchemaParser

toJson(Snapshot) - Static method in class org.apache.iceberg.SnapshotParser

toJson(TableMetadata) - Static method in class org.apache.iceberg.TableMetadataParser

toManifestFile() - Method in class org.apache.iceberg.ManifestWriter

toOrc(Schema, ColumnIdMap) - Static method in class org.apache.iceberg.orc.TypeConversion

Convert a given Iceberg schema to ORC.

toPosition(Accessor<StructLike>) - Static method in class org.apache.iceberg.Accessors

toSnapshotAtTime(long) - Method in interface org.apache.iceberg.Rollback

Roll this table's data back to the last Snapshot before the given timestamp.

toSnapshotId(long) - Method in interface org.apache.iceberg.Rollback

Roll this table's data back to a specific Snapshot identified by id.

toString() - Method in class org.apache.iceberg.BaseTable

toString() - Method in class org.apache.iceberg.catalog.Namespace

toString() - Method in class org.apache.iceberg.catalog.TableIdentifier

toString() - Method in class org.apache.iceberg.common.DynConstructors.Ctor

toString() - Method in class org.apache.iceberg.common.DynFields.UnboundField

toString() - Method in class org.apache.iceberg.common.DynMethods.UnboundMethod

toString() - Method in class org.apache.iceberg.data.GenericRecord

toString() - Method in class org.apache.iceberg.expressions.And

toString() - Method in class org.apache.iceberg.expressions.BoundReference

toString() - Method in class org.apache.iceberg.expressions.False

toString() - Method in class org.apache.iceberg.expressions.NamedReference

toString() - Method in class org.apache.iceberg.expressions.Not

toString() - Method in class org.apache.iceberg.expressions.Or

toString() - Method in class org.apache.iceberg.expressions.Predicate

toString() - Method in class org.apache.iceberg.expressions.True

toString() - Method in class org.apache.iceberg.GenericManifestFile

toString() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

toString() - Method in class org.apache.iceberg.hadoop.HadoopInputFile

toString() - Method in class org.apache.iceberg.hadoop.HadoopOutputFile

toString() - Method in class org.apache.iceberg.PartitionField

toString() - Method in class org.apache.iceberg.PartitionSpec

toString() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics

toString() - Method in class org.apache.iceberg.Schema

toString() - Method in class org.apache.iceberg.TableMetadata.SnapshotLogEntry

toString() - Method in class org.apache.iceberg.types.Types.BinaryType

toString() - Method in class org.apache.iceberg.types.Types.BooleanType

toString() - Method in class org.apache.iceberg.types.Types.DateType

toString() - Method in class org.apache.iceberg.types.Types.DecimalType

toString() - Method in class org.apache.iceberg.types.Types.DoubleType

toString() - Method in class org.apache.iceberg.types.Types.FixedType

toString() - Method in class org.apache.iceberg.types.Types.FloatType

toString() - Method in class org.apache.iceberg.types.Types.IntegerType

toString() - Method in class org.apache.iceberg.types.Types.ListType

toString() - Method in class org.apache.iceberg.types.Types.LongType

toString() - Method in class org.apache.iceberg.types.Types.MapType

toString() - Method in class org.apache.iceberg.types.Types.NestedField

toString() - Method in class org.apache.iceberg.types.Types.StringType

toString() - Method in class org.apache.iceberg.types.Types.StructType

toString() - Method in class org.apache.iceberg.types.Types.TimestampType

toString() - Method in class org.apache.iceberg.types.Types.TimeType

toString() - Method in class org.apache.iceberg.types.Types.UUIDType

toString() - Method in class org.apache.iceberg.util.Pair

TOTAL_FILES_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

TOTAL_RECORDS_PROP - Static variable in class org.apache.iceberg.SnapshotSummary

totalSize() - Method in class org.apache.iceberg.ScanSummary.PartitionMetrics

Transaction - Interface in org.apache.iceberg

A transaction for performing multiple updates to a table.

Transactions - Class in org.apache.iceberg

transform(CloseableIterable<I>, Function<I, O>) - Static method in interface org.apache.iceberg.io.CloseableIterable

transform() - Method in class org.apache.iceberg.PartitionField

Transform<S,T> - Interface in org.apache.iceberg.transforms

A transform function used for partitioning.

Transforms - Class in org.apache.iceberg.transforms

Factory methods for transforms.

TripleWriter<T> - Interface in org.apache.iceberg.parquet

True - Class in org.apache.iceberg.expressions

An expression that is always true.

truncate(String, int) - Method in class org.apache.iceberg.PartitionSpec.Builder

truncate(String, int, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

truncate(Type, int) - Static method in class org.apache.iceberg.transforms.Transforms

Returns a truncate Transform for the given type and width.

type() - Method in interface org.apache.iceberg.Accessor

type() - Method in class org.apache.iceberg.expressions.BoundReference

TYPE - Static variable in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary

Type - Interface in org.apache.iceberg.types

type() - Method in class org.apache.iceberg.types.Types.NestedField

Type.NestedType - Class in org.apache.iceberg.types

Type.PrimitiveType - Class in org.apache.iceberg.types

Type.TypeID - Enum in org.apache.iceberg.types

TypeConversion - Class in org.apache.iceberg.orc

TypeConversion() - Constructor for class org.apache.iceberg.orc.TypeConversion

typeId() - Method in interface org.apache.iceberg.types.Type

typeId() - Method in class org.apache.iceberg.types.Types.BinaryType

typeId() - Method in class org.apache.iceberg.types.Types.BooleanType

typeId() - Method in class org.apache.iceberg.types.Types.DateType

typeId() - Method in class org.apache.iceberg.types.Types.DecimalType

typeId() - Method in class org.apache.iceberg.types.Types.DoubleType

typeId() - Method in class org.apache.iceberg.types.Types.FixedType

typeId() - Method in class org.apache.iceberg.types.Types.FloatType

typeId() - Method in class org.apache.iceberg.types.Types.IntegerType

typeId() - Method in class org.apache.iceberg.types.Types.ListType

typeId() - Method in class org.apache.iceberg.types.Types.LongType

typeId() - Method in class org.apache.iceberg.types.Types.MapType

typeId() - Method in class org.apache.iceberg.types.Types.StringType

typeId() - Method in class org.apache.iceberg.types.Types.StructType

typeId() - Method in class org.apache.iceberg.types.Types.TimestampType

typeId() - Method in class org.apache.iceberg.types.Types.TimeType

typeId() - Method in class org.apache.iceberg.types.Types.UUIDType

Types - Class in org.apache.iceberg.types

Types.BinaryType - Class in org.apache.iceberg.types

Types.BooleanType - Class in org.apache.iceberg.types

Types.DateType - Class in org.apache.iceberg.types

Types.DecimalType - Class in org.apache.iceberg.types

Types.DoubleType - Class in org.apache.iceberg.types

Types.FixedType - Class in org.apache.iceberg.types

Types.FloatType - Class in org.apache.iceberg.types

Types.IntegerType - Class in org.apache.iceberg.types

Types.ListType - Class in org.apache.iceberg.types

Types.LongType - Class in org.apache.iceberg.types

Types.MapType - Class in org.apache.iceberg.types

Types.NestedField - Class in org.apache.iceberg.types

Types.StringType - Class in org.apache.iceberg.types

Types.StructType - Class in org.apache.iceberg.types

Types.TimestampType - Class in org.apache.iceberg.types

Types.TimeType - Class in org.apache.iceberg.types

Types.UUIDType - Class in org.apache.iceberg.types

TypeToMessageType - Class in org.apache.iceberg.parquet

TypeToMessageType() - Constructor for class org.apache.iceberg.parquet.TypeToMessageType

TypeUtil - Class in org.apache.iceberg.types

TypeUtil.CustomOrderSchemaVisitor<T> - Class in org.apache.iceberg.types

TypeUtil.NextID - Interface in org.apache.iceberg.types

Interface for passing a function that assigns column IDs.

TypeUtil.SchemaVisitor<T> - Class in org.apache.iceberg.types

TypeWithSchemaVisitor<T> - Class in org.apache.iceberg.parquet

Visitor for traversing a Parquet type with a companion Iceberg type.

TypeWithSchemaVisitor() - Constructor for class org.apache.iceberg.parquet.TypeWithSchemaVisitor

U

UnboundPredicate<T> - Class in org.apache.iceberg.expressions

unboxed(ColumnDescriptor) - Static method in class org.apache.iceberg.parquet.ParquetValueWriters

UnboxedReader(ColumnDescriptor) - Constructor for class org.apache.iceberg.parquet.ParquetValueReaders.UnboxedReader

union(Schema, List<T>) - Method in class org.apache.iceberg.avro.AvroSchemaVisitor

union(List<ValueReader<?>>) - Static method in class org.apache.iceberg.avro.ValueReaders

unpartitioned() - Static method in class org.apache.iceberg.PartitionSpec

Returns a spec for unpartitioned tables.

UnrecoverableException(String) - Constructor for exception org.apache.iceberg.util.Tasks.UnrecoverableException

UnrecoverableException(String, Throwable) - Constructor for exception org.apache.iceberg.util.Tasks.UnrecoverableException

UnrecoverableException(Throwable) - Constructor for exception org.apache.iceberg.util.Tasks.UnrecoverableException

unsignedBytes() - Static method in class org.apache.iceberg.types.Comparators

updateColumn(String, Type.PrimitiveType) - Method in interface org.apache.iceberg.UpdateSchema

Update a column in the schema to a new primitive type.

updateColumn(String, Type.PrimitiveType, String) - Method in interface org.apache.iceberg.UpdateSchema

Update a column in the schema to a new primitive type.

updateColumnDoc(String, String) - Method in interface org.apache.iceberg.UpdateSchema

Update a column in the schema to a new primitive type.

updateLocation() - Method in class org.apache.iceberg.BaseTable

updateLocation() - Method in interface org.apache.iceberg.Table

Create a new UpdateLocation to update table location and commit the changes.

updateLocation(String) - Method in class org.apache.iceberg.TableMetadata

updateLocation() - Method in interface org.apache.iceberg.Transaction

Create a new UpdateLocation to update table location.

UpdateLocation - Interface in org.apache.iceberg

API for setting a table's base location.

updatePartitionSpec(PartitionSpec) - Method in class org.apache.iceberg.TableMetadata

updateProperties() - Method in class org.apache.iceberg.BaseTable

updateProperties() - Method in interface org.apache.iceberg.Table

Create a new UpdateProperties to update table properties and commit the changes.

updateProperties() - Method in interface org.apache.iceberg.Transaction

Create a new UpdateProperties to update table properties.

UpdateProperties - Interface in org.apache.iceberg

API for updating table properties.

updateSchema() - Method in class org.apache.iceberg.BaseTable

updateSchema() - Method in interface org.apache.iceberg.Table

Create a new UpdateSchema to alter the columns of this table and commit the change.

updateSchema(Schema, int) - Method in class org.apache.iceberg.TableMetadata

updateSchema() - Method in interface org.apache.iceberg.Transaction

Create a new UpdateSchema to alter the columns of this table.

UpdateSchema - Interface in org.apache.iceberg

API for schema evolution.

updateTableLocation(String) - Method in class org.apache.iceberg.TableMetadata

upperBound() - Method in class org.apache.iceberg.GenericPartitionFieldSummary

upperBound() - Method in interface org.apache.iceberg.ManifestFile.PartitionFieldSummary

upperBounds() - Method in interface org.apache.iceberg.DataFile

upperBounds() - Method in class org.apache.iceberg.Metrics

useSnapshot(long) - Method in interface org.apache.iceberg.TableScan

Create a new TableScan from this scan's configuration that will use the given snapshot by ID.

utf8s() - Static method in class org.apache.iceberg.avro.ValueReaders

utf8s() - Static method in class org.apache.iceberg.avro.ValueWriters

UUIDConversion - Class in org.apache.iceberg.avro

UUIDConversion() - Constructor for class org.apache.iceberg.avro.UUIDConversion

uuids() - Static method in class org.apache.iceberg.avro.ValueReaders

uuids() - Static method in class org.apache.iceberg.avro.ValueWriters

UUIDType() - Constructor for class org.apache.iceberg.types.Types.UUIDType

V

validate(Schema) - Method in class org.apache.iceberg.avro.LogicalMap

validateAddedFiles() - Method in class org.apache.iceberg.OverwriteData

validateAddedFiles() - Method in interface org.apache.iceberg.OverwriteFiles

Signal that each file added to the table must match the overwrite expression.

validateAppendOnly() - Method in interface org.apache.iceberg.ReplacePartitions

Validate that no partitions will be replaced and the operation is append-only.

validateAppendOnly() - Method in class org.apache.iceberg.ReplacePartitionsOperation

ValidationException - Exception in org.apache.iceberg.exceptions

Exception raised when validation checks fail.

ValidationException(String, Object...) - Constructor for exception org.apache.iceberg.exceptions.ValidationException

ValidationException(Throwable, String, Object...) - Constructor for exception org.apache.iceberg.exceptions.ValidationException

value() - Method in interface org.apache.iceberg.expressions.Literal

VALUE_ID_PROP - Static variable in class org.apache.iceberg.avro.AvroSchemaUtil

valueCounts() - Method in interface org.apache.iceberg.DataFile

valueCounts() - Method in class org.apache.iceberg.Metrics

valueId() - Method in class org.apache.iceberg.types.Types.MapType

valueOf(String) - Static method in enum org.apache.iceberg.expressions.Expression.Operation

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.iceberg.FileFormat

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.iceberg.types.Type.TypeID

Returns the enum constant of this type with the specified name.

ValueReader<T> - Interface in org.apache.iceberg.avro

ValueReaders - Class in org.apache.iceberg.avro

ValueReaders.StructReader<S> - Class in org.apache.iceberg.avro

values() - Static method in enum org.apache.iceberg.expressions.Expression.Operation

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.iceberg.FileFormat

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Method in class org.apache.iceberg.orc.ColumnIdMap

values() - Static method in enum org.apache.iceberg.types.Type.TypeID

Returns an array containing the constants of this enum type, in the order they are declared.

valueType() - Method in class org.apache.iceberg.types.Types.MapType

ValueWriter<D> - Interface in org.apache.iceberg.avro

ValueWriters - Class in org.apache.iceberg.avro

ValueWriters.StructWriter<S> - Class in org.apache.iceberg.avro

VectorizedRowBatchIterator - Class in org.apache.iceberg.orc

An adaptor so that the ORC RecordReader can be used as an Iterator.

visit(Schema, AvroSchemaVisitor<T>) - Static method in class org.apache.iceberg.avro.AvroSchemaVisitor

visit(Expression, ExpressionVisitors.ExpressionVisitor<R>) - Static method in class org.apache.iceberg.expressions.ExpressionVisitors

Traverses the given expression with a visitor.

visit(Type, ParquetTypeVisitor<T>) - Static method in class org.apache.iceberg.parquet.ParquetTypeVisitor

visit(Type, Type, TypeWithSchemaVisitor<T>) - Static method in class org.apache.iceberg.parquet.TypeWithSchemaVisitor

visit(Schema, PartitionSpec, PartitionSpecVisitor<R>) - Static method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

visit(Schema, TypeUtil.SchemaVisitor<T>) - Static method in class org.apache.iceberg.types.TypeUtil

visit(Type, TypeUtil.SchemaVisitor<T>) - Static method in class org.apache.iceberg.types.TypeUtil

visit(Schema, TypeUtil.CustomOrderSchemaVisitor<T>) - Static method in class org.apache.iceberg.types.TypeUtil

visit(Type, TypeUtil.CustomOrderSchemaVisitor<T>) - Static method in class org.apache.iceberg.types.TypeUtil

Used to traverse types with traversals other than pre-order.

W

where(Expression) - Method in class org.apache.iceberg.data.IcebergGenerics.ScanBuilder

withEncryptedOutputFile(EncryptedOutputFile) - Method in class org.apache.iceberg.DataFiles.Builder

withEncryptionKeyMetadata(ByteBuffer) - Method in class org.apache.iceberg.DataFiles.Builder

withEncryptionKeyMetadata(EncryptionKeyMetadata) - Method in class org.apache.iceberg.DataFiles.Builder

withFileSizeInBytes(long) - Method in class org.apache.iceberg.DataFiles.Builder

withFormat(String) - Method in class org.apache.iceberg.DataFiles.Builder

withFormat(FileFormat) - Method in class org.apache.iceberg.DataFiles.Builder

withInputFile(InputFile) - Method in class org.apache.iceberg.DataFiles.Builder

withMetrics(Metrics) - Method in class org.apache.iceberg.DataFiles.Builder

withNoopClose(Iterable<E>) - Static method in interface org.apache.iceberg.io.CloseableIterable

withoutZone() - Static method in class org.apache.iceberg.types.Types.TimestampType

withPartition(StructLike) - Method in class org.apache.iceberg.DataFiles.Builder

withPartitionPath(String) - Method in class org.apache.iceberg.DataFiles.Builder

withPath(String) - Method in class org.apache.iceberg.DataFiles.Builder

withRecordCount(long) - Method in class org.apache.iceberg.DataFiles.Builder

withSpecId(int) - Method in class org.apache.iceberg.PartitionSpec.Builder

withSplitOffsets(List<Long>) - Method in class org.apache.iceberg.DataFiles.Builder

withStatus(FileStatus) - Method in class org.apache.iceberg.DataFiles.Builder

withZone() - Static method in class org.apache.iceberg.types.Types.TimestampType

WORKER_THREAD_POOL_SIZE - Static variable in class org.apache.iceberg.util.ThreadPools

WORKER_THREAD_POOL_SIZE_PROP - Static variable in class org.apache.iceberg.SystemProperties

Sets the size of the worker pool.

WORKER_THREAD_POOL_SIZE_PROP - Static variable in class org.apache.iceberg.util.ThreadPools

wrap(CharSequence) - Static method in class org.apache.iceberg.util.CharSequenceWrapper

wrap(StructLike) - Static method in class org.apache.iceberg.util.StructLikeWrapper

write(OutputFile) - Static method in class org.apache.iceberg.avro.Avro

write(D, Encoder) - Method in interface org.apache.iceberg.avro.ValueWriter

write(S, Encoder) - Method in class org.apache.iceberg.avro.ValueWriters.StructWriter

write(T, Encoder) - Method in class org.apache.iceberg.data.avro.DataWriter

write(PartitionSpec, OutputFile) - Static method in class org.apache.iceberg.ManifestWriter

Create a new ManifestWriter.

write(OutputFile) - Static method in class org.apache.iceberg.orc.ORC

write(T, VectorizedRowBatch) - Method in interface org.apache.iceberg.orc.OrcValueWriter

Writes the data.

write(OutputFile) - Static method in class org.apache.iceberg.parquet.Parquet

write(int, T) - Method in interface org.apache.iceberg.parquet.ParquetValueWriter

write(int, T) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.PrimitiveWriter

write(int, M) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter

write(int, L) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter

write(int, S) - Method in class org.apache.iceberg.parquet.ParquetValueWriters.StructWriter

write(int, T) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a value.

write(InternalRow, Encoder) - Method in class org.apache.iceberg.spark.data.SparkAvroWriter

write(InternalRow, VectorizedRowBatch) - Method in class org.apache.iceberg.spark.data.SparkOrcWriter

write(TableMetadata, OutputFile) - Static method in class org.apache.iceberg.TableMetadataParser

WRITE_METADATA_LOCATION - Static variable in class org.apache.iceberg.TableProperties

WRITE_NEW_DATA_LOCATION - Static variable in class org.apache.iceberg.TableProperties

writeBinary(int, Binary) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeBinary(int, Binary) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeBoolean(int, boolean) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeBoolean(int, boolean) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeCompatibilityErrors(Schema, Schema) - Static method in class org.apache.iceberg.types.CheckCompatibility

Returns a list of compatibility errors for writing with the given write schema.

writeDouble(int, double) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeDouble(int, double) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeFloat(int, float) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeFloat(int, float) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeInteger(int, int) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeInteger(int, int) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeLong(int, long) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeLong(int, long) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple.

writeNewMetadata(TableMetadata, int) - Method in class org.apache.iceberg.BaseMetastoreTableOperations

writeNull(int, int) - Method in class org.apache.iceberg.parquet.ColumnWriter

writeNull(int, int) - Method in interface org.apache.iceberg.parquet.TripleWriter

Write a triple for a null value.

writer(int) - Method in class org.apache.iceberg.avro.ValueWriters.StructWriter

writeSupport(WriteSupport<?>) - Method in class org.apache.iceberg.parquet.Parquet.WriteBuilder

Y

year(String) - Method in class org.apache.iceberg.PartitionSpec.Builder

year(String, int) - Method in interface org.apache.iceberg.transforms.PartitionSpecVisitor

year(Type) - Static method in class org.apache.iceberg.transforms.Transforms

Returns a year Transform for date or timestamp types.

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