public class ChunkedByteBuf extends Object implements org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
ByteBuf
instance to be consumed in chunks by ChunkedWriteHandler
, respecting
the high and low watermarks.Constructor and Description |
---|
ChunkedByteBuf(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf,
int chunkSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
isEndOfInput() |
long |
length() |
long |
progress() |
org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf |
readChunk(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBufAllocator byteBufAllocator) |
org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf |
readChunk(org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandlerContext ctx) |
String |
toString() |
public ChunkedByteBuf(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf, int chunkSize)
public boolean isEndOfInput() throws Exception
isEndOfInput
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
Exception
public void close() throws Exception
close
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
Exception
public org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf readChunk(org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandlerContext ctx) throws Exception
readChunk
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
Exception
public org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf readChunk(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBufAllocator byteBufAllocator) throws Exception
readChunk
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
Exception
public long length()
length
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
public long progress()
progress
in interface org.apache.paimon.shade.netty4.io.netty.handler.stream.ChunkedInput<org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.