import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config, Executor executor) {
  return RpcConfig.newBuilder()
      .name("CONTROL")
      .executor(executor)
      .timeout(config.getInt(ExecConstants.BIT_RPC_TIMEOUT))
      .add(RpcType.HANDSHAKE, BitControlHandshake.class, RpcType.HANDSHAKE, BitControlHandshake.class)
      .add(RpcType.REQ_INITIALIZE_FRAGMENTS, InitializeFragments.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_CANCEL_FRAGMENT, FragmentHandle.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_QUERY_CANCEL, QueryId.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_RECEIVER_FINISHED, FinishedReceiver.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_FRAGMENT_STATUS, FragmentStatus.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_QUERY_STATUS, QueryId.class, RpcType.RESP_QUERY_STATUS, QueryProfile.class)
      .add(RpcType.REQ_UNPAUSE_FRAGMENT, FragmentHandle.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_CUSTOM, CustomMessage.class, RpcType.RESP_CUSTOM, CustomMessage.class)
      .add(RpcType.SASL_MESSAGE, SaslMessage.class, RpcType.SASL_MESSAGE, SaslMessage.class)
      .build();
}
 

import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config, Executor executor) {
  return RpcConfig.newBuilder()
      .name("USER")
      .timeout(config.getInt(ExecConstants.USER_RPC_TIMEOUT))
      .executor(executor)
      .add(RpcType.HANDSHAKE, UserToBitHandshake.class, RpcType.HANDSHAKE, BitToUserHandshake.class) // user to bit
      .add(RpcType.RUN_QUERY, RunQuery.class, RpcType.QUERY_HANDLE, QueryId.class) // user to bit
      .add(RpcType.CANCEL_QUERY, QueryId.class, RpcType.ACK, Ack.class) // user to bit
      .add(RpcType.QUERY_DATA, QueryData.class, RpcType.ACK, Ack.class) // bit to user
      .add(RpcType.QUERY_RESULT, QueryResult.class, RpcType.ACK, Ack.class) // bit to user
      .add(RpcType.RESUME_PAUSED_QUERY, QueryId.class, RpcType.ACK, Ack.class) // user to bit
      .add(RpcType.GET_QUERY_PLAN_FRAGMENTS, GetQueryPlanFragments.class,
        RpcType.QUERY_PLAN_FRAGMENTS, QueryPlanFragments.class) // user to bit
      .add(RpcType.GET_CATALOGS, GetCatalogsReq.class, RpcType.CATALOGS, GetCatalogsResp.class) // user to bit
      .add(RpcType.GET_SCHEMAS, GetSchemasReq.class, RpcType.SCHEMAS, GetSchemasResp.class) // user to bit
      .add(RpcType.GET_TABLES, GetTablesReq.class, RpcType.TABLES, GetTablesResp.class) // user to bit
      .add(RpcType.GET_COLUMNS, GetColumnsReq.class, RpcType.COLUMNS, GetColumnsResp.class) // user to bit
      .add(RpcType.CREATE_PREPARED_STATEMENT, CreatePreparedStatementReq.class,
          RpcType.PREPARED_STATEMENT, CreatePreparedStatementResp.class) // user to bit
      .add(RpcType.SASL_MESSAGE, SaslMessage.class, RpcType.SASL_MESSAGE, SaslMessage.class) // user <-> bit
      .add(RpcType.GET_SERVER_META, GetServerMetaReq.class, RpcType.SERVER_META, GetServerMetaResp.class) // user to bit
      .build();
}
 

import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config) {
  return RpcConfig.newBuilder()
      .name("CONTROL")
      .timeout(config.getInt(ExecConstants.BIT_RPC_TIMEOUT))
      .add(RpcType.HANDSHAKE, BitControlHandshake.class, RpcType.HANDSHAKE, BitControlHandshake.class)
      .add(RpcType.REQ_INITIALIZE_FRAGMENTS, InitializeFragments.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_CANCEL_FRAGMENT, FragmentHandle.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_QUERY_CANCEL, QueryId.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_RECEIVER_FINISHED, FinishedReceiver.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_FRAGMENT_STATUS, FragmentStatus.class, RpcType.ACK, Ack.class)
      .add(RpcType.REQ_QUERY_STATUS, QueryId.class, RpcType.RESP_QUERY_STATUS, QueryProfile.class)
      .add(RpcType.REQ_UNPAUSE_FRAGMENT, FragmentHandle.class, RpcType.ACK, Ack.class)
      .build();
}
 

import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config) {
  return RpcConfig.newBuilder()
      .name("DATA")
      .timeout(config.getInt(ExecConstants.BIT_RPC_TIMEOUT))
      .add(RpcType.HANDSHAKE, BitClientHandshake.class, RpcType.HANDSHAKE, BitServerHandshake.class)
      .add(RpcType.REQ_RECORD_BATCH, FragmentRecordBatch.class, RpcType.ACK, Ack.class)
      .build();
}
 

import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config) {
  return RpcConfig.newBuilder()
      .name("USER")
      .timeout(config.getInt(ExecConstants.USER_RPC_TIMEOUT))
      .add(RpcType.HANDSHAKE, UserToBitHandshake.class, RpcType.HANDSHAKE, BitToUserHandshake.class) // user to bit
      .add(RpcType.RUN_QUERY, RunQuery.class, RpcType.QUERY_HANDLE, QueryId.class) // user to bit
      .add(RpcType.CANCEL_QUERY, QueryId.class, RpcType.ACK, Ack.class) // user to bit
      .add(RpcType.QUERY_DATA, QueryData.class, RpcType.ACK, Ack.class) // bit to user
      .add(RpcType.QUERY_RESULT, QueryResult.class, RpcType.ACK, Ack.class) // bit to user
      .add(RpcType.RESUME_PAUSED_QUERY, QueryId.class, RpcType.ACK, Ack.class) // user to bit
      .build();
}
 

import org.apache.drill.exec.rpc.RpcConfig; //导入依赖的package包/类
public static RpcConfig getMapping(DrillConfig config, Executor executor) {
  return RpcConfig.newBuilder()
      .name("DATA")
      .executor(executor)
      .timeout(config.getInt(ExecConstants.BIT_RPC_TIMEOUT))
      .add(RpcType.HANDSHAKE, BitClientHandshake.class, RpcType.HANDSHAKE, BitServerHandshake.class)
      .add(RpcType.REQ_RECORD_BATCH, FragmentRecordBatch.class, RpcType.ACK, Ack.class)
      .add(RpcType.SASL_MESSAGE, SaslMessage.class, RpcType.SASL_MESSAGE, SaslMessage.class)
      .build();
}