| Package | Description |
|---|---|
| org.apache.drill.exec.rpc | |
| org.apache.drill.exec.rpc.control | |
| org.apache.drill.exec.rpc.data | |
| org.apache.drill.exec.rpc.user |
| Modifier and Type | Interface and Description |
|---|---|
interface |
RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite> |
| Modifier and Type | Class and Description |
|---|---|
class |
FutureBitCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite> |
class |
ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite> |
class |
ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite> |
| Modifier and Type | Method and Description |
|---|---|
protected void |
BasicClient.connectAsClient(RpcConnectionHandler<CC> connectionListener,
HS handshakeValue,
String host,
int port) |
static <T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>> |
ConnectionMultiListener.newBuilder(RpcConnectionHandler<CC> connectionListener,
HS handshakeValue,
BC basicClient) |
protected abstract void |
BasicClient.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler,
List<String> serverAuthMechanisms)
Creates various instances needed to start the SASL handshake.
|
static <T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite> |
BitRpcUtility.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler,
List<String> serverAuthMechanisms,
CC connection,
BitConnectionConfig config,
CoordinationProtos.DrillbitEndpoint endpoint,
BasicClient<T,CC,HS,HR> client,
T saslRpcType)
Creates various instances needed to start the SASL handshake.
|
protected void |
BasicClient.startSaslHandshake(RpcConnectionHandler<CC> connectionHandler,
Map<String,?> saslProperties,
org.apache.hadoop.security.UserGroupInformation ugi,
AuthenticatorFactory authFactory,
T rpcType)
Main method which starts the SASL handshake for all client channels (user/data/control) once it's determined
after regular RPC handshake that authentication is required by server side.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
ControlTunnel.CancelQuery |
static class |
ControlTunnel.CustomMessageSender |
static class |
ControlTunnel.ReceiverFinished |
static class |
ControlTunnel.RequestProfile |
static class |
ControlTunnel.SendFragment |
static class |
ControlTunnel.SendFragmentStatus |
static class |
ControlTunnel.SignalFragment |
static class |
ControlTunnel.SyncCustomMessageSender |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ControlClient.prepareSaslHandshake(RpcConnectionHandler<ControlConnection> connectionHandler,
List<String> serverAuthMechanisms) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DataClient.prepareSaslHandshake(RpcConnectionHandler<DataClientConnection> connectionHandler,
List<String> serverAuthMechanisms) |
| Modifier and Type | Method and Description |
|---|---|
RpcConnectionHandler<UserClient.UserToBitConnection> |
QueryResultHandler.getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler) |
| Modifier and Type | Method and Description |
|---|---|
RpcConnectionHandler<UserClient.UserToBitConnection> |
QueryResultHandler.getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler) |
protected void |
UserClient.prepareSaslHandshake(RpcConnectionHandler<UserClient.UserToBitConnection> connectionHandler,
List<String> serverAuthMechanisms) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.