public abstract class RowDecoder<C,R> extends Object
| Modifier | Constructor and Description |
|---|---|
protected |
RowDecoder(Collector<Row,C,R> collector) |
| Modifier and Type | Method and Description |
|---|---|
Throwable |
complete() |
protected abstract Row |
decodeRow(int len,
io.netty.buffer.ByteBuf in) |
void |
handleRow(int len,
io.netty.buffer.ByteBuf in) |
void |
reset() |
R |
result() |
int |
size() |
Copyright © 2020. All rights reserved.