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
