Package | Description |
---|---|
org.apache.cassandra.transport |
Modifier and Type | Method and Description |
---|---|
Frame |
FrameCompressor.compress(Frame frame) |
Frame |
FrameCompressor.SnappyCompressor.compress(Frame frame) |
Frame |
FrameCompressor.LZ4Compressor.compress(Frame frame) |
static Frame |
Frame.create(Message.Type type,
int streamId,
ProtocolVersion version,
java.util.EnumSet<Frame.Header.Flag> flags,
io.netty.buffer.ByteBuf body) |
Frame |
FrameCompressor.decompress(Frame frame) |
Frame |
FrameCompressor.SnappyCompressor.decompress(Frame frame) |
Frame |
FrameCompressor.LZ4Compressor.decompress(Frame frame) |
Frame |
Message.getSourceFrame() |
Frame |
Frame.with(io.netty.buffer.ByteBuf newBody) |
Modifier and Type | Method and Description |
---|---|
Frame |
FrameCompressor.compress(Frame frame) |
Frame |
FrameCompressor.SnappyCompressor.compress(Frame frame) |
Frame |
FrameCompressor.LZ4Compressor.compress(Frame frame) |
void |
Message.ProtocolDecoder.decode(io.netty.channel.ChannelHandlerContext ctx,
Frame frame,
java.util.List results) |
void |
Frame.Decompressor.decode(io.netty.channel.ChannelHandlerContext ctx,
Frame frame,
java.util.List<java.lang.Object> results) |
Frame |
FrameCompressor.decompress(Frame frame) |
Frame |
FrameCompressor.SnappyCompressor.decompress(Frame frame) |
Frame |
FrameCompressor.LZ4Compressor.decompress(Frame frame) |
void |
Frame.Encoder.encode(io.netty.channel.ChannelHandlerContext ctx,
Frame frame,
java.util.List<java.lang.Object> results) |
void |
Frame.Compressor.encode(io.netty.channel.ChannelHandlerContext ctx,
Frame frame,
java.util.List<java.lang.Object> results) |
void |
Message.setSourceFrame(Frame sourceFrame) |
Copyright © 2018 The Apache Software Foundation