@Override public TimeoutProcessorRequest getRequestData() throws IOException { TimeoutProcessorRequest.Builder builder = TimeoutProcessorRequest.newBuilder(); builder.setRow(ByteStringer.wrap(row)); return builder.build(); }
@Override public void initialize(TimeoutProcessorRequest msg) throws IOException { this.row = msg.getRow().toByteArray(); }
@Override public TimeoutProcessorRequest getRequestData() throws IOException { TimeoutProcessorRequest.Builder builder = TimeoutProcessorRequest.newBuilder(); builder.setRow(HBaseZeroCopyByteString.wrap(row)); return builder.build(); }
@Override public TimeoutProcessorRequest getRequestData() throws IOException { TimeoutProcessorRequest.Builder builder = TimeoutProcessorRequest.newBuilder(); builder.setRow(ZeroCopyLiteralByteString.wrap(row)); return builder.build(); }
@Override public TimeoutProcessorRequest getRequestData() throws IOException { TimeoutProcessorRequest.Builder builder = TimeoutProcessorRequest.newBuilder(); builder.setRow(ByteString.copyFrom(row)); return builder.build(); }