Uh oh!
There was an error while loading. Please reload this page.
HDDS-5666. Add option to createKey via streaming api in Freon - #2574
Conversation
f637b1e to
ce1d880Compare
captainzmc
left a comment
There was a problem hiding this comment.
Thanks @sadanand48 work on this. I left few comments.
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
There was a problem hiding this comment.
This line will conflict with the patch of EC. EC is currently voting on merge to master, so EC will merge into master soon. So can we continue this PR after EC merge?
There was a problem hiding this comment.
@sadanand48 , let's hardcode replicationConfig in createStreamKey(..) for the moment. We may change it later if there is a need.
private void createStreamKey(long counter) throws Exception {
final ReplicationConfig replicationConfig = ReplicationConfig
.fromProtoTypeAndFactor(HddsProtos.ReplicationType.RATIS,
HddsProtos.ReplicationFactor.THREE);
final String key = generateObjectName(counter);
timer.time(() -> {
try (OzoneDataStreamOutput stream = bucket
.createStreamKey(key, keySize, replicationConfig, metadata)) {
contentGenerator.write(stream);
}
return null;
});
}
b6f1921 to
f826d12Compareszetszwo
commented
Apr 6, 2022
@sadanand48 , there are conflicts. Could could you update the change? |
(cherry picked from commit f623bec992e80eda82e6155a3b20c476e683a3d6)
szetszwo
left a comment
There was a problem hiding this comment.
+1 the change looks good.
What changes were proposed in this pull request?
Add an option to createKey via streaming api in Freon via OzoneClientKeyGenerator.
What is the link to the Apache JIRA
https://issues.apache.org/jira/browse/HDDS-5666
How was this patch tested?
Tested the command via docker