org.apache.hadoop.hbase.io.asyncfs

Class FanOutOneBlockAsyncDFSOutputSaslHelper.SaslNegotiateHandler.BuilderPayloadSetter

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutputSaslHelper.SaslNegotiateHandler.BuilderPayloadSetter

Enclosing class:

FanOutOneBlockAsyncDFSOutputSaslHelper.SaslNegotiateHandler

private static class FanOutOneBlockAsyncDFSOutputSaslHelper.SaslNegotiateHandler.BuilderPayloadSetter
extends Object

The asyncfs subsystem emulates a HDFS client by sending protobuf messages via netty. After Hadoop 3.3.0, the protobuf classes are relocated to org.apache.hadoop.thirdparty.protobuf.*. Use Reflection to check which ones to use.

Field Summary

Fields

Modifier and Type	Field and Description
private static Constructor<?>	constructor
private static Method	setPayloadMethod

Constructor Summary

Constructors

Modifier	Constructor and Description
private	BuilderPayloadSetter()

Method Summary

Modifier and Type	Method and Description
(package private) static void	wrapAndSetPayload(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.DataTransferEncryptorMessageProto.Builder builder, byte[] payload) Create a ByteString from byte array without copying (wrap), and then set it as the payload for the builder.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

setPayloadMethod

private static Method setPayloadMethod

constructor

private static Constructor<?> constructor

Constructor Detail

BuilderPayloadSetter

private BuilderPayloadSetter()

Method Detail

wrapAndSetPayload

static void wrapAndSetPayload(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.DataTransferEncryptorMessageProto.Builder builder,
                              byte[] payload)
                       throws IOException

Create a ByteString from byte array without copying (wrap), and then set it as the payload for the builder.

Parameters:

builder - builder for HDFS DataTransferEncryptorMessage.

payload - byte array of payload.

Throws:

IOException