com.netflix.iceberg

Class TableMetadata

java.lang.Object

com.netflix.iceberg.TableMetadata

public class TableMetadata
extends java.lang.Object

Metadata for a table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableMetadata.SnapshotLogEntry

Method Summary

Modifier and Type	Method and Description
TableMetadata	addSnapshot(Snapshot snapshot)
TableMetadata	buildReplacement(Schema schema, PartitionSpec partitionSpec, java.util.Map<java.lang.String,java.lang.String> properties)
Snapshot	currentSnapshot()
InputFile	file()
int	lastColumnId()
long	lastUpdatedMillis()
java.lang.String	location()
static TableMetadata	newTableMetadata(TableOperations ops, Schema schema, PartitionSpec spec, java.lang.String location)
static TableMetadata	newTableMetadata(TableOperations ops, Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties)
java.util.Map<java.lang.String,java.lang.String>	properties()
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	replaceProperties(java.util.Map<java.lang.String,java.lang.String> newProperties)
TableMetadata	rollbackTo(Snapshot snapshot)
Schema	schema()
Snapshot	snapshot(long snapshotId)
java.util.List<TableMetadata.SnapshotLogEntry>	snapshotLog()
java.util.List<Snapshot>	snapshots()
PartitionSpec	spec()
TableMetadata	updateSchema(Schema schema, int lastColumnId)
TableMetadata	updateTableLocation(java.lang.String newLocation)

Methods inherited from class java.lang.Object

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

Method Detail

newTableMetadata

public static TableMetadata newTableMetadata(TableOperations ops,
                                             Schema schema,
                                             PartitionSpec spec,
                                             java.lang.String location)

newTableMetadata

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

file

public InputFile file()

lastUpdatedMillis

public long lastUpdatedMillis()

lastColumnId

public int lastColumnId()

schema

public Schema schema()

spec

public PartitionSpec spec()

location

public java.lang.String location()

properties

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

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<TableMetadata.SnapshotLogEntry> snapshotLog()

updateTableLocation

public TableMetadata updateTableLocation(java.lang.String newLocation)

updateSchema

public TableMetadata updateSchema(Schema schema,
                                  int lastColumnId)

addSnapshot

public TableMetadata addSnapshot(Snapshot snapshot)

removeSnapshotsIf

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

rollbackTo

public TableMetadata rollbackTo(Snapshot snapshot)

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 schema,
                                      PartitionSpec partitionSpec,
                                      java.util.Map<java.lang.String,java.lang.String> properties)