jun0315 commented on code in PR #8619:
URL: https://github.com/apache/iotdb/pull/8619#discussion_r1058487129
##########
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/FlushLevelProcessor.java:
##########
@@ -20,19 +20,26 @@
import org.apache.iotdb.lsm.context.requestcontext.FlushRequestContext;
+import java.io.IOException;
+
/** indicates the flush method of each layer of memory nodes */
-public abstract class FlushLevelProcessor<I, O>
- extends BasicLevelProcessor<I, O, Object, FlushRequestContext> {
+public abstract class FlushLevelProcessor<I, O, R>
+ extends BasicLevelProcessor<I, O, R, FlushRequestContext> {
/**
* the flush method of memory node
*
* @param memNode memory node
* @param context flush request context
*/
- public abstract void flush(I memNode, FlushRequestContext context);
+ public abstract void flush(I memNode, R flushRequest, FlushRequestContext
context)
+ throws IOException;
- public void handle(I memNode, Object request, FlushRequestContext context) {
- flush(memNode, context);
+ public void handle(I memNode, R request, FlushRequestContext context) {
+ try {
+ flush(memNode, request, context);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
Review Comment:
done
--
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.
To unsubscribe, e-mail: reviews-unsubscr...@iotdb.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
