RowId¶
extractHighWatermark¶
extractHighWatermark(
snapshot: Snapshot): Option[Long]
extractHighWatermark
...FIXME
extractHighWatermark
is used when:
OptimisticTransactionImpl
is requested to commitImplRowId
is requested to assignFreshRowIds
isSupported¶
isSupported(
protocol: Protocol): Boolean
isSupported
isSupported with the given Protocol.
isSupported
is used when:
ConflictChecker
is requested to reassignOverlappingRowIdsRowId
is requested to isEnabled, assignFreshRowIds, checkStatsCollectedIfRowTrackingSupported
isEnabled¶
isEnabled(
protocol: Protocol,
metadata: Metadata): Boolean
isEnabled
holds true
when the following are all met:
- delta.enableRowTracking table property is enabled (in the given Metadata)
- Row Tracking feature is supported
RowTracking
This is an exact copy of RowTracking.isEnabled.
isEnabled
is used when:
RowId
is requested to verifyMetadata
assignFreshRowIds¶
assignFreshRowIds(
protocol: Protocol,
snapshot: Snapshot,
actions: Iterator[Action]): Iterator[Action]
assignFreshRowIds
...FIXME
assignFreshRowIds
is used when:
OptimisticTransactionImpl
is requested to commitLarge, prepareCommit
checkStatsCollectedIfRowTrackingSupported¶
checkStatsCollectedIfRowTrackingSupported(
protocol: Protocol,
convertToDeltaShouldCollectStats: Boolean,
statsCollectionEnabled: Boolean): Unit
Procedure
checkStatsCollectedIfRowTrackingSupported
is a procedure (returns Unit
) so what happens inside stays inside (paraphrasing the former advertising slogan of Las Vegas, Nevada).
checkStatsCollectedIfRowTrackingSupported
throws a DeltaIllegalStateException
when either the given convertToDeltaShouldCollectStats
or statsCollectionEnabled
flag are disabled (false
).
Otherwise, checkStatsCollectedIfRowTrackingSupported
does nothing.
checkStatsCollectedIfRowTrackingSupported
is used when:
ConvertToDeltaCommandBase
is requested to performConvert
verifyMetadata¶
verifyMetadata(
oldProtocol: Protocol,
newProtocol: Protocol,
oldMetadata: Metadata,
newMetadata: Metadata,
isCreatingNewTable: Boolean): Unit
Procedure
verifyMetadata
is a procedure (returns Unit
) so what happens inside stays inside (paraphrasing the former advertising slogan of Las Vegas, Nevada).
verifyMetadata
throws an UnsupportedOperationException
when...FIXME
verifyMetadata
is used when:
OptimisticTransactionImpl
is requested to updateMetadataInternal