@Override public RowSwapProcessorRequest getRequestData() throws IOException { RowSwapProcessorRequest.Builder builder = RowSwapProcessorRequest.newBuilder(); builder.setRow1(ByteStringer.wrap(row1)); builder.setRow2(ByteStringer.wrap(row2)); return builder.build(); }
@Override public RowSwapProcessorRequest getRequestData() throws IOException { RowSwapProcessorRequest.Builder builder = RowSwapProcessorRequest.newBuilder(); builder.setRow1(HBaseZeroCopyByteString.wrap(row1)); builder.setRow2(HBaseZeroCopyByteString.wrap(row2)); return builder.build(); }
@Override public RowSwapProcessorRequest getRequestData() throws IOException { RowSwapProcessorRequest.Builder builder = RowSwapProcessorRequest.newBuilder(); builder.setRow1(ZeroCopyLiteralByteString.wrap(row1)); builder.setRow2(ZeroCopyLiteralByteString.wrap(row2)); return builder.build(); }
@Override public RowSwapProcessorRequest getRequestData() throws IOException { RowSwapProcessorRequest.Builder builder = RowSwapProcessorRequest.newBuilder(); builder.setRow1(ByteString.copyFrom(row1)); builder.setRow2(ByteString.copyFrom(row2)); return builder.build(); }
@Override public void initialize(RowSwapProcessorRequest msg) { this.row1 = msg.getRow1().toByteArray(); this.row2 = msg.getRow2().toByteArray(); }