This is an automated email from the ASF dual-hosted git repository. hangxiang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 43a3d50ce39 [FLINK-34633][table] Support unnesting array constants add 369bbb8f925 [FLINK-35045][state] Introduce ForStFlinkFileSystem add 0cfbe4c95e0 [FLINK-35045][state] ForStFlinkFileSystem supports reading and writing with ByteBuffer add 7d004ca99a5 [FLINK-35045][state] Introduce input stream pool to improve the performance of readFully add a1476843d37 [FLINK-35045][state] Introduce ByteBufferReadable to support reading and positionable reading with ByteBuffer add a312a3bdd25 [FLINK-35045][state] Support ByteBufferReadable for HadoopDataInputStream No new revisions were added by this update. Summary of changes: .../apache/flink/core/fs/ByteBufferReadable.java | 75 ++++++++ ...ByteBufferReadableClosingFSDataInputStream.java | 45 ++--- .../flink/core/fs/ClosingFSDataInputStream.java | 7 +- .../runtime/fs/hdfs/HadoopDataInputStream.java | 58 +++++- .../fs/ByteBufferReadableFSDataInputStream.java | 213 +++++++++++++++++++++ .../fs/ByteBufferWritableFSDataOutputStream.java | 107 +++++++++++ .../flink/state/forst/fs/ForStFlinkFileSystem.java | 157 +++++++++++++++ .../state/forst/fs/ForStFlinkFileSystemTest.java | 165 ++++++++++++++++ 8 files changed, 795 insertions(+), 32 deletions(-) create mode 100644 flink-core/src/main/java/org/apache/flink/core/fs/ByteBufferReadable.java copy flink-runtime/src/main/java/org/apache/flink/runtime/util/ForwardingOutputStream.java => flink-core/src/main/java/org/apache/flink/core/fs/ByteBufferReadableClosingFSDataInputStream.java (51%) create mode 100644 flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java create mode 100644 flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java create mode 100644 flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java create mode 100644 flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystemTest.java