amaliujia commented on a change in pull request #298:
URL: https://github.com/apache/incubator-ratis/pull/298#discussion_r530010628
##########
File path:
ratis-examples/src/main/java/org/apache/ratis/examples/filestore/FileStoreStateMachine.java
##########
@@ -153,6 +160,83 @@ public TransactionContext
startTransaction(RaftClientRequest request) throws IOE
return reply.thenApply(ExamplesProtos.ReadReplyProto::getData);
}
+ class LocalStream implements DataStream {
+ private final StateMachineDataChannel dataChannel;
+
+ LocalStream(String path) {
+ final Path root = files.getRoot();
+ final Path relative = Paths.get(path).normalize();
+ final Path full = root.resolve(relative).normalize().toAbsolutePath();
+ dataChannel = new FileStoreStateMachineDataChannel(full);
Review comment:
I will move this part to FileStore.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
