public class EcsTableOperations extends BaseMetastoreTableOperations
BaseMetastoreTableOperations.CommitStatus
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ICEBERG_METADATA_LOCATION |
ICEBERG_TABLE_TYPE_VALUE, METADATA_LOCATION_PROP, PREVIOUS_METADATA_LOCATION_PROP, TABLE_TYPE_PROP
Constructor and Description |
---|
EcsTableOperations(java.lang.String tableName,
org.apache.iceberg.dell.ecs.EcsURI tableObject,
FileIO fileIO,
EcsCatalog catalog) |
Modifier and Type | Method and Description |
---|---|
protected void |
doCommit(TableMetadata base,
TableMetadata metadata) |
protected void |
doRefresh() |
FileIO |
io()
Returns a
FileIO to read and write table data and metadata files. |
protected java.lang.String |
tableName()
The full name of the table used for logging purposes only.
|
checkCommitStatus, commit, current, currentMetadataLocation, currentVersion, disableRefresh, locationProvider, metadataFileLocation, refresh, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, requestRefresh, temp, writeNewMetadata, writeNewMetadataIfRequired
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
encryption, newSnapshotId
public static final java.lang.String ICEBERG_METADATA_LOCATION
public EcsTableOperations(java.lang.String tableName, org.apache.iceberg.dell.ecs.EcsURI tableObject, FileIO fileIO, EcsCatalog catalog)
protected java.lang.String tableName()
BaseMetastoreTableOperations
tableName
in class BaseMetastoreTableOperations
public FileIO io()
TableOperations
FileIO
to read and write table data and metadata files.protected void doRefresh()
doRefresh
in class BaseMetastoreTableOperations
protected void doCommit(TableMetadata base, TableMetadata metadata)
doCommit
in class BaseMetastoreTableOperations