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 <[email protected]> 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;
