This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push:
new 2536c91 Remove WriteFlags from public API
2536c91 is described below
commit 2536c91fde3eefe8f426e4e91e05ccfa26294f03
Author: Sijie Guo <si...@apache.org>
AuthorDate: Tue Apr 10 00:03:36 2018 -0700
Remove WriteFlags from public API
Descriptions of the changes in this PR:
`DeferredSync` is not implemented at server side. So remove
`withWriteFlags` from builder API.
Author: Sijie Guo <si...@apache.org>
Reviewers: Enrico Olivelli <eolive...@gmail.com>
This closes #1324 from sijie/remove_write_flag
---
.../apache/bookkeeper/client/LedgerCreateOp.java | 10 ++++++++--
.../bookkeeper/client/api/CreateBuilder.java | 22 ----------------------
.../bookkeeper/client/MockBookKeeperTestCase.java | 4 ++--
.../client/api/BookKeeperBuildersTest.java | 6 +++---
4 files changed, 13 insertions(+), 29 deletions(-)
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerCreateOp.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerCreateOp.java
index aa6cd69..d6c77de 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerCreateOp.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerCreateOp.java
@@ -21,8 +21,10 @@
package org.apache.bookkeeper.client;
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
import java.security.GeneralSecurityException;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collections;
import java.util.EnumSet;
import java.util.List;
@@ -238,7 +240,7 @@ class LedgerCreateOp implements GenericCallback<Void> {
cb.createComplete(rc, lh, ctx);
}
- static class CreateBuilderImpl implements CreateBuilder {
+ public static class CreateBuilderImpl implements CreateBuilder {
private final BookKeeper bk;
private int builderEnsembleSize = 3;
@@ -260,12 +262,15 @@ class LedgerCreateOp implements GenericCallback<Void> {
return this;
}
- @Override
public CreateBuilder withWriteFlags(EnumSet<WriteFlag> writeFlags) {
this.builderWriteFlags = writeFlags;
return this;
}
+ public CreateBuilder withWriteFlags(WriteFlag... writeFlags) {
+ return withWriteFlags(EnumSet.copyOf(Arrays.asList(writeFlags)));
+ }
+
@Override
public CreateBuilder withWriteQuorumSize(int writeQuorumSize) {
this.builderWriteQuorumSize = writeQuorumSize;
@@ -278,6 +283,7 @@ class LedgerCreateOp implements GenericCallback<Void> {
return this;
}
+ @SuppressFBWarnings("EI_EXPOSE_REP2")
@Override
public CreateBuilder withPassword(byte[] password) {
this.builderPassword = password;
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateBuilder.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateBuilder.java
index aa6ad6d..cd5fd3d 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateBuilder.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateBuilder.java
@@ -20,8 +20,6 @@
*/
package org.apache.bookkeeper.client.api;
-import java.util.Arrays;
-import java.util.EnumSet;
import java.util.Map;
import org.apache.bookkeeper.common.annotation.InterfaceAudience.Public;
import org.apache.bookkeeper.common.annotation.InterfaceStability.Unstable;
@@ -94,26 +92,6 @@ public interface CreateBuilder extends
OpBuilder<WriteHandle> {
CreateBuilder withDigestType(DigestType digestType);
/**
- * Set write flags. Write wlags specify the behaviour of writes
- *
- * @param writeFlags the flags
- *
- * @return the builder itself
- */
- CreateBuilder withWriteFlags(EnumSet<WriteFlag> writeFlags);
-
- /**
- * Set write flags. Write wlags specify the behaviour of writes
- *
- * @param writeFlags the flags
- *
- * @return the builder itself
- */
- default CreateBuilder withWriteFlags(WriteFlag ... writeFlags) {
- return withWriteFlags(EnumSet.copyOf(Arrays.asList(writeFlags)));
- }
-
- /**
* Switch the ledger into 'Advanced' mode. A ledger used in Advanced mode
will explicitly generate the sequence of
* entry identifiers. Advanced ledgers can be created with a client side
defined ledgerId
*
diff --git
a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MockBookKeeperTestCase.java
b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MockBookKeeperTestCase.java
index 5efd7bd..f7ff436 100644
---
a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MockBookKeeperTestCase.java
+++
b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/MockBookKeeperTestCase.java
@@ -48,7 +48,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.apache.bookkeeper.client.BKException.BKDigestMatchException;
import org.apache.bookkeeper.client.BKException.Code;
-import org.apache.bookkeeper.client.api.CreateBuilder;
+import org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl;
import org.apache.bookkeeper.client.api.DeleteBuilder;
import org.apache.bookkeeper.client.api.OpenBuilder;
import org.apache.bookkeeper.common.util.OrderedExecutor;
@@ -209,7 +209,7 @@ public abstract class MockBookKeeperTestCase {
when(bk.getConf()).thenReturn(config);
}
- protected CreateBuilder newCreateLedgerOp() {
+ protected CreateBuilderImpl newCreateLedgerOp() {
return new LedgerCreateOp.CreateBuilderImpl(bk);
}
diff --git
a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/BookKeeperBuildersTest.java
b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/BookKeeperBuildersTest.java
index ddd9d4e..cac76d4 100644
---
a/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/BookKeeperBuildersTest.java
+++
b/bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/BookKeeperBuildersTest.java
@@ -225,12 +225,12 @@ public class BookKeeperBuildersTest extends
MockBookKeeperTestCase {
public void testCreateAdvLedgerWriteFlags() throws Exception {
setNewGeneratedLedgerId(ledgerId);
WriteAdvHandle writer = newCreateLedgerOp()
+ .withWriteFlags(writeFlagsDeferredSync)
.withAckQuorumSize(ackQuorumSize)
.withEnsembleSize(ensembleSize)
.withPassword(password)
.withWriteQuorumSize(writeQuorumSize)
.withCustomMetadata(customMetadata)
- .withWriteFlags(writeFlagsDeferredSync)
.makeAdv()
.execute()
.get();
@@ -248,12 +248,12 @@ public class BookKeeperBuildersTest extends
MockBookKeeperTestCase {
public void testCreateLedgerWriteFlags() throws Exception {
setNewGeneratedLedgerId(ledgerId);
WriteHandle writer = newCreateLedgerOp()
+ .withWriteFlags(writeFlagsDeferredSync)
.withAckQuorumSize(ackQuorumSize)
.withEnsembleSize(ensembleSize)
.withPassword(password)
.withWriteQuorumSize(writeQuorumSize)
.withCustomMetadata(customMetadata)
- .withWriteFlags(writeFlagsDeferredSync)
.execute()
.get();
assertEquals(ledgerId, writer.getId());
@@ -270,12 +270,12 @@ public class BookKeeperBuildersTest extends
MockBookKeeperTestCase {
public void testCreateLedgerWriteFlagsVarargs() throws Exception {
setNewGeneratedLedgerId(ledgerId);
WriteHandle writer = newCreateLedgerOp()
+ .withWriteFlags(DEFERRED_SYNC)
.withAckQuorumSize(ackQuorumSize)
.withEnsembleSize(ensembleSize)
.withPassword(password)
.withWriteQuorumSize(writeQuorumSize)
.withCustomMetadata(customMetadata)
- .withWriteFlags(DEFERRED_SYNC)
.execute()
.get();
assertEquals(ledgerId, writer.getId());
--
To stop receiving notification emails like this one, please contact
si...@apache.org.
