(final byte server_version)
| 753 | } |
| 754 | |
| 755 | @Override |
| 756 | ChannelBuffer serialize(final byte server_version) { |
| 757 | if (server_version < SERVER_VERSION_095_OR_ABOVE) { |
| 758 | return serializeOld(server_version); |
| 759 | } |
| 760 | final ClientPB.Get getpb = ClientPB.Get.newBuilder() |
| 761 | .setRow(Bytes.wrap(row)) |
| 762 | .addColumn(FAM_INFO) // Fetch from one family only. |
| 763 | .setClosestRowBefore(true) |
| 764 | .build(); |
| 765 | final ClientPB.GetRequest get = ClientPB.GetRequest.newBuilder() |
| 766 | .setRegion(region.toProtobuf()) |
| 767 | .setGet(getpb) |
| 768 | .build(); |
| 769 | return toChannelBuffer(GetRequest.GGET, get); |
| 770 | } |
| 771 | |
| 772 | private ChannelBuffer serializeOld(final byte server_version) { |
| 773 | // region.length and row.length will use at most a 3-byte VLong. |
no test coverage detected