Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: apache/hive
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 754edc2b227d805b956817de06a0312a23e29a5d
Choose a base ref
..
head repository: apache/hive
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: b95efa4127a0084dc2e32f4eb4560f9fce665b86
Choose a head ref
Original file line number Diff line number Diff line change
@@ -1173,10 +1173,10 @@ private List<String> getTxnDbsUpdated(long txnId) throws MetaException {
}

/**
* Returns the databases & writeID updated by txnId.
* Returns the databases and writeID updated by txnId.
* Queries TXN_TO_WRITE_ID using txnId.
*
* @param txnId
* @param txnId Transaction ID for which write IDs are requested.
* @throws MetaException
*/
public List<TxnWriteDetails> getWriteIdsForTxnID(long txnId) throws MetaException {
Original file line number Diff line number Diff line change
@@ -587,9 +587,9 @@ private void updateWSCommitIdAndCleanUpMetadata(MultiDataSourceJdbcResource jdbc
/**
* Create Notifiaction Events on txn commit
*
* @param txnid committed txn
* @param txnType transaction type
* @param txnWriteDetails
* @param txnid committed txn
* @param txnType transaction type
* @param txnWriteDetails write details of the transaction
* @throws MetaException ex
*/
private void createCommitNotificationEvent(MultiDataSourceJdbcResource jdbcResource, long txnid, TxnType txnType, List<TxnWriteDetails> txnWriteDetails)
Original file line number Diff line number Diff line change
@@ -31,7 +31,7 @@
import java.util.List;

/**
* Returns the databases & writeID updated by txnId.
* Returns the databases and writeID updated by txnId.
* Queries TXN_TO_WRITE_ID using txnId.
*/
public class GetWriteIdsForTxnIDHandler implements QueryHandler<List<TxnWriteDetails>> {