iotdb
iotdb copied to clipboard
FileNodeProcessor的action问题
FileNodeProcessor会向下传递三个action,在close的时候会用到
其中的两个:
close是同步操作,在recordWriter.close()之后可以结束,然后在FileNode的close函数中完成这两个操作,似乎没有必要下放到这里完成。
因为close操作是同步的,这两个操作确实不需要放到bufferwriteProcessor类中,但是在刷新rowgroup的时候同样需要调用这两个操作,是异步完成的。BufferWriteRecordWriter调用flushRowGroup函数的时候需要异步的刷新,所以bufferwriteCloseAction.act()和filenodeFlushAction.act()两个操作有必要下放到bufferwriteProcessor类中完成。