Package io.delta.kernel.internal
Class ReplaceTableTransactionBuilderV2Impl
Object
io.delta.kernel.internal.ReplaceTableTransactionBuilderV2Impl
- All Implemented Interfaces:
ReplaceTableTransactionBuilder
public class ReplaceTableTransactionBuilderV2Impl
extends Object
implements ReplaceTableTransactionBuilder
-
Constructor Summary
ConstructorsConstructorDescriptionReplaceTableTransactionBuilderV2Impl(SnapshotImpl snapshot, StructType schema, String engineInfo) -
Method Summary
Modifier and TypeMethodDescriptionBuild the transaction for replacing the Delta table.Set the data layout specification for the new table definition.withMaxRetries(int maxRetries) Set the maximum number of retries to retry the commit in the case of a retryable error.withTableProperties(Map<String, String> properties) Set table properties for the new table definition.
-
Constructor Details
-
ReplaceTableTransactionBuilderV2Impl
public ReplaceTableTransactionBuilderV2Impl(SnapshotImpl snapshot, StructType schema, String engineInfo)
-
-
Method Details
-
withTableProperties
Description copied from interface:ReplaceTableTransactionBuilderSet table properties for the new table definition.- Specified by:
withTablePropertiesin interfaceReplaceTableTransactionBuilder- Parameters:
properties- A map of table property names to their values.
-
withDataLayoutSpec
Description copied from interface:ReplaceTableTransactionBuilderSet the data layout specification for the new table definition.- Specified by:
withDataLayoutSpecin interfaceReplaceTableTransactionBuilder- Parameters:
spec- The data layout specification.- See Also:
-
withMaxRetries
Description copied from interface:ReplaceTableTransactionBuilderSet the maximum number of retries to retry the commit in the case of a retryable error.- Specified by:
withMaxRetriesin interfaceReplaceTableTransactionBuilder- Parameters:
maxRetries- The maximum number of retries. Must be at least 0. Default is 200.
-
build
Description copied from interface:ReplaceTableTransactionBuilderBuild the transaction for replacing the Delta table.The transaction must be committed using
Transaction.commit(Engine, io.delta.kernel.utils.CloseableIterable)to apply the changes.- Specified by:
buildin interfaceReplaceTableTransactionBuilder- Parameters:
engine- TheEngineinstance to use for the transaction. Cannot be null.- Returns:
- A configured
Transactionfor replacing the table.
-