You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/08/02 16:22:42 UTC
[pulsar] branch master updated: [fix] OffloadPoliciesImplBuilder
missing method and not implements OffloadPolicies.Builder (#11453)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b046233 [fix] OffloadPoliciesImplBuilder missing method and not implements OffloadPolicies.Builder (#11453)
b046233 is described below
commit b046233c898963cfb0b9da04e12db1465ce75876
Author: WJL3333 <wj...@163.com>
AuthorDate: Tue Aug 3 00:22:00 2021 +0800
[fix] OffloadPoliciesImplBuilder missing method and not implements OffloadPolicies.Builder (#11453)
* org.apache.pulsar.common.policies.data.OffloadPoliciesImplBuilder not implement OffloadPolicies.Builder
and missing the method setS3ManagedLedgerOffloadRoleSessionName
---
.../apache/pulsar/common/policies/data/OffloadPoliciesImpl.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java
index 9f1d74a..e1da6a1 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java
@@ -472,7 +472,7 @@ public class OffloadPoliciesImpl implements Serializable, OffloadPolicies {
return value((String) object, field);
}
- public static class OffloadPoliciesImplBuilder {
+ public static class OffloadPoliciesImplBuilder implements OffloadPolicies.Builder {
private OffloadPoliciesImpl impl = new OffloadPoliciesImpl();
public OffloadPoliciesImplBuilder offloadersDirectory(String offloadersDirectory) {
@@ -550,6 +550,12 @@ public class OffloadPoliciesImpl implements Serializable, OffloadPolicies {
return this;
}
+ @Override
+ public Builder setS3ManagedLedgerOffloadRoleSessionName(String s3ManagedLedgerOffloadRoleSessionName) {
+ impl.s3ManagedLedgerOffloadRoleSessionName = s3ManagedLedgerOffloadRoleSessionName;
+ return this;
+ }
+
public OffloadPoliciesImplBuilder s3ManagedLedgerOffloadRoleSessionName(String s3ManagedLedgerOffloadRoleSessionName) {
impl.s3ManagedLedgerOffloadRoleSessionName = s3ManagedLedgerOffloadRoleSessionName;
return this;