#589 - ElasticSearch, Transaction - rename DocStoreMode and batch size methods

This commit is contained in:
Robin Bygrave
2016-03-07 19:15:08 +13:00
parent a0609b1726
commit cf825f7ac4
7 changed files with 27 additions and 27 deletions
@@ -92,7 +92,7 @@ public interface Transaction extends Closeable {
* to control how that is sent to the document store.
* </p>
*/
void setDocStoreUpdateMode(DocStoreMode updateMode);
void setDocStoreMode(DocStoreMode mode);
/**
* Set the batch size to use for sending messages to the document store.
@@ -104,7 +104,7 @@ public interface Transaction extends Closeable {
* Setting this overrides the default of {@link DocStoreConfig#getBulkBatchSize()}
* </p>
*/
void setDocStoreUpdateBatchSize(int batchSize);
void setDocStoreBatchSize(int batchSize);
/**
* Explicitly turn off or on the cascading nature of save() and delete(). This
@@ -110,7 +110,7 @@ public class DocStoreConfig {
/**
* Set the default batch size to use for calls to the Bulk API.
* <p>
* The batch size can be set on a transaction via {@link com.avaje.ebean.Transaction#setDocStoreUpdateBatchSize(int)}.
* The batch size can be set on a transaction via {@link com.avaje.ebean.Transaction#setDocStoreBatchSize(int)}.
* </p>
*/
public void setBulkBatchSize(int bulkBatchSize) {
@@ -61,23 +61,23 @@ public class ScopedTransaction implements SpiTransaction {
}
@Override
public DocStoreMode getDocStoreUpdateMode() {
return transaction.getDocStoreUpdateMode();
public DocStoreMode getDocStoreMode() {
return transaction.getDocStoreMode();
}
@Override
public void setDocStoreUpdateMode(DocStoreMode mode) {
transaction.setDocStoreUpdateMode(mode);
public void setDocStoreMode(DocStoreMode mode) {
transaction.setDocStoreMode(mode);
}
@Override
public int getDocStoreBulkBatchSize() {
return transaction.getDocStoreBulkBatchSize();
public int getDocStoreBatchSize() {
return transaction.getDocStoreBatchSize();
}
@Override
public void setDocStoreUpdateBatchSize(int batchSize) {
transaction.setDocStoreUpdateBatchSize(batchSize);
public void setDocStoreBatchSize(int batchSize) {
transaction.setDocStoreBatchSize(batchSize);
}
@Override
@@ -109,13 +109,13 @@ public interface SpiTransaction extends Transaction {
* Returning 0 implies to use the system wide default batch size.
* </p>
*/
DocStoreMode getDocStoreUpdateMode();
DocStoreMode getDocStoreMode();
/**
* Return the batch size to us for ElasticSearch Bulk API calls
* as a result of this transaction.
*/
int getDocStoreBulkBatchSize();
int getDocStoreBatchSize();
/**
* Return the batchSize specifically set for this transaction or 0.
@@ -176,8 +176,8 @@ public final class PersistRequestBean<T> extends PersistRequest implements BeanP
* don't want to send to the doc store.
*/
private DocStoreMode calcDocStoreEvent(SpiTransaction txn, Type type) {
DocStoreMode docStoreMode = (txn == null) ? null : txn.getDocStoreUpdateMode();
return beanDescriptor.getDocStoreMode(type, docStoreMode);
DocStoreMode txnMode = (txn == null) ? null : txn.getDocStoreMode();
return beanDescriptor.getDocStoreMode(type, txnMode);
}
/**
@@ -147,9 +147,9 @@ public class JdbcTransaction implements SpiTransaction {
* The mode for updating doc store indexes for this transaction.
* Only set when you want to override the default behavior.
*/
protected DocStoreMode docStoreUpdateMode;
protected DocStoreMode docStoreMode;
protected int docStoreBulkBatchSize;
protected int docStoreBatchSize;
/**
* Create a new JdbcTransaction.
@@ -282,22 +282,22 @@ public class JdbcTransaction implements SpiTransaction {
}
@Override
public int getDocStoreBulkBatchSize() {
return docStoreBulkBatchSize;
public int getDocStoreBatchSize() {
return docStoreBatchSize;
}
@Override
public void setDocStoreUpdateBatchSize(int docStoreBulkBatchSize) {
this.docStoreBulkBatchSize = docStoreBulkBatchSize;
public void setDocStoreBatchSize(int docStoreBatchSize) {
this.docStoreBatchSize = docStoreBatchSize;
}
public DocStoreMode getDocStoreUpdateMode() {
return docStoreUpdateMode;
public DocStoreMode getDocStoreMode() {
return docStoreMode;
}
@Override
public void setDocStoreUpdateMode(DocStoreMode docStoreUpdateMode) {
this.docStoreUpdateMode = docStoreUpdateMode;
public void setDocStoreMode(DocStoreMode docStoreMode) {
this.docStoreMode = docStoreMode;
}
@Override
@@ -69,8 +69,8 @@ public final class PostCommitProcessing {
this.clusterManager = clusterManager;
this.manager = manager;
this.serverName = manager.getServerName();
this.txnDocStoreMode = transaction.getDocStoreUpdateMode();
this.txnDocStoreBatchSize = transaction.getDocStoreBulkBatchSize();
this.txnDocStoreMode = transaction.getDocStoreMode();
this.txnDocStoreBatchSize = transaction.getDocStoreBatchSize();
this.event = transaction.getEvent();
this.deleteByIdMap = event.getDeleteByIdMap();
this.persistBeanRequests = event.getPersistRequestBeans();