Package org.apache.iceberg.dell.ecs
Class EcsTableOperations
- java.lang.Object
-
- org.apache.iceberg.BaseMetastoreTableOperations
-
- org.apache.iceberg.dell.ecs.EcsTableOperations
-
- All Implemented Interfaces:
TableOperations
public class EcsTableOperations extends BaseMetastoreTableOperations
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.iceberg.BaseMetastoreTableOperations
BaseMetastoreTableOperations.CommitStatus
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
ICEBERG_METADATA_LOCATION
-
Fields inherited from class org.apache.iceberg.BaseMetastoreTableOperations
ICEBERG_TABLE_TYPE_VALUE, METADATA_LOCATION_PROP, PREVIOUS_METADATA_LOCATION_PROP, TABLE_TYPE_PROP
-
-
Constructor Summary
Constructors Constructor Description EcsTableOperations(java.lang.String tableName, org.apache.iceberg.dell.ecs.EcsURI tableObject, FileIO fileIO, EcsCatalog catalog)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doCommit(TableMetadata base, TableMetadata metadata)
protected void
doRefresh()
FileIO
io()
Returns aFileIO
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.-
Methods inherited from class org.apache.iceberg.BaseMetastoreTableOperations
checkCommitStatus, commit, current, currentMetadataLocation, currentVersion, disableRefresh, locationProvider, metadataFileLocation, refresh, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, requestRefresh, temp, writeNewMetadata, writeNewMetadataIfRequired
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.TableOperations
encryption, newSnapshotId, requireStrictCleanup
-
-
-
-
Field Detail
-
ICEBERG_METADATA_LOCATION
public static final java.lang.String ICEBERG_METADATA_LOCATION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
EcsTableOperations
public EcsTableOperations(java.lang.String tableName, org.apache.iceberg.dell.ecs.EcsURI tableObject, FileIO fileIO, EcsCatalog catalog)
-
-
Method Detail
-
tableName
protected java.lang.String tableName()
Description copied from class:BaseMetastoreTableOperations
The full name of the table used for logging purposes only. For example for HiveTableOperations it is catalogName + "." + database + "." + table.- Specified by:
tableName
in classBaseMetastoreTableOperations
- Returns:
- The full name
-
io
public FileIO io()
Description copied from interface:TableOperations
Returns aFileIO
to read and write table data and metadata files.
-
doRefresh
protected void doRefresh()
- Overrides:
doRefresh
in classBaseMetastoreTableOperations
-
doCommit
protected void doCommit(TableMetadata base, TableMetadata metadata)
- Overrides:
doCommit
in classBaseMetastoreTableOperations
-
-