java.lang.Object
org.elasticsearch.transport.InboundDecoder
- All Implemented Interfaces:
Closeable,AutoCloseable,Releasable
-
Nested Class Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionInboundDecoder(Recycler<org.apache.lucene.util.BytesRef> recycler) InboundDecoder(Recycler<org.apache.lucene.util.BytesRef> recycler, ByteSizeValue maxHeaderSize, InboundDecoder.ChannelType channelType) InboundDecoder(Recycler<org.apache.lucene.util.BytesRef> recycler, InboundDecoder.ChannelType channelType) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intdecode(ReleasableBytesReference reference, Consumer<Object> fragmentConsumer) intinternalDecode(ReleasableBytesReference reference, Consumer<Object> fragmentConsumer)
-
Constructor Details
-
InboundDecoder
-
InboundDecoder
public InboundDecoder(Recycler<org.apache.lucene.util.BytesRef> recycler, InboundDecoder.ChannelType channelType) -
InboundDecoder
public InboundDecoder(Recycler<org.apache.lucene.util.BytesRef> recycler, ByteSizeValue maxHeaderSize, InboundDecoder.ChannelType channelType)
-
-
Method Details
-
decode
public int decode(ReleasableBytesReference reference, Consumer<Object> fragmentConsumer) throws IOException - Throws:
IOException
-
internalDecode
public int internalDecode(ReleasableBytesReference reference, Consumer<Object> fragmentConsumer) throws IOException - Throws:
IOException
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceReleasable
-