Package org.apache.iceberg.dell.ecs
Class EcsTableOperations
- java.lang.Object
-
- org.apache.iceberg.BaseMetastoreOperations
-
- 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.BaseMetastoreOperations
BaseMetastoreOperations.CommitStatus
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.StringICEBERG_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 voiddoCommit(TableMetadata base, TableMetadata metadata)protected voiddoRefresh()FileIOio()Returns aFileIOto read and write table data and metadata files.protected java.lang.StringtableName()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 org.apache.iceberg.BaseMetastoreOperations
checkCommitStatus
-
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:BaseMetastoreTableOperationsThe full name of the table used for logging purposes only. For example for HiveTableOperations it is catalogName + "." + database + "." + table.- Specified by:
tableNamein classBaseMetastoreTableOperations- Returns:
- The full name
-
io
public FileIO io()
Description copied from interface:TableOperationsReturns aFileIOto read and write table data and metadata files.
-
doRefresh
protected void doRefresh()
- Overrides:
doRefreshin classBaseMetastoreTableOperations
-
doCommit
protected void doCommit(TableMetadata base, TableMetadata metadata)
- Overrides:
doCommitin classBaseMetastoreTableOperations
-
-