alluxio.master.table

Class Table

java.lang.Object

alluxio.master.table.Table

@NotThreadSafe
public class Table
extends Object

The table implementation which manages all the versions of the table.

Field Summary

Fields

Modifier and Type	Field and Description
static long	FIRST_VERSION

Method Summary

Modifier and Type	Method and Description
void	addPartitions(Table.AddTablePartitionsEntry entry) Add partitions to the current table.
static Table	create(Database database, Table.AddTableEntry entry)
static Table	create(Database database, UdbTable udbTable, Table previousTable)
String	getName()
Partition	getPartition(String spec)
List<Partition>	getPartitions()
long	getPreviousVersion()
Schema	getSchema()
List<ColumnStatisticsInfo>	getStatistics()
Table.AddTableEntry	getTableJournalProto()
List<Table.AddTablePartitionsEntry>	getTablePartitionsJournalProto()
List<TransformPlan>	getTransformPlans(TransformDefinition definition) Returns a list of plans to transform the table, according to the transformation definition.
long	getVersion()
boolean	shouldSync(UdbTable udbTable)
TableInfo	toProto()

Methods inherited from class java.lang.Object

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

Field Detail

FIRST_VERSION

public static final long FIRST_VERSION

See Also:

Constant Field Values

Method Detail

create

public static Table create(Database database,
                           UdbTable udbTable,
                           @Nullable
                           Table previousTable)

Parameters:

database - the database

udbTable - the udb table

previousTable - the previous table, or null if creating first version of table

Returns:

a new (or first) version of the table based on the udb table, or null if there no changes in the udb table

create

public static Table create(Database database,
                           Table.AddTableEntry entry)

Parameters:

database - the database

entry - the add table journal entry

Returns:

a new instance

addPartitions

public void addPartitions(Table.AddTablePartitionsEntry entry)

Add partitions to the current table.

Parameters:

entry - the add table partitions entry

getName

public String getName()

Returns:

the table name

getPartition

public Partition getPartition(String spec)

Parameters:

spec - the partition spec

Returns:

the corresponding partition

getPartitions

public List<Partition> getPartitions()

Returns:

the list of partitions

getSchema

public Schema getSchema()

Returns:

the table schema

getStatistics

public List<ColumnStatisticsInfo> getStatistics()

Returns:

the statistics

getVersion

public long getVersion()

Returns:

the table version

getPreviousVersion

public long getPreviousVersion()

Returns:

the previous table version

getTransformPlans

public List<TransformPlan> getTransformPlans(TransformDefinition definition)
                                      throws IOException

Returns a list of plans to transform the table, according to the transformation definition.

Parameters:

definition - the transformation definition

Returns:

a list of TransformPlan to transform this table

Throws:

IOException

shouldSync

public boolean shouldSync(UdbTable udbTable)

Parameters:

udbTable - the udb table to check against

Returns:

true if the table should be synced, because of differences in the udb table

toProto

public TableInfo toProto()

Returns:

the proto representation

getTableJournalProto

public Table.AddTableEntry getTableJournalProto()

Returns:

the journal proto representation

getTablePartitionsJournalProto

public List<Table.AddTablePartitionsEntry> getTablePartitionsJournalProto()

Returns:

the journal proto representation