|
|
|
@ -61,9 +61,12 @@ public class BatchBuilderImpl implements BatchBuilder, Configurable, Manageable,
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public Batch buildBatch(BatchKey key, JdbcCoordinator jdbcCoordinator) { |
|
|
|
|
LOG.tracef( "Building batch [size=%s]", size ); |
|
|
|
|
return size > 1 |
|
|
|
|
? new BatchingBatch( key, jdbcCoordinator, size ) |
|
|
|
|
int batchSize = jdbcCoordinator.getJdbcSessionOwner().getJdbcBatchSize() > 1 |
|
|
|
|
? jdbcCoordinator.getJdbcSessionOwner().getJdbcBatchSize() |
|
|
|
|
: size; |
|
|
|
|
LOG.tracef( "Building batch [size=%s]", batchSize ); |
|
|
|
|
return batchSize > 1 |
|
|
|
|
? new BatchingBatch( key, jdbcCoordinator, batchSize ) |
|
|
|
|
: new NonBatchingBatch( key, jdbcCoordinator ); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|