Fixup batch method naming

This commit is contained in:
Christian Beikov 2022-12-14 19:26:07 +01:00
parent 3c287d4429
commit 6777f4f7ac
4 changed files with 4 additions and 4 deletions

View File

@ -172,7 +172,7 @@ public class JdbcCoordinatorImpl implements JdbcCoordinator {
}
@Override
public Batch getBatch2(BatchKey key, Integer batchSize, Supplier<PreparedStatementGroup> statementGroupSupplier) {
public Batch getBatch(BatchKey key, Integer batchSize, Supplier<PreparedStatementGroup> statementGroupSupplier) {
if ( currentBatch != null ) {
if ( currentBatch.getKey().equals( key ) ) {
return currentBatch;

View File

@ -44,7 +44,7 @@ public class MutationExecutorSingleBatched extends AbstractSingleMutationExecuto
private Batch resolveBatch() {
if ( batch == null ) {
batch = session.getJdbcCoordinator().getBatch2(
batch = session.getJdbcCoordinator().getBatch(
batchKey,
batchSize,
() -> new PreparedStatementGroupSingleTable( getMutationOperation(), session )

View File

@ -127,7 +127,7 @@ public class MutationExecutorStandard extends AbstractMutationExecutor {
}
else {
final List<PreparableMutationOperation> batchedMutationsRef = batchedJdbcMutations;
this.batch = session.getJdbcCoordinator().getBatch2(
this.batch = session.getJdbcCoordinator().getBatch(
batchKey,
batchSize,
() -> ModelMutationHelper.toPreparedStatementGroup(

View File

@ -49,7 +49,7 @@ public interface JdbcCoordinator extends Serializable, TransactionCoordinatorOwn
*
* @implNote Any previous Batch is executed and released prior to returning
*/
Batch getBatch2(
Batch getBatch(
BatchKey key,
Integer batchSize,
Supplier<PreparedStatementGroup> statementGroupSupplier);