public class SnappyCodec<IN,OUT> extends CompressionCodec<IN,OUT>
DEFAULT_DELIMITER, delimiter
Constructor and Description |
---|
SnappyCodec(Codec<Buffer,IN,OUT> delegate) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
createInputStream(InputStream parent) |
protected OutputStream |
createOutputStream(OutputStream parent) |
apply, decoder
decode, encode
addDelimiterIfAny, decoder, doBufferDecode, doDelimitedBufferDecode, encoder, invokeCallbackOrReturn
protected InputStream createInputStream(InputStream parent) throws IOException
createInputStream
in class CompressionCodec<IN,OUT>
IOException
protected OutputStream createOutputStream(OutputStream parent) throws IOException
createOutputStream
in class CompressionCodec<IN,OUT>
IOException
Copyright © 2016. All rights reserved.