Package org.apache.iceberg

Class TableMetadata

java.lang.Object

org.apache.iceberg.TableMetadata

All Implemented Interfaces:

java.io.Serializable

public class TableMetadata
extends java.lang.Object
implements java.io.Serializable

Metadata for a table.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TableMetadata.MetadataLogEntry
static class	TableMetadata.SnapshotLogEntry

Method Summary

Modifier and Type	Method	Description
TableMetadata	addStagedSnapshot(Snapshot snapshot)
TableMetadata	buildReplacement(Schema updatedSchema, PartitionSpec updatedPartitionSpec, java.lang.String newLocation, java.util.Map<java.lang.String,java.lang.String> updatedProperties)
Snapshot	currentSnapshot()
int	defaultSpecId()
int	formatVersion()
int	lastColumnId()
long	lastSequenceNumber()
long	lastUpdatedMillis()
java.lang.String	location()
java.lang.String	metadataFileLocation()
static TableMetadata	newTableMetadata(Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties)
static TableMetadata	newTableMetadata(TableOperations ops, Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties)	Deprecated. will be removed in 0.9.0; use newTableMetadata(Schema, PartitionSpec, String, Map) instead.
long	nextSequenceNumber()
java.util.List<TableMetadata.MetadataLogEntry>	previousFiles()
java.util.Map<java.lang.String,java.lang.String>	properties()
java.lang.String	property(java.lang.String property, java.lang.String defaultValue)
boolean	propertyAsBoolean(java.lang.String property, boolean defaultValue)
int	propertyAsInt(java.lang.String property, int defaultValue)
long	propertyAsLong(java.lang.String property, long defaultValue)
TableMetadata	removeSnapshotLogEntries(java.util.Set<java.lang.Long> snapshotIds)
TableMetadata	removeSnapshotsIf(java.util.function.Predicate<Snapshot> removeIf)
TableMetadata	replaceCurrentSnapshot(Snapshot snapshot)
TableMetadata	replaceProperties(java.util.Map<java.lang.String,java.lang.String> newProperties)
Schema	schema()
Snapshot	snapshot(long snapshotId)
java.util.List<HistoryEntry>	snapshotLog()
java.util.List<Snapshot>	snapshots()
PartitionSpec	spec()
PartitionSpec	spec(int id)
java.util.List<PartitionSpec>	specs()
java.util.Map<java.lang.Integer,PartitionSpec>	specsById()
TableMetadata	updateLocation(java.lang.String newLocation)
TableMetadata	updatePartitionSpec(PartitionSpec newPartitionSpec)
TableMetadata	updateSchema(Schema newSchema, int newLastColumnId)
TableMetadata	upgradeToFormatVersion(int newFormatVersion)
java.lang.String	uuid()
TableMetadata	withUUID()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

newTableMetadata

@Deprecated
public static TableMetadata newTableMetadata(TableOperations ops,
                                             Schema schema,
                                             PartitionSpec spec,
                                             java.lang.String location,
                                             java.util.Map<java.lang.String,java.lang.String> properties)

Deprecated.

will be removed in 0.9.0; use newTableMetadata(Schema, PartitionSpec, String, Map) instead.

newTableMetadata

public static TableMetadata newTableMetadata(Schema schema,
                                             PartitionSpec spec,
                                             java.lang.String location,
                                             java.util.Map<java.lang.String,java.lang.String> properties)

formatVersion

public int formatVersion()

metadataFileLocation

public java.lang.String metadataFileLocation()

uuid

public java.lang.String uuid()

lastSequenceNumber

public long lastSequenceNumber()

nextSequenceNumber

public long nextSequenceNumber()

lastUpdatedMillis

public long lastUpdatedMillis()

lastColumnId

public int lastColumnId()

schema

public Schema schema()

spec

public PartitionSpec spec()

spec

public PartitionSpec spec(int id)

specs

public java.util.List<PartitionSpec> specs()

specsById

public java.util.Map<java.lang.Integer,PartitionSpec> specsById()

defaultSpecId

public int defaultSpecId()

location

public java.lang.String location()

properties

public java.util.Map<java.lang.String,java.lang.String> properties()

property

public java.lang.String property(java.lang.String property,
                                 java.lang.String defaultValue)

propertyAsBoolean

public boolean propertyAsBoolean(java.lang.String property,
                                 boolean defaultValue)

propertyAsInt

public int propertyAsInt(java.lang.String property,
                         int defaultValue)

propertyAsLong

public long propertyAsLong(java.lang.String property,
                           long defaultValue)

snapshot

public Snapshot snapshot(long snapshotId)

currentSnapshot

public Snapshot currentSnapshot()

snapshots

public java.util.List<Snapshot> snapshots()

snapshotLog

public java.util.List<HistoryEntry> snapshotLog()

previousFiles

public java.util.List<TableMetadata.MetadataLogEntry> previousFiles()

withUUID

public TableMetadata withUUID()

updateSchema

public TableMetadata updateSchema(Schema newSchema,
                                  int newLastColumnId)

updatePartitionSpec

public TableMetadata updatePartitionSpec(PartitionSpec newPartitionSpec)

addStagedSnapshot

public TableMetadata addStagedSnapshot(Snapshot snapshot)

replaceCurrentSnapshot

public TableMetadata replaceCurrentSnapshot(Snapshot snapshot)

removeSnapshotsIf

public TableMetadata removeSnapshotsIf(java.util.function.Predicate<Snapshot> removeIf)

replaceProperties

public TableMetadata replaceProperties(java.util.Map<java.lang.String,java.lang.String> newProperties)

removeSnapshotLogEntries

public TableMetadata removeSnapshotLogEntries(java.util.Set<java.lang.Long> snapshotIds)

buildReplacement

public TableMetadata buildReplacement(Schema updatedSchema,
                                      PartitionSpec updatedPartitionSpec,
                                      java.lang.String newLocation,
                                      java.util.Map<java.lang.String,java.lang.String> updatedProperties)

updateLocation

public TableMetadata updateLocation(java.lang.String newLocation)

upgradeToFormatVersion

public TableMetadata upgradeToFormatVersion(int newFormatVersion)