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/04 13:02:10 UTC
[pulsar] 01/09: [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 branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit fb117f535ff4025703e107a57cb7e4348e7b2e92
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
(cherry picked from commit b046233c898963cfb0b9da04e12db1465ce75876)
---
.../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 f7f4477..68761a6 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;