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, writeNewMetadataIfRequiredclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitencryption, newSnapshotIdpublic 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()
BaseMetastoreTableOperationstableName in class BaseMetastoreTableOperationspublic FileIO io()
TableOperationsFileIO to read and write table data and metadata files.protected void doRefresh()
doRefresh in class BaseMetastoreTableOperationsprotected void doCommit(TableMetadata base, TableMetadata metadata)
doCommit in class BaseMetastoreTableOperations