MetaServiceGrpc.java

package org.apache.doris.cloud.proto;

import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;
import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;

/**
 */
@javax.annotation.Generated(
    value = "by gRPC proto compiler (version 1.34.0)",
    comments = "Source: cloud.proto")
public final class MetaServiceGrpc {

  private MetaServiceGrpc() {}

  public static final String SERVICE_NAME = "doris.cloud.MetaService";

  // Static method descriptors that strictly reflect the proto.
  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginTxnRequest,
      org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> getBeginTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "begin_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.BeginTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.BeginTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginTxnRequest,
      org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> getBeginTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginTxnRequest, org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> getBeginTxnMethod;
    if ((getBeginTxnMethod = MetaServiceGrpc.getBeginTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getBeginTxnMethod = MetaServiceGrpc.getBeginTxnMethod) == null) {
          MetaServiceGrpc.getBeginTxnMethod = getBeginTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.BeginTxnRequest, org.apache.doris.cloud.proto.Cloud.BeginTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "begin_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("begin_txn"))
              .build();
        }
      }
    }
    return getBeginTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest,
      org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> getPrecommitTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "precommit_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest,
      org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> getPrecommitTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest, org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> getPrecommitTxnMethod;
    if ((getPrecommitTxnMethod = MetaServiceGrpc.getPrecommitTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getPrecommitTxnMethod = MetaServiceGrpc.getPrecommitTxnMethod) == null) {
          MetaServiceGrpc.getPrecommitTxnMethod = getPrecommitTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest, org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "precommit_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("precommit_txn"))
              .build();
        }
      }
    }
    return getPrecommitTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CommitTxnRequest,
      org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> getCommitTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "commit_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.CommitTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CommitTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CommitTxnRequest,
      org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> getCommitTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CommitTxnRequest, org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> getCommitTxnMethod;
    if ((getCommitTxnMethod = MetaServiceGrpc.getCommitTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCommitTxnMethod = MetaServiceGrpc.getCommitTxnMethod) == null) {
          MetaServiceGrpc.getCommitTxnMethod = getCommitTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CommitTxnRequest, org.apache.doris.cloud.proto.Cloud.CommitTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "commit_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CommitTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CommitTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("commit_txn"))
              .build();
        }
      }
    }
    return getCommitTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnRequest,
      org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> getAbortTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "abort_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.AbortTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AbortTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnRequest,
      org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> getAbortTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnRequest, org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> getAbortTxnMethod;
    if ((getAbortTxnMethod = MetaServiceGrpc.getAbortTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAbortTxnMethod = MetaServiceGrpc.getAbortTxnMethod) == null) {
          MetaServiceGrpc.getAbortTxnMethod = getAbortTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AbortTxnRequest, org.apache.doris.cloud.proto.Cloud.AbortTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "abort_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("abort_txn"))
              .build();
        }
      }
    }
    return getAbortTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnRequest,
      org.apache.doris.cloud.proto.Cloud.GetTxnResponse> getGetTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.GetTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnRequest,
      org.apache.doris.cloud.proto.Cloud.GetTxnResponse> getGetTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnRequest, org.apache.doris.cloud.proto.Cloud.GetTxnResponse> getGetTxnMethod;
    if ((getGetTxnMethod = MetaServiceGrpc.getGetTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetTxnMethod = MetaServiceGrpc.getGetTxnMethod) == null) {
          MetaServiceGrpc.getGetTxnMethod = getGetTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetTxnRequest, org.apache.doris.cloud.proto.Cloud.GetTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_txn"))
              .build();
        }
      }
    }
    return getGetTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest,
      org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> getGetCurrentMaxTxnIdMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_current_max_txn_id",
      requestType = org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest,
      org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> getGetCurrentMaxTxnIdMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest, org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> getGetCurrentMaxTxnIdMethod;
    if ((getGetCurrentMaxTxnIdMethod = MetaServiceGrpc.getGetCurrentMaxTxnIdMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetCurrentMaxTxnIdMethod = MetaServiceGrpc.getGetCurrentMaxTxnIdMethod) == null) {
          MetaServiceGrpc.getGetCurrentMaxTxnIdMethod = getGetCurrentMaxTxnIdMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest, org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_current_max_txn_id"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_current_max_txn_id"))
              .build();
        }
      }
    }
    return getGetCurrentMaxTxnIdMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest,
      org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> getCheckTxnConflictMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "check_txn_conflict",
      requestType = org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest,
      org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> getCheckTxnConflictMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest, org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> getCheckTxnConflictMethod;
    if ((getCheckTxnConflictMethod = MetaServiceGrpc.getCheckTxnConflictMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCheckTxnConflictMethod = MetaServiceGrpc.getCheckTxnConflictMethod) == null) {
          MetaServiceGrpc.getCheckTxnConflictMethod = getCheckTxnConflictMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest, org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "check_txn_conflict"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("check_txn_conflict"))
              .build();
        }
      }
    }
    return getCheckTxnConflictMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest,
      org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> getCleanTxnLabelMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "clean_txn_label",
      requestType = org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest,
      org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> getCleanTxnLabelMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest, org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> getCleanTxnLabelMethod;
    if ((getCleanTxnLabelMethod = MetaServiceGrpc.getCleanTxnLabelMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCleanTxnLabelMethod = MetaServiceGrpc.getCleanTxnLabelMethod) == null) {
          MetaServiceGrpc.getCleanTxnLabelMethod = getCleanTxnLabelMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest, org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "clean_txn_label"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("clean_txn_label"))
              .build();
        }
      }
    }
    return getCleanTxnLabelMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest,
      org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> getGetTxnIdMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_txn_id",
      requestType = org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest,
      org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> getGetTxnIdMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest, org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> getGetTxnIdMethod;
    if ((getGetTxnIdMethod = MetaServiceGrpc.getGetTxnIdMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetTxnIdMethod = MetaServiceGrpc.getGetTxnIdMethod) == null) {
          MetaServiceGrpc.getGetTxnIdMethod = getGetTxnIdMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest, org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_txn_id"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_txn_id"))
              .build();
        }
      }
    }
    return getGetTxnIdMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest,
      org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> getBeginSubTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "begin_sub_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest,
      org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> getBeginSubTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest, org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> getBeginSubTxnMethod;
    if ((getBeginSubTxnMethod = MetaServiceGrpc.getBeginSubTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getBeginSubTxnMethod = MetaServiceGrpc.getBeginSubTxnMethod) == null) {
          MetaServiceGrpc.getBeginSubTxnMethod = getBeginSubTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest, org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "begin_sub_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("begin_sub_txn"))
              .build();
        }
      }
    }
    return getBeginSubTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest,
      org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> getAbortSubTxnMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "abort_sub_txn",
      requestType = org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest,
      org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> getAbortSubTxnMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest, org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> getAbortSubTxnMethod;
    if ((getAbortSubTxnMethod = MetaServiceGrpc.getAbortSubTxnMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAbortSubTxnMethod = MetaServiceGrpc.getAbortSubTxnMethod) == null) {
          MetaServiceGrpc.getAbortSubTxnMethod = getAbortSubTxnMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest, org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "abort_sub_txn"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("abort_sub_txn"))
              .build();
        }
      }
    }
    return getAbortSubTxnMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest,
      org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> getAbortTxnWithCoordinatorMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "abort_txn_with_coordinator",
      requestType = org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest,
      org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> getAbortTxnWithCoordinatorMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest, org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> getAbortTxnWithCoordinatorMethod;
    if ((getAbortTxnWithCoordinatorMethod = MetaServiceGrpc.getAbortTxnWithCoordinatorMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAbortTxnWithCoordinatorMethod = MetaServiceGrpc.getAbortTxnWithCoordinatorMethod) == null) {
          MetaServiceGrpc.getAbortTxnWithCoordinatorMethod = getAbortTxnWithCoordinatorMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest, org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "abort_txn_with_coordinator"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("abort_txn_with_coordinator"))
              .build();
        }
      }
    }
    return getAbortTxnWithCoordinatorMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetVersionRequest,
      org.apache.doris.cloud.proto.Cloud.GetVersionResponse> getGetVersionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_version",
      requestType = org.apache.doris.cloud.proto.Cloud.GetVersionRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetVersionResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetVersionRequest,
      org.apache.doris.cloud.proto.Cloud.GetVersionResponse> getGetVersionMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetVersionRequest, org.apache.doris.cloud.proto.Cloud.GetVersionResponse> getGetVersionMethod;
    if ((getGetVersionMethod = MetaServiceGrpc.getGetVersionMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetVersionMethod = MetaServiceGrpc.getGetVersionMethod) == null) {
          MetaServiceGrpc.getGetVersionMethod = getGetVersionMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetVersionRequest, org.apache.doris.cloud.proto.Cloud.GetVersionResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_version"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetVersionRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetVersionResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_version"))
              .build();
        }
      }
    }
    return getGetVersionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest,
      org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> getCreateTabletsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "create_tablets",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest,
      org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> getCreateTabletsMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest, org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> getCreateTabletsMethod;
    if ((getCreateTabletsMethod = MetaServiceGrpc.getCreateTabletsMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCreateTabletsMethod = MetaServiceGrpc.getCreateTabletsMethod) == null) {
          MetaServiceGrpc.getCreateTabletsMethod = getCreateTabletsMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest, org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "create_tablets"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("create_tablets"))
              .build();
        }
      }
    }
    return getCreateTabletsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> getUpdateTabletMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "update_tablet",
      requestType = org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> getUpdateTabletMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest, org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> getUpdateTabletMethod;
    if ((getUpdateTabletMethod = MetaServiceGrpc.getUpdateTabletMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getUpdateTabletMethod = MetaServiceGrpc.getUpdateTabletMethod) == null) {
          MetaServiceGrpc.getUpdateTabletMethod = getUpdateTabletMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest, org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "update_tablet"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("update_tablet"))
              .build();
        }
      }
    }
    return getUpdateTabletMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> getUpdateTabletSchemaMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "update_tablet_schema",
      requestType = org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> getUpdateTabletSchemaMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest, org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> getUpdateTabletSchemaMethod;
    if ((getUpdateTabletSchemaMethod = MetaServiceGrpc.getUpdateTabletSchemaMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getUpdateTabletSchemaMethod = MetaServiceGrpc.getUpdateTabletSchemaMethod) == null) {
          MetaServiceGrpc.getUpdateTabletSchemaMethod = getUpdateTabletSchemaMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest, org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "update_tablet_schema"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("update_tablet_schema"))
              .build();
        }
      }
    }
    return getUpdateTabletSchemaMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletRequest,
      org.apache.doris.cloud.proto.Cloud.GetTabletResponse> getGetTabletMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_tablet",
      requestType = org.apache.doris.cloud.proto.Cloud.GetTabletRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetTabletResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletRequest,
      org.apache.doris.cloud.proto.Cloud.GetTabletResponse> getGetTabletMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletRequest, org.apache.doris.cloud.proto.Cloud.GetTabletResponse> getGetTabletMethod;
    if ((getGetTabletMethod = MetaServiceGrpc.getGetTabletMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetTabletMethod = MetaServiceGrpc.getGetTabletMethod) == null) {
          MetaServiceGrpc.getGetTabletMethod = getGetTabletMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetTabletRequest, org.apache.doris.cloud.proto.Cloud.GetTabletResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_tablet"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTabletRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTabletResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_tablet"))
              .build();
        }
      }
    }
    return getGetTabletMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getPrepareRowsetMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "prepare_rowset",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getPrepareRowsetMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getPrepareRowsetMethod;
    if ((getPrepareRowsetMethod = MetaServiceGrpc.getPrepareRowsetMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getPrepareRowsetMethod = MetaServiceGrpc.getPrepareRowsetMethod) == null) {
          MetaServiceGrpc.getPrepareRowsetMethod = getPrepareRowsetMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "prepare_rowset"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("prepare_rowset"))
              .build();
        }
      }
    }
    return getPrepareRowsetMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getCommitRowsetMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "commit_rowset",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getCommitRowsetMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getCommitRowsetMethod;
    if ((getCommitRowsetMethod = MetaServiceGrpc.getCommitRowsetMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCommitRowsetMethod = MetaServiceGrpc.getCommitRowsetMethod) == null) {
          MetaServiceGrpc.getCommitRowsetMethod = getCommitRowsetMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "commit_rowset"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("commit_rowset"))
              .build();
        }
      }
    }
    return getCommitRowsetMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getUpdateTmpRowsetMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "update_tmp_rowset",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getUpdateTmpRowsetMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> getUpdateTmpRowsetMethod;
    if ((getUpdateTmpRowsetMethod = MetaServiceGrpc.getUpdateTmpRowsetMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getUpdateTmpRowsetMethod = MetaServiceGrpc.getUpdateTmpRowsetMethod) == null) {
          MetaServiceGrpc.getUpdateTmpRowsetMethod = getUpdateTmpRowsetMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest, org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "update_tmp_rowset"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("update_tmp_rowset"))
              .build();
        }
      }
    }
    return getUpdateTmpRowsetMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> getGetRowsetMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_rowset",
      requestType = org.apache.doris.cloud.proto.Cloud.GetRowsetRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetRowsetResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRowsetRequest,
      org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> getGetRowsetMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRowsetRequest, org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> getGetRowsetMethod;
    if ((getGetRowsetMethod = MetaServiceGrpc.getGetRowsetMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetRowsetMethod = MetaServiceGrpc.getGetRowsetMethod) == null) {
          MetaServiceGrpc.getGetRowsetMethod = getGetRowsetMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetRowsetRequest, org.apache.doris.cloud.proto.Cloud.GetRowsetResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_rowset"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetRowsetRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetRowsetResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_rowset"))
              .build();
        }
      }
    }
    return getGetRowsetMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest,
      org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> getGetSchemaDictMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_schema_dict",
      requestType = org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest,
      org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> getGetSchemaDictMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest, org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> getGetSchemaDictMethod;
    if ((getGetSchemaDictMethod = MetaServiceGrpc.getGetSchemaDictMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetSchemaDictMethod = MetaServiceGrpc.getGetSchemaDictMethod) == null) {
          MetaServiceGrpc.getGetSchemaDictMethod = getGetSchemaDictMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest, org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_schema_dict"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_schema_dict"))
              .build();
        }
      }
    }
    return getGetSchemaDictMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getPrepareIndexMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "prepare_index",
      requestType = org.apache.doris.cloud.proto.Cloud.IndexRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.IndexResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getPrepareIndexMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse> getPrepareIndexMethod;
    if ((getPrepareIndexMethod = MetaServiceGrpc.getPrepareIndexMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getPrepareIndexMethod = MetaServiceGrpc.getPrepareIndexMethod) == null) {
          MetaServiceGrpc.getPrepareIndexMethod = getPrepareIndexMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "prepare_index"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("prepare_index"))
              .build();
        }
      }
    }
    return getPrepareIndexMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getCommitIndexMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "commit_index",
      requestType = org.apache.doris.cloud.proto.Cloud.IndexRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.IndexResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getCommitIndexMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse> getCommitIndexMethod;
    if ((getCommitIndexMethod = MetaServiceGrpc.getCommitIndexMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCommitIndexMethod = MetaServiceGrpc.getCommitIndexMethod) == null) {
          MetaServiceGrpc.getCommitIndexMethod = getCommitIndexMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "commit_index"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("commit_index"))
              .build();
        }
      }
    }
    return getCommitIndexMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getDropIndexMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "drop_index",
      requestType = org.apache.doris.cloud.proto.Cloud.IndexRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.IndexResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest,
      org.apache.doris.cloud.proto.Cloud.IndexResponse> getDropIndexMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse> getDropIndexMethod;
    if ((getDropIndexMethod = MetaServiceGrpc.getDropIndexMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getDropIndexMethod = MetaServiceGrpc.getDropIndexMethod) == null) {
          MetaServiceGrpc.getDropIndexMethod = getDropIndexMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.IndexRequest, org.apache.doris.cloud.proto.Cloud.IndexResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "drop_index"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.IndexResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("drop_index"))
              .build();
        }
      }
    }
    return getDropIndexMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getPreparePartitionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "prepare_partition",
      requestType = org.apache.doris.cloud.proto.Cloud.PartitionRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.PartitionResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getPreparePartitionMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse> getPreparePartitionMethod;
    if ((getPreparePartitionMethod = MetaServiceGrpc.getPreparePartitionMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getPreparePartitionMethod = MetaServiceGrpc.getPreparePartitionMethod) == null) {
          MetaServiceGrpc.getPreparePartitionMethod = getPreparePartitionMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "prepare_partition"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("prepare_partition"))
              .build();
        }
      }
    }
    return getPreparePartitionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getCommitPartitionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "commit_partition",
      requestType = org.apache.doris.cloud.proto.Cloud.PartitionRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.PartitionResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getCommitPartitionMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse> getCommitPartitionMethod;
    if ((getCommitPartitionMethod = MetaServiceGrpc.getCommitPartitionMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCommitPartitionMethod = MetaServiceGrpc.getCommitPartitionMethod) == null) {
          MetaServiceGrpc.getCommitPartitionMethod = getCommitPartitionMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "commit_partition"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("commit_partition"))
              .build();
        }
      }
    }
    return getCommitPartitionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getDropPartitionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "drop_partition",
      requestType = org.apache.doris.cloud.proto.Cloud.PartitionRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.PartitionResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest,
      org.apache.doris.cloud.proto.Cloud.PartitionResponse> getDropPartitionMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse> getDropPartitionMethod;
    if ((getDropPartitionMethod = MetaServiceGrpc.getDropPartitionMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getDropPartitionMethod = MetaServiceGrpc.getDropPartitionMethod) == null) {
          MetaServiceGrpc.getDropPartitionMethod = getDropPartitionMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.PartitionRequest, org.apache.doris.cloud.proto.Cloud.PartitionResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "drop_partition"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.PartitionResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("drop_partition"))
              .build();
        }
      }
    }
    return getDropPartitionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest,
      org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> getStartTabletJobMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "start_tablet_job",
      requestType = org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest,
      org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> getStartTabletJobMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest, org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> getStartTabletJobMethod;
    if ((getStartTabletJobMethod = MetaServiceGrpc.getStartTabletJobMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getStartTabletJobMethod = MetaServiceGrpc.getStartTabletJobMethod) == null) {
          MetaServiceGrpc.getStartTabletJobMethod = getStartTabletJobMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest, org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "start_tablet_job"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("start_tablet_job"))
              .build();
        }
      }
    }
    return getStartTabletJobMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest,
      org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> getFinishTabletJobMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "finish_tablet_job",
      requestType = org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest,
      org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> getFinishTabletJobMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest, org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> getFinishTabletJobMethod;
    if ((getFinishTabletJobMethod = MetaServiceGrpc.getFinishTabletJobMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getFinishTabletJobMethod = MetaServiceGrpc.getFinishTabletJobMethod) == null) {
          MetaServiceGrpc.getFinishTabletJobMethod = getFinishTabletJobMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest, org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "finish_tablet_job"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("finish_tablet_job"))
              .build();
        }
      }
    }
    return getFinishTabletJobMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest,
      org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> getHttpMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "http",
      requestType = org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest,
      org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> getHttpMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest, org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> getHttpMethod;
    if ((getHttpMethod = MetaServiceGrpc.getHttpMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getHttpMethod = MetaServiceGrpc.getHttpMethod) == null) {
          MetaServiceGrpc.getHttpMethod = getHttpMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest, org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "http"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("http"))
              .build();
        }
      }
    }
    return getHttpMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> getGetObjStoreInfoMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_obj_store_info",
      requestType = org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> getGetObjStoreInfoMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> getGetObjStoreInfoMethod;
    if ((getGetObjStoreInfoMethod = MetaServiceGrpc.getGetObjStoreInfoMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetObjStoreInfoMethod = MetaServiceGrpc.getGetObjStoreInfoMethod) == null) {
          MetaServiceGrpc.getGetObjStoreInfoMethod = getGetObjStoreInfoMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_obj_store_info"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_obj_store_info"))
              .build();
        }
      }
    }
    return getGetObjStoreInfoMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterObjStoreInfoMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_obj_store_info",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterObjStoreInfoMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterObjStoreInfoMethod;
    if ((getAlterObjStoreInfoMethod = MetaServiceGrpc.getAlterObjStoreInfoMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterObjStoreInfoMethod = MetaServiceGrpc.getAlterObjStoreInfoMethod) == null) {
          MetaServiceGrpc.getAlterObjStoreInfoMethod = getAlterObjStoreInfoMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_obj_store_info"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_obj_store_info"))
              .build();
        }
      }
    }
    return getAlterObjStoreInfoMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterStorageVaultMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_storage_vault",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
      org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterStorageVaultMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> getAlterStorageVaultMethod;
    if ((getAlterStorageVaultMethod = MetaServiceGrpc.getAlterStorageVaultMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterStorageVaultMethod = MetaServiceGrpc.getAlterStorageVaultMethod) == null) {
          MetaServiceGrpc.getAlterStorageVaultMethod = getAlterStorageVaultMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest, org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_storage_vault"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_storage_vault"))
              .build();
        }
      }
    }
    return getAlterStorageVaultMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> getUpdateAkSkMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "update_ak_sk",
      requestType = org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> getUpdateAkSkMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest, org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> getUpdateAkSkMethod;
    if ((getUpdateAkSkMethod = MetaServiceGrpc.getUpdateAkSkMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getUpdateAkSkMethod = MetaServiceGrpc.getUpdateAkSkMethod) == null) {
          MetaServiceGrpc.getUpdateAkSkMethod = getUpdateAkSkMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest, org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "update_ak_sk"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("update_ak_sk"))
              .build();
        }
      }
    }
    return getUpdateAkSkMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> getCreateInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "create_instance",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> getCreateInstanceMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest, org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> getCreateInstanceMethod;
    if ((getCreateInstanceMethod = MetaServiceGrpc.getCreateInstanceMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCreateInstanceMethod = MetaServiceGrpc.getCreateInstanceMethod) == null) {
          MetaServiceGrpc.getCreateInstanceMethod = getCreateInstanceMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest, org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "create_instance"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("create_instance"))
              .build();
        }
      }
    }
    return getCreateInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> getAlterInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_instance",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> getAlterInstanceMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest, org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> getAlterInstanceMethod;
    if ((getAlterInstanceMethod = MetaServiceGrpc.getAlterInstanceMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterInstanceMethod = MetaServiceGrpc.getAlterInstanceMethod) == null) {
          MetaServiceGrpc.getAlterInstanceMethod = getAlterInstanceMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest, org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_instance"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_instance"))
              .build();
        }
      }
    }
    return getAlterInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> getGetInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_instance",
      requestType = org.apache.doris.cloud.proto.Cloud.GetInstanceRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetInstanceResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetInstanceRequest,
      org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> getGetInstanceMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetInstanceRequest, org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> getGetInstanceMethod;
    if ((getGetInstanceMethod = MetaServiceGrpc.getGetInstanceMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetInstanceMethod = MetaServiceGrpc.getGetInstanceMethod) == null) {
          MetaServiceGrpc.getGetInstanceMethod = getGetInstanceMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetInstanceRequest, org.apache.doris.cloud.proto.Cloud.GetInstanceResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_instance"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetInstanceRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetInstanceResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_instance"))
              .build();
        }
      }
    }
    return getGetInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterClusterRequest,
      org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> getAlterClusterMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_cluster",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterClusterRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterClusterResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterClusterRequest,
      org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> getAlterClusterMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterClusterRequest, org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> getAlterClusterMethod;
    if ((getAlterClusterMethod = MetaServiceGrpc.getAlterClusterMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterClusterMethod = MetaServiceGrpc.getAlterClusterMethod) == null) {
          MetaServiceGrpc.getAlterClusterMethod = getAlterClusterMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterClusterRequest, org.apache.doris.cloud.proto.Cloud.AlterClusterResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_cluster"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterClusterRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterClusterResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_cluster"))
              .build();
        }
      }
    }
    return getAlterClusterMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterRequest,
      org.apache.doris.cloud.proto.Cloud.GetClusterResponse> getGetClusterMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_cluster",
      requestType = org.apache.doris.cloud.proto.Cloud.GetClusterRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetClusterResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterRequest,
      org.apache.doris.cloud.proto.Cloud.GetClusterResponse> getGetClusterMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterRequest, org.apache.doris.cloud.proto.Cloud.GetClusterResponse> getGetClusterMethod;
    if ((getGetClusterMethod = MetaServiceGrpc.getGetClusterMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetClusterMethod = MetaServiceGrpc.getGetClusterMethod) == null) {
          MetaServiceGrpc.getGetClusterMethod = getGetClusterMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetClusterRequest, org.apache.doris.cloud.proto.Cloud.GetClusterResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_cluster"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetClusterRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetClusterResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_cluster"))
              .build();
        }
      }
    }
    return getGetClusterMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest,
      org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> getGetClusterStatusMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_cluster_status",
      requestType = org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest,
      org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> getGetClusterStatusMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest, org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> getGetClusterStatusMethod;
    if ((getGetClusterStatusMethod = MetaServiceGrpc.getGetClusterStatusMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetClusterStatusMethod = MetaServiceGrpc.getGetClusterStatusMethod) == null) {
          MetaServiceGrpc.getGetClusterStatusMethod = getGetClusterStatusMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest, org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_cluster_status"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_cluster_status"))
              .build();
        }
      }
    }
    return getGetClusterStatusMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest,
      org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> getGetTabletStatsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_tablet_stats",
      requestType = org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest,
      org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> getGetTabletStatsMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest, org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> getGetTabletStatsMethod;
    if ((getGetTabletStatsMethod = MetaServiceGrpc.getGetTabletStatsMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetTabletStatsMethod = MetaServiceGrpc.getGetTabletStatsMethod) == null) {
          MetaServiceGrpc.getGetTabletStatsMethod = getGetTabletStatsMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest, org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_tablet_stats"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_tablet_stats"))
              .build();
        }
      }
    }
    return getGetTabletStatsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateStageRequest,
      org.apache.doris.cloud.proto.Cloud.CreateStageResponse> getCreateStageMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "create_stage",
      requestType = org.apache.doris.cloud.proto.Cloud.CreateStageRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CreateStageResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateStageRequest,
      org.apache.doris.cloud.proto.Cloud.CreateStageResponse> getCreateStageMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CreateStageRequest, org.apache.doris.cloud.proto.Cloud.CreateStageResponse> getCreateStageMethod;
    if ((getCreateStageMethod = MetaServiceGrpc.getCreateStageMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCreateStageMethod = MetaServiceGrpc.getCreateStageMethod) == null) {
          MetaServiceGrpc.getCreateStageMethod = getCreateStageMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CreateStageRequest, org.apache.doris.cloud.proto.Cloud.CreateStageResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "create_stage"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateStageRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CreateStageResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("create_stage"))
              .build();
        }
      }
    }
    return getCreateStageMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetStageRequest,
      org.apache.doris.cloud.proto.Cloud.GetStageResponse> getGetStageMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_stage",
      requestType = org.apache.doris.cloud.proto.Cloud.GetStageRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetStageResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetStageRequest,
      org.apache.doris.cloud.proto.Cloud.GetStageResponse> getGetStageMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetStageRequest, org.apache.doris.cloud.proto.Cloud.GetStageResponse> getGetStageMethod;
    if ((getGetStageMethod = MetaServiceGrpc.getGetStageMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetStageMethod = MetaServiceGrpc.getGetStageMethod) == null) {
          MetaServiceGrpc.getGetStageMethod = getGetStageMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetStageRequest, org.apache.doris.cloud.proto.Cloud.GetStageResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_stage"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetStageRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetStageResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_stage"))
              .build();
        }
      }
    }
    return getGetStageMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.DropStageRequest,
      org.apache.doris.cloud.proto.Cloud.DropStageResponse> getDropStageMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "drop_stage",
      requestType = org.apache.doris.cloud.proto.Cloud.DropStageRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.DropStageResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.DropStageRequest,
      org.apache.doris.cloud.proto.Cloud.DropStageResponse> getDropStageMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.DropStageRequest, org.apache.doris.cloud.proto.Cloud.DropStageResponse> getDropStageMethod;
    if ((getDropStageMethod = MetaServiceGrpc.getDropStageMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getDropStageMethod = MetaServiceGrpc.getDropStageMethod) == null) {
          MetaServiceGrpc.getDropStageMethod = getDropStageMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.DropStageRequest, org.apache.doris.cloud.proto.Cloud.DropStageResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "drop_stage"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.DropStageRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.DropStageResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("drop_stage"))
              .build();
        }
      }
    }
    return getDropStageMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetIamRequest,
      org.apache.doris.cloud.proto.Cloud.GetIamResponse> getGetIamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_iam",
      requestType = org.apache.doris.cloud.proto.Cloud.GetIamRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetIamResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetIamRequest,
      org.apache.doris.cloud.proto.Cloud.GetIamResponse> getGetIamMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetIamRequest, org.apache.doris.cloud.proto.Cloud.GetIamResponse> getGetIamMethod;
    if ((getGetIamMethod = MetaServiceGrpc.getGetIamMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetIamMethod = MetaServiceGrpc.getGetIamMethod) == null) {
          MetaServiceGrpc.getGetIamMethod = getGetIamMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetIamRequest, org.apache.doris.cloud.proto.Cloud.GetIamResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_iam"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetIamRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetIamResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_iam"))
              .build();
        }
      }
    }
    return getGetIamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterIamRequest,
      org.apache.doris.cloud.proto.Cloud.AlterIamResponse> getAlterIamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_iam",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterIamRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterIamResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterIamRequest,
      org.apache.doris.cloud.proto.Cloud.AlterIamResponse> getAlterIamMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterIamRequest, org.apache.doris.cloud.proto.Cloud.AlterIamResponse> getAlterIamMethod;
    if ((getAlterIamMethod = MetaServiceGrpc.getAlterIamMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterIamMethod = MetaServiceGrpc.getAlterIamMethod) == null) {
          MetaServiceGrpc.getAlterIamMethod = getAlterIamMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterIamRequest, org.apache.doris.cloud.proto.Cloud.AlterIamResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_iam"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterIamRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterIamResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_iam"))
              .build();
        }
      }
    }
    return getAlterIamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest,
      org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> getAlterRamUserMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "alter_ram_user",
      requestType = org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest,
      org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> getAlterRamUserMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest, org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> getAlterRamUserMethod;
    if ((getAlterRamUserMethod = MetaServiceGrpc.getAlterRamUserMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getAlterRamUserMethod = MetaServiceGrpc.getAlterRamUserMethod) == null) {
          MetaServiceGrpc.getAlterRamUserMethod = getAlterRamUserMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest, org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "alter_ram_user"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("alter_ram_user"))
              .build();
        }
      }
    }
    return getAlterRamUserMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginCopyRequest,
      org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> getBeginCopyMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "begin_copy",
      requestType = org.apache.doris.cloud.proto.Cloud.BeginCopyRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.BeginCopyResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginCopyRequest,
      org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> getBeginCopyMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.BeginCopyRequest, org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> getBeginCopyMethod;
    if ((getBeginCopyMethod = MetaServiceGrpc.getBeginCopyMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getBeginCopyMethod = MetaServiceGrpc.getBeginCopyMethod) == null) {
          MetaServiceGrpc.getBeginCopyMethod = getBeginCopyMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.BeginCopyRequest, org.apache.doris.cloud.proto.Cloud.BeginCopyResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "begin_copy"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginCopyRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.BeginCopyResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("begin_copy"))
              .build();
        }
      }
    }
    return getBeginCopyMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishCopyRequest,
      org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> getFinishCopyMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "finish_copy",
      requestType = org.apache.doris.cloud.proto.Cloud.FinishCopyRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.FinishCopyResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishCopyRequest,
      org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> getFinishCopyMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FinishCopyRequest, org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> getFinishCopyMethod;
    if ((getFinishCopyMethod = MetaServiceGrpc.getFinishCopyMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getFinishCopyMethod = MetaServiceGrpc.getFinishCopyMethod) == null) {
          MetaServiceGrpc.getFinishCopyMethod = getFinishCopyMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.FinishCopyRequest, org.apache.doris.cloud.proto.Cloud.FinishCopyResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "finish_copy"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FinishCopyRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FinishCopyResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("finish_copy"))
              .build();
        }
      }
    }
    return getFinishCopyMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest,
      org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> getGetCopyJobMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_copy_job",
      requestType = org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest,
      org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> getGetCopyJobMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest, org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> getGetCopyJobMethod;
    if ((getGetCopyJobMethod = MetaServiceGrpc.getGetCopyJobMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetCopyJobMethod = MetaServiceGrpc.getGetCopyJobMethod) == null) {
          MetaServiceGrpc.getGetCopyJobMethod = getGetCopyJobMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest, org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_copy_job"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_copy_job"))
              .build();
        }
      }
    }
    return getGetCopyJobMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest,
      org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> getGetCopyFilesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_copy_files",
      requestType = org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest,
      org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> getGetCopyFilesMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest, org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> getGetCopyFilesMethod;
    if ((getGetCopyFilesMethod = MetaServiceGrpc.getGetCopyFilesMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetCopyFilesMethod = MetaServiceGrpc.getGetCopyFilesMethod) == null) {
          MetaServiceGrpc.getGetCopyFilesMethod = getGetCopyFilesMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest, org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_copy_files"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_copy_files"))
              .build();
        }
      }
    }
    return getGetCopyFilesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest,
      org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> getFilterCopyFilesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "filter_copy_files",
      requestType = org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest,
      org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> getFilterCopyFilesMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest, org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> getFilterCopyFilesMethod;
    if ((getFilterCopyFilesMethod = MetaServiceGrpc.getFilterCopyFilesMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getFilterCopyFilesMethod = MetaServiceGrpc.getFilterCopyFilesMethod) == null) {
          MetaServiceGrpc.getFilterCopyFilesMethod = getFilterCopyFilesMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest, org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "filter_copy_files"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("filter_copy_files"))
              .build();
        }
      }
    }
    return getFilterCopyFilesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> getUpdateDeleteBitmapMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "update_delete_bitmap",
      requestType = org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> getUpdateDeleteBitmapMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> getUpdateDeleteBitmapMethod;
    if ((getUpdateDeleteBitmapMethod = MetaServiceGrpc.getUpdateDeleteBitmapMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getUpdateDeleteBitmapMethod = MetaServiceGrpc.getUpdateDeleteBitmapMethod) == null) {
          MetaServiceGrpc.getUpdateDeleteBitmapMethod = getUpdateDeleteBitmapMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "update_delete_bitmap"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("update_delete_bitmap"))
              .build();
        }
      }
    }
    return getUpdateDeleteBitmapMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> getGetDeleteBitmapMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_delete_bitmap",
      requestType = org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> getGetDeleteBitmapMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> getGetDeleteBitmapMethod;
    if ((getGetDeleteBitmapMethod = MetaServiceGrpc.getGetDeleteBitmapMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetDeleteBitmapMethod = MetaServiceGrpc.getGetDeleteBitmapMethod) == null) {
          MetaServiceGrpc.getGetDeleteBitmapMethod = getGetDeleteBitmapMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_delete_bitmap"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_delete_bitmap"))
              .build();
        }
      }
    }
    return getGetDeleteBitmapMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest,
      org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> getGetDeleteBitmapUpdateLockMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_delete_bitmap_update_lock",
      requestType = org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest,
      org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> getGetDeleteBitmapUpdateLockMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest, org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> getGetDeleteBitmapUpdateLockMethod;
    if ((getGetDeleteBitmapUpdateLockMethod = MetaServiceGrpc.getGetDeleteBitmapUpdateLockMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetDeleteBitmapUpdateLockMethod = MetaServiceGrpc.getGetDeleteBitmapUpdateLockMethod) == null) {
          MetaServiceGrpc.getGetDeleteBitmapUpdateLockMethod = getGetDeleteBitmapUpdateLockMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest, org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_delete_bitmap_update_lock"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_delete_bitmap_update_lock"))
              .build();
        }
      }
    }
    return getGetDeleteBitmapUpdateLockMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest,
      org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> getRemoveDeleteBitmapUpdateLockMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "remove_delete_bitmap_update_lock",
      requestType = org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest,
      org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> getRemoveDeleteBitmapUpdateLockMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest, org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> getRemoveDeleteBitmapUpdateLockMethod;
    if ((getRemoveDeleteBitmapUpdateLockMethod = MetaServiceGrpc.getRemoveDeleteBitmapUpdateLockMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getRemoveDeleteBitmapUpdateLockMethod = MetaServiceGrpc.getRemoveDeleteBitmapUpdateLockMethod) == null) {
          MetaServiceGrpc.getRemoveDeleteBitmapUpdateLockMethod = getRemoveDeleteBitmapUpdateLockMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest, org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "remove_delete_bitmap_update_lock"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("remove_delete_bitmap_update_lock"))
              .build();
        }
      }
    }
    return getRemoveDeleteBitmapUpdateLockMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> getRemoveDeleteBitmapMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "remove_delete_bitmap",
      requestType = org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest,
      org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> getRemoveDeleteBitmapMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> getRemoveDeleteBitmapMethod;
    if ((getRemoveDeleteBitmapMethod = MetaServiceGrpc.getRemoveDeleteBitmapMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getRemoveDeleteBitmapMethod = MetaServiceGrpc.getRemoveDeleteBitmapMethod) == null) {
          MetaServiceGrpc.getRemoveDeleteBitmapMethod = getRemoveDeleteBitmapMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest, org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "remove_delete_bitmap"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("remove_delete_bitmap"))
              .build();
        }
      }
    }
    return getRemoveDeleteBitmapMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest,
      org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> getGetRlTaskCommitAttachMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "get_rl_task_commit_attach",
      requestType = org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest,
      org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> getGetRlTaskCommitAttachMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest, org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> getGetRlTaskCommitAttachMethod;
    if ((getGetRlTaskCommitAttachMethod = MetaServiceGrpc.getGetRlTaskCommitAttachMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getGetRlTaskCommitAttachMethod = MetaServiceGrpc.getGetRlTaskCommitAttachMethod) == null) {
          MetaServiceGrpc.getGetRlTaskCommitAttachMethod = getGetRlTaskCommitAttachMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest, org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "get_rl_task_commit_attach"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("get_rl_task_commit_attach"))
              .build();
        }
      }
    }
    return getGetRlTaskCommitAttachMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest,
      org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> getResetRlProgressMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "reset_rl_progress",
      requestType = org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest,
      org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> getResetRlProgressMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest, org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> getResetRlProgressMethod;
    if ((getResetRlProgressMethod = MetaServiceGrpc.getResetRlProgressMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getResetRlProgressMethod = MetaServiceGrpc.getResetRlProgressMethod) == null) {
          MetaServiceGrpc.getResetRlProgressMethod = getResetRlProgressMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest, org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "reset_rl_progress"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("reset_rl_progress"))
              .build();
        }
      }
    }
    return getResetRlProgressMethod;
  }

  private static volatile io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckKVRequest,
      org.apache.doris.cloud.proto.Cloud.CheckKVResponse> getCheckKvMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "check_kv",
      requestType = org.apache.doris.cloud.proto.Cloud.CheckKVRequest.class,
      responseType = org.apache.doris.cloud.proto.Cloud.CheckKVResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckKVRequest,
      org.apache.doris.cloud.proto.Cloud.CheckKVResponse> getCheckKvMethod() {
    io.grpc.MethodDescriptor<org.apache.doris.cloud.proto.Cloud.CheckKVRequest, org.apache.doris.cloud.proto.Cloud.CheckKVResponse> getCheckKvMethod;
    if ((getCheckKvMethod = MetaServiceGrpc.getCheckKvMethod) == null) {
      synchronized (MetaServiceGrpc.class) {
        if ((getCheckKvMethod = MetaServiceGrpc.getCheckKvMethod) == null) {
          MetaServiceGrpc.getCheckKvMethod = getCheckKvMethod =
              io.grpc.MethodDescriptor.<org.apache.doris.cloud.proto.Cloud.CheckKVRequest, org.apache.doris.cloud.proto.Cloud.CheckKVResponse>newBuilder()
              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "check_kv"))
              .setSampledToLocalTracing(true)
              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CheckKVRequest.getDefaultInstance()))
              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                  org.apache.doris.cloud.proto.Cloud.CheckKVResponse.getDefaultInstance()))
              .setSchemaDescriptor(new MetaServiceMethodDescriptorSupplier("check_kv"))
              .build();
        }
      }
    }
    return getCheckKvMethod;
  }

  /**
   * Creates a new async stub that supports all call types for the service
   */
  public static MetaServiceStub newStub(io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<MetaServiceStub> factory =
      new io.grpc.stub.AbstractStub.StubFactory<MetaServiceStub>() {
        @java.lang.Override
        public MetaServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
          return new MetaServiceStub(channel, callOptions);
        }
      };
    return MetaServiceStub.newStub(factory, channel);
  }

  /**
   * Creates a new blocking-style stub that supports unary and streaming output calls on the service
   */
  public static MetaServiceBlockingStub newBlockingStub(
      io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<MetaServiceBlockingStub> factory =
      new io.grpc.stub.AbstractStub.StubFactory<MetaServiceBlockingStub>() {
        @java.lang.Override
        public MetaServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
          return new MetaServiceBlockingStub(channel, callOptions);
        }
      };
    return MetaServiceBlockingStub.newStub(factory, channel);
  }

  /**
   * Creates a new ListenableFuture-style stub that supports unary calls on the service
   */
  public static MetaServiceFutureStub newFutureStub(
      io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<MetaServiceFutureStub> factory =
      new io.grpc.stub.AbstractStub.StubFactory<MetaServiceFutureStub>() {
        @java.lang.Override
        public MetaServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
          return new MetaServiceFutureStub(channel, callOptions);
        }
      };
    return MetaServiceFutureStub.newStub(factory, channel);
  }

  /**
   */
  public static abstract class MetaServiceImplBase implements io.grpc.BindableService {

    /**
     */
    public void beginTxn(org.apache.doris.cloud.proto.Cloud.BeginTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getBeginTxnMethod(), responseObserver);
    }

    /**
     */
    public void precommitTxn(org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getPrecommitTxnMethod(), responseObserver);
    }

    /**
     */
    public void commitTxn(org.apache.doris.cloud.proto.Cloud.CommitTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCommitTxnMethod(), responseObserver);
    }

    /**
     */
    public void abortTxn(org.apache.doris.cloud.proto.Cloud.AbortTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAbortTxnMethod(), responseObserver);
    }

    /**
     */
    public void getTxn(org.apache.doris.cloud.proto.Cloud.GetTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetTxnMethod(), responseObserver);
    }

    /**
     */
    public void getCurrentMaxTxnId(org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetCurrentMaxTxnIdMethod(), responseObserver);
    }

    /**
     */
    public void checkTxnConflict(org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCheckTxnConflictMethod(), responseObserver);
    }

    /**
     */
    public void cleanTxnLabel(org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCleanTxnLabelMethod(), responseObserver);
    }

    /**
     */
    public void getTxnId(org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetTxnIdMethod(), responseObserver);
    }

    /**
     */
    public void beginSubTxn(org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getBeginSubTxnMethod(), responseObserver);
    }

    /**
     */
    public void abortSubTxn(org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAbortSubTxnMethod(), responseObserver);
    }

    /**
     */
    public void abortTxnWithCoordinator(org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAbortTxnWithCoordinatorMethod(), responseObserver);
    }

    /**
     */
    public void getVersion(org.apache.doris.cloud.proto.Cloud.GetVersionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetVersionResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetVersionMethod(), responseObserver);
    }

    /**
     */
    public void createTablets(org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCreateTabletsMethod(), responseObserver);
    }

    /**
     */
    public void updateTablet(org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getUpdateTabletMethod(), responseObserver);
    }

    /**
     */
    public void updateTabletSchema(org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getUpdateTabletSchemaMethod(), responseObserver);
    }

    /**
     */
    public void getTablet(org.apache.doris.cloud.proto.Cloud.GetTabletRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetTabletMethod(), responseObserver);
    }

    /**
     */
    public void prepareRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getPrepareRowsetMethod(), responseObserver);
    }

    /**
     */
    public void commitRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCommitRowsetMethod(), responseObserver);
    }

    /**
     */
    public void updateTmpRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getUpdateTmpRowsetMethod(), responseObserver);
    }

    /**
     */
    public void getRowset(org.apache.doris.cloud.proto.Cloud.GetRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetRowsetMethod(), responseObserver);
    }

    /**
     */
    public void getSchemaDict(org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetSchemaDictMethod(), responseObserver);
    }

    /**
     */
    public void prepareIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getPrepareIndexMethod(), responseObserver);
    }

    /**
     */
    public void commitIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCommitIndexMethod(), responseObserver);
    }

    /**
     */
    public void dropIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getDropIndexMethod(), responseObserver);
    }

    /**
     */
    public void preparePartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getPreparePartitionMethod(), responseObserver);
    }

    /**
     */
    public void commitPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCommitPartitionMethod(), responseObserver);
    }

    /**
     */
    public void dropPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getDropPartitionMethod(), responseObserver);
    }

    /**
     */
    public void startTabletJob(org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getStartTabletJobMethod(), responseObserver);
    }

    /**
     */
    public void finishTabletJob(org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getFinishTabletJobMethod(), responseObserver);
    }

    /**
     */
    public void http(org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getHttpMethod(), responseObserver);
    }

    /**
     */
    public void getObjStoreInfo(org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetObjStoreInfoMethod(), responseObserver);
    }

    /**
     */
    public void alterObjStoreInfo(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterObjStoreInfoMethod(), responseObserver);
    }

    /**
     */
    public void alterStorageVault(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterStorageVaultMethod(), responseObserver);
    }

    /**
     */
    public void updateAkSk(org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getUpdateAkSkMethod(), responseObserver);
    }

    /**
     */
    public void createInstance(org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCreateInstanceMethod(), responseObserver);
    }

    /**
     */
    public void alterInstance(org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterInstanceMethod(), responseObserver);
    }

    /**
     */
    public void getInstance(org.apache.doris.cloud.proto.Cloud.GetInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetInstanceMethod(), responseObserver);
    }

    /**
     */
    public void alterCluster(org.apache.doris.cloud.proto.Cloud.AlterClusterRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterClusterMethod(), responseObserver);
    }

    /**
     */
    public void getCluster(org.apache.doris.cloud.proto.Cloud.GetClusterRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetClusterMethod(), responseObserver);
    }

    /**
     */
    public void getClusterStatus(org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetClusterStatusMethod(), responseObserver);
    }

    /**
     */
    public void getTabletStats(org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetTabletStatsMethod(), responseObserver);
    }

    /**
     * <pre>
     * stage
     * </pre>
     */
    public void createStage(org.apache.doris.cloud.proto.Cloud.CreateStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateStageResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCreateStageMethod(), responseObserver);
    }

    /**
     */
    public void getStage(org.apache.doris.cloud.proto.Cloud.GetStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetStageResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetStageMethod(), responseObserver);
    }

    /**
     */
    public void dropStage(org.apache.doris.cloud.proto.Cloud.DropStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.DropStageResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getDropStageMethod(), responseObserver);
    }

    /**
     */
    public void getIam(org.apache.doris.cloud.proto.Cloud.GetIamRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetIamResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetIamMethod(), responseObserver);
    }

    /**
     */
    public void alterIam(org.apache.doris.cloud.proto.Cloud.AlterIamRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterIamResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterIamMethod(), responseObserver);
    }

    /**
     */
    public void alterRamUser(org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getAlterRamUserMethod(), responseObserver);
    }

    /**
     * <pre>
     * copy into
     * </pre>
     */
    public void beginCopy(org.apache.doris.cloud.proto.Cloud.BeginCopyRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getBeginCopyMethod(), responseObserver);
    }

    /**
     */
    public void finishCopy(org.apache.doris.cloud.proto.Cloud.FinishCopyRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getFinishCopyMethod(), responseObserver);
    }

    /**
     */
    public void getCopyJob(org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetCopyJobMethod(), responseObserver);
    }

    /**
     */
    public void getCopyFiles(org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetCopyFilesMethod(), responseObserver);
    }

    /**
     */
    public void filterCopyFiles(org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getFilterCopyFilesMethod(), responseObserver);
    }

    /**
     * <pre>
     * delete bitmap
     * </pre>
     */
    public void updateDeleteBitmap(org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getUpdateDeleteBitmapMethod(), responseObserver);
    }

    /**
     */
    public void getDeleteBitmap(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetDeleteBitmapMethod(), responseObserver);
    }

    /**
     */
    public void getDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetDeleteBitmapUpdateLockMethod(), responseObserver);
    }

    /**
     */
    public void removeDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getRemoveDeleteBitmapUpdateLockMethod(), responseObserver);
    }

    /**
     */
    public void removeDeleteBitmap(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getRemoveDeleteBitmapMethod(), responseObserver);
    }

    /**
     * <pre>
     * routine load progress
     * </pre>
     */
    public void getRlTaskCommitAttach(org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getGetRlTaskCommitAttachMethod(), responseObserver);
    }

    /**
     */
    public void resetRlProgress(org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getResetRlProgressMethod(), responseObserver);
    }

    /**
     * <pre>
     * check KV
     * </pre>
     */
    public void checkKv(org.apache.doris.cloud.proto.Cloud.CheckKVRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckKVResponse> responseObserver) {
      asyncUnimplementedUnaryCall(getCheckKvMethod(), responseObserver);
    }

    @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
      return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
          .addMethod(
            getBeginTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.BeginTxnRequest,
                org.apache.doris.cloud.proto.Cloud.BeginTxnResponse>(
                  this, METHODID_BEGIN_TXN)))
          .addMethod(
            getPrecommitTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest,
                org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse>(
                  this, METHODID_PRECOMMIT_TXN)))
          .addMethod(
            getCommitTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CommitTxnRequest,
                org.apache.doris.cloud.proto.Cloud.CommitTxnResponse>(
                  this, METHODID_COMMIT_TXN)))
          .addMethod(
            getAbortTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AbortTxnRequest,
                org.apache.doris.cloud.proto.Cloud.AbortTxnResponse>(
                  this, METHODID_ABORT_TXN)))
          .addMethod(
            getGetTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetTxnRequest,
                org.apache.doris.cloud.proto.Cloud.GetTxnResponse>(
                  this, METHODID_GET_TXN)))
          .addMethod(
            getGetCurrentMaxTxnIdMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest,
                org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse>(
                  this, METHODID_GET_CURRENT_MAX_TXN_ID)))
          .addMethod(
            getCheckTxnConflictMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest,
                org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse>(
                  this, METHODID_CHECK_TXN_CONFLICT)))
          .addMethod(
            getCleanTxnLabelMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest,
                org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse>(
                  this, METHODID_CLEAN_TXN_LABEL)))
          .addMethod(
            getGetTxnIdMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest,
                org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse>(
                  this, METHODID_GET_TXN_ID)))
          .addMethod(
            getBeginSubTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest,
                org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse>(
                  this, METHODID_BEGIN_SUB_TXN)))
          .addMethod(
            getAbortSubTxnMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest,
                org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse>(
                  this, METHODID_ABORT_SUB_TXN)))
          .addMethod(
            getAbortTxnWithCoordinatorMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest,
                org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse>(
                  this, METHODID_ABORT_TXN_WITH_COORDINATOR)))
          .addMethod(
            getGetVersionMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetVersionRequest,
                org.apache.doris.cloud.proto.Cloud.GetVersionResponse>(
                  this, METHODID_GET_VERSION)))
          .addMethod(
            getCreateTabletsMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest,
                org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse>(
                  this, METHODID_CREATE_TABLETS)))
          .addMethod(
            getUpdateTabletMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest,
                org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse>(
                  this, METHODID_UPDATE_TABLET)))
          .addMethod(
            getUpdateTabletSchemaMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest,
                org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse>(
                  this, METHODID_UPDATE_TABLET_SCHEMA)))
          .addMethod(
            getGetTabletMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetTabletRequest,
                org.apache.doris.cloud.proto.Cloud.GetTabletResponse>(
                  this, METHODID_GET_TABLET)))
          .addMethod(
            getPrepareRowsetMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
                org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>(
                  this, METHODID_PREPARE_ROWSET)))
          .addMethod(
            getCommitRowsetMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
                org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>(
                  this, METHODID_COMMIT_ROWSET)))
          .addMethod(
            getUpdateTmpRowsetMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest,
                org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>(
                  this, METHODID_UPDATE_TMP_ROWSET)))
          .addMethod(
            getGetRowsetMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetRowsetRequest,
                org.apache.doris.cloud.proto.Cloud.GetRowsetResponse>(
                  this, METHODID_GET_ROWSET)))
          .addMethod(
            getGetSchemaDictMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest,
                org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse>(
                  this, METHODID_GET_SCHEMA_DICT)))
          .addMethod(
            getPrepareIndexMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.IndexRequest,
                org.apache.doris.cloud.proto.Cloud.IndexResponse>(
                  this, METHODID_PREPARE_INDEX)))
          .addMethod(
            getCommitIndexMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.IndexRequest,
                org.apache.doris.cloud.proto.Cloud.IndexResponse>(
                  this, METHODID_COMMIT_INDEX)))
          .addMethod(
            getDropIndexMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.IndexRequest,
                org.apache.doris.cloud.proto.Cloud.IndexResponse>(
                  this, METHODID_DROP_INDEX)))
          .addMethod(
            getPreparePartitionMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.PartitionRequest,
                org.apache.doris.cloud.proto.Cloud.PartitionResponse>(
                  this, METHODID_PREPARE_PARTITION)))
          .addMethod(
            getCommitPartitionMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.PartitionRequest,
                org.apache.doris.cloud.proto.Cloud.PartitionResponse>(
                  this, METHODID_COMMIT_PARTITION)))
          .addMethod(
            getDropPartitionMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.PartitionRequest,
                org.apache.doris.cloud.proto.Cloud.PartitionResponse>(
                  this, METHODID_DROP_PARTITION)))
          .addMethod(
            getStartTabletJobMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest,
                org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse>(
                  this, METHODID_START_TABLET_JOB)))
          .addMethod(
            getFinishTabletJobMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest,
                org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse>(
                  this, METHODID_FINISH_TABLET_JOB)))
          .addMethod(
            getHttpMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest,
                org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse>(
                  this, METHODID_HTTP)))
          .addMethod(
            getGetObjStoreInfoMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest,
                org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse>(
                  this, METHODID_GET_OBJ_STORE_INFO)))
          .addMethod(
            getAlterObjStoreInfoMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
                org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>(
                  this, METHODID_ALTER_OBJ_STORE_INFO)))
          .addMethod(
            getAlterStorageVaultMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest,
                org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>(
                  this, METHODID_ALTER_STORAGE_VAULT)))
          .addMethod(
            getUpdateAkSkMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest,
                org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse>(
                  this, METHODID_UPDATE_AK_SK)))
          .addMethod(
            getCreateInstanceMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest,
                org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse>(
                  this, METHODID_CREATE_INSTANCE)))
          .addMethod(
            getAlterInstanceMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest,
                org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse>(
                  this, METHODID_ALTER_INSTANCE)))
          .addMethod(
            getGetInstanceMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetInstanceRequest,
                org.apache.doris.cloud.proto.Cloud.GetInstanceResponse>(
                  this, METHODID_GET_INSTANCE)))
          .addMethod(
            getAlterClusterMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterClusterRequest,
                org.apache.doris.cloud.proto.Cloud.AlterClusterResponse>(
                  this, METHODID_ALTER_CLUSTER)))
          .addMethod(
            getGetClusterMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetClusterRequest,
                org.apache.doris.cloud.proto.Cloud.GetClusterResponse>(
                  this, METHODID_GET_CLUSTER)))
          .addMethod(
            getGetClusterStatusMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest,
                org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse>(
                  this, METHODID_GET_CLUSTER_STATUS)))
          .addMethod(
            getGetTabletStatsMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest,
                org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse>(
                  this, METHODID_GET_TABLET_STATS)))
          .addMethod(
            getCreateStageMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CreateStageRequest,
                org.apache.doris.cloud.proto.Cloud.CreateStageResponse>(
                  this, METHODID_CREATE_STAGE)))
          .addMethod(
            getGetStageMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetStageRequest,
                org.apache.doris.cloud.proto.Cloud.GetStageResponse>(
                  this, METHODID_GET_STAGE)))
          .addMethod(
            getDropStageMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.DropStageRequest,
                org.apache.doris.cloud.proto.Cloud.DropStageResponse>(
                  this, METHODID_DROP_STAGE)))
          .addMethod(
            getGetIamMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetIamRequest,
                org.apache.doris.cloud.proto.Cloud.GetIamResponse>(
                  this, METHODID_GET_IAM)))
          .addMethod(
            getAlterIamMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterIamRequest,
                org.apache.doris.cloud.proto.Cloud.AlterIamResponse>(
                  this, METHODID_ALTER_IAM)))
          .addMethod(
            getAlterRamUserMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest,
                org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse>(
                  this, METHODID_ALTER_RAM_USER)))
          .addMethod(
            getBeginCopyMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.BeginCopyRequest,
                org.apache.doris.cloud.proto.Cloud.BeginCopyResponse>(
                  this, METHODID_BEGIN_COPY)))
          .addMethod(
            getFinishCopyMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.FinishCopyRequest,
                org.apache.doris.cloud.proto.Cloud.FinishCopyResponse>(
                  this, METHODID_FINISH_COPY)))
          .addMethod(
            getGetCopyJobMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest,
                org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse>(
                  this, METHODID_GET_COPY_JOB)))
          .addMethod(
            getGetCopyFilesMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest,
                org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse>(
                  this, METHODID_GET_COPY_FILES)))
          .addMethod(
            getFilterCopyFilesMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest,
                org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse>(
                  this, METHODID_FILTER_COPY_FILES)))
          .addMethod(
            getUpdateDeleteBitmapMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest,
                org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse>(
                  this, METHODID_UPDATE_DELETE_BITMAP)))
          .addMethod(
            getGetDeleteBitmapMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest,
                org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse>(
                  this, METHODID_GET_DELETE_BITMAP)))
          .addMethod(
            getGetDeleteBitmapUpdateLockMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest,
                org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse>(
                  this, METHODID_GET_DELETE_BITMAP_UPDATE_LOCK)))
          .addMethod(
            getRemoveDeleteBitmapUpdateLockMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest,
                org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse>(
                  this, METHODID_REMOVE_DELETE_BITMAP_UPDATE_LOCK)))
          .addMethod(
            getRemoveDeleteBitmapMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest,
                org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse>(
                  this, METHODID_REMOVE_DELETE_BITMAP)))
          .addMethod(
            getGetRlTaskCommitAttachMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest,
                org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse>(
                  this, METHODID_GET_RL_TASK_COMMIT_ATTACH)))
          .addMethod(
            getResetRlProgressMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest,
                org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse>(
                  this, METHODID_RESET_RL_PROGRESS)))
          .addMethod(
            getCheckKvMethod(),
            asyncUnaryCall(
              new MethodHandlers<
                org.apache.doris.cloud.proto.Cloud.CheckKVRequest,
                org.apache.doris.cloud.proto.Cloud.CheckKVResponse>(
                  this, METHODID_CHECK_KV)))
          .build();
    }
  }

  /**
   */
  public static final class MetaServiceStub extends io.grpc.stub.AbstractAsyncStub<MetaServiceStub> {
    private MetaServiceStub(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected MetaServiceStub build(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new MetaServiceStub(channel, callOptions);
    }

    /**
     */
    public void beginTxn(org.apache.doris.cloud.proto.Cloud.BeginTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getBeginTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void precommitTxn(org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getPrecommitTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void commitTxn(org.apache.doris.cloud.proto.Cloud.CommitTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCommitTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void abortTxn(org.apache.doris.cloud.proto.Cloud.AbortTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAbortTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getTxn(org.apache.doris.cloud.proto.Cloud.GetTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getCurrentMaxTxnId(org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetCurrentMaxTxnIdMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void checkTxnConflict(org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCheckTxnConflictMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void cleanTxnLabel(org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCleanTxnLabelMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getTxnId(org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetTxnIdMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void beginSubTxn(org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getBeginSubTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void abortSubTxn(org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAbortSubTxnMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void abortTxnWithCoordinator(org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAbortTxnWithCoordinatorMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getVersion(org.apache.doris.cloud.proto.Cloud.GetVersionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetVersionResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetVersionMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void createTablets(org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCreateTabletsMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void updateTablet(org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getUpdateTabletMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void updateTabletSchema(org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getUpdateTabletSchemaMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getTablet(org.apache.doris.cloud.proto.Cloud.GetTabletRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetTabletMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void prepareRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getPrepareRowsetMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void commitRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCommitRowsetMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void updateTmpRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getUpdateTmpRowsetMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getRowset(org.apache.doris.cloud.proto.Cloud.GetRowsetRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetRowsetMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getSchemaDict(org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetSchemaDictMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void prepareIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getPrepareIndexMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void commitIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCommitIndexMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void dropIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getDropIndexMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void preparePartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getPreparePartitionMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void commitPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCommitPartitionMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void dropPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getDropPartitionMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void startTabletJob(org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getStartTabletJobMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void finishTabletJob(org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getFinishTabletJobMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void http(org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getHttpMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getObjStoreInfo(org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetObjStoreInfoMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterObjStoreInfo(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterObjStoreInfoMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterStorageVault(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterStorageVaultMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void updateAkSk(org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getUpdateAkSkMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void createInstance(org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCreateInstanceMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterInstance(org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterInstanceMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getInstance(org.apache.doris.cloud.proto.Cloud.GetInstanceRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetInstanceMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterCluster(org.apache.doris.cloud.proto.Cloud.AlterClusterRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterClusterMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getCluster(org.apache.doris.cloud.proto.Cloud.GetClusterRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetClusterMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getClusterStatus(org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetClusterStatusMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getTabletStats(org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetTabletStatsMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     * <pre>
     * stage
     * </pre>
     */
    public void createStage(org.apache.doris.cloud.proto.Cloud.CreateStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateStageResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCreateStageMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getStage(org.apache.doris.cloud.proto.Cloud.GetStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetStageResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetStageMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void dropStage(org.apache.doris.cloud.proto.Cloud.DropStageRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.DropStageResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getDropStageMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getIam(org.apache.doris.cloud.proto.Cloud.GetIamRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetIamResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetIamMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterIam(org.apache.doris.cloud.proto.Cloud.AlterIamRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterIamResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterIamMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void alterRamUser(org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getAlterRamUserMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     * <pre>
     * copy into
     * </pre>
     */
    public void beginCopy(org.apache.doris.cloud.proto.Cloud.BeginCopyRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getBeginCopyMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void finishCopy(org.apache.doris.cloud.proto.Cloud.FinishCopyRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getFinishCopyMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getCopyJob(org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetCopyJobMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getCopyFiles(org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetCopyFilesMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void filterCopyFiles(org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getFilterCopyFilesMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     * <pre>
     * delete bitmap
     * </pre>
     */
    public void updateDeleteBitmap(org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getUpdateDeleteBitmapMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getDeleteBitmap(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetDeleteBitmapMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void getDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetDeleteBitmapUpdateLockMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void removeDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getRemoveDeleteBitmapUpdateLockMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void removeDeleteBitmap(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getRemoveDeleteBitmapMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     * <pre>
     * routine load progress
     * </pre>
     */
    public void getRlTaskCommitAttach(org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getGetRlTaskCommitAttachMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     */
    public void resetRlProgress(org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getResetRlProgressMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     * <pre>
     * check KV
     * </pre>
     */
    public void checkKv(org.apache.doris.cloud.proto.Cloud.CheckKVRequest request,
        io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckKVResponse> responseObserver) {
      asyncUnaryCall(
          getChannel().newCall(getCheckKvMethod(), getCallOptions()), request, responseObserver);
    }
  }

  /**
   */
  public static final class MetaServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<MetaServiceBlockingStub> {
    private MetaServiceBlockingStub(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected MetaServiceBlockingStub build(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new MetaServiceBlockingStub(channel, callOptions);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.BeginTxnResponse beginTxn(org.apache.doris.cloud.proto.Cloud.BeginTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getBeginTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse precommitTxn(org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getPrecommitTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CommitTxnResponse commitTxn(org.apache.doris.cloud.proto.Cloud.CommitTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getCommitTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AbortTxnResponse abortTxn(org.apache.doris.cloud.proto.Cloud.AbortTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getAbortTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetTxnResponse getTxn(org.apache.doris.cloud.proto.Cloud.GetTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse getCurrentMaxTxnId(org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetCurrentMaxTxnIdMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse checkTxnConflict(org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest request) {
      return blockingUnaryCall(
          getChannel(), getCheckTxnConflictMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse cleanTxnLabel(org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest request) {
      return blockingUnaryCall(
          getChannel(), getCleanTxnLabelMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse getTxnId(org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetTxnIdMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse beginSubTxn(org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getBeginSubTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse abortSubTxn(org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest request) {
      return blockingUnaryCall(
          getChannel(), getAbortSubTxnMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse abortTxnWithCoordinator(org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest request) {
      return blockingUnaryCall(
          getChannel(), getAbortTxnWithCoordinatorMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetVersionResponse getVersion(org.apache.doris.cloud.proto.Cloud.GetVersionRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetVersionMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse createTablets(org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest request) {
      return blockingUnaryCall(
          getChannel(), getCreateTabletsMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse updateTablet(org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest request) {
      return blockingUnaryCall(
          getChannel(), getUpdateTabletMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse updateTabletSchema(org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest request) {
      return blockingUnaryCall(
          getChannel(), getUpdateTabletSchemaMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetTabletResponse getTablet(org.apache.doris.cloud.proto.Cloud.GetTabletRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetTabletMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse prepareRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return blockingUnaryCall(
          getChannel(), getPrepareRowsetMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse commitRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return blockingUnaryCall(
          getChannel(), getCommitRowsetMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse updateTmpRowset(org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return blockingUnaryCall(
          getChannel(), getUpdateTmpRowsetMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetRowsetResponse getRowset(org.apache.doris.cloud.proto.Cloud.GetRowsetRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetRowsetMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse getSchemaDict(org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetSchemaDictMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.IndexResponse prepareIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return blockingUnaryCall(
          getChannel(), getPrepareIndexMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.IndexResponse commitIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return blockingUnaryCall(
          getChannel(), getCommitIndexMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.IndexResponse dropIndex(org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return blockingUnaryCall(
          getChannel(), getDropIndexMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.PartitionResponse preparePartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return blockingUnaryCall(
          getChannel(), getPreparePartitionMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.PartitionResponse commitPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return blockingUnaryCall(
          getChannel(), getCommitPartitionMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.PartitionResponse dropPartition(org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return blockingUnaryCall(
          getChannel(), getDropPartitionMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse startTabletJob(org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest request) {
      return blockingUnaryCall(
          getChannel(), getStartTabletJobMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse finishTabletJob(org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest request) {
      return blockingUnaryCall(
          getChannel(), getFinishTabletJobMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse http(org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest request) {
      return blockingUnaryCall(
          getChannel(), getHttpMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse getObjStoreInfo(org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetObjStoreInfoMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse alterObjStoreInfo(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterObjStoreInfoMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse alterStorageVault(org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterStorageVaultMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse updateAkSk(org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest request) {
      return blockingUnaryCall(
          getChannel(), getUpdateAkSkMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse createInstance(org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest request) {
      return blockingUnaryCall(
          getChannel(), getCreateInstanceMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse alterInstance(org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterInstanceMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetInstanceResponse getInstance(org.apache.doris.cloud.proto.Cloud.GetInstanceRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetInstanceMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterClusterResponse alterCluster(org.apache.doris.cloud.proto.Cloud.AlterClusterRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterClusterMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetClusterResponse getCluster(org.apache.doris.cloud.proto.Cloud.GetClusterRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetClusterMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse getClusterStatus(org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetClusterStatusMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse getTabletStats(org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetTabletStatsMethod(), getCallOptions(), request);
    }

    /**
     * <pre>
     * stage
     * </pre>
     */
    public org.apache.doris.cloud.proto.Cloud.CreateStageResponse createStage(org.apache.doris.cloud.proto.Cloud.CreateStageRequest request) {
      return blockingUnaryCall(
          getChannel(), getCreateStageMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetStageResponse getStage(org.apache.doris.cloud.proto.Cloud.GetStageRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetStageMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.DropStageResponse dropStage(org.apache.doris.cloud.proto.Cloud.DropStageRequest request) {
      return blockingUnaryCall(
          getChannel(), getDropStageMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetIamResponse getIam(org.apache.doris.cloud.proto.Cloud.GetIamRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetIamMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterIamResponse alterIam(org.apache.doris.cloud.proto.Cloud.AlterIamRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterIamMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse alterRamUser(org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest request) {
      return blockingUnaryCall(
          getChannel(), getAlterRamUserMethod(), getCallOptions(), request);
    }

    /**
     * <pre>
     * copy into
     * </pre>
     */
    public org.apache.doris.cloud.proto.Cloud.BeginCopyResponse beginCopy(org.apache.doris.cloud.proto.Cloud.BeginCopyRequest request) {
      return blockingUnaryCall(
          getChannel(), getBeginCopyMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.FinishCopyResponse finishCopy(org.apache.doris.cloud.proto.Cloud.FinishCopyRequest request) {
      return blockingUnaryCall(
          getChannel(), getFinishCopyMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse getCopyJob(org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetCopyJobMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse getCopyFiles(org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetCopyFilesMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse filterCopyFiles(org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest request) {
      return blockingUnaryCall(
          getChannel(), getFilterCopyFilesMethod(), getCallOptions(), request);
    }

    /**
     * <pre>
     * delete bitmap
     * </pre>
     */
    public org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse updateDeleteBitmap(org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest request) {
      return blockingUnaryCall(
          getChannel(), getUpdateDeleteBitmapMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse getDeleteBitmap(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetDeleteBitmapMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse getDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetDeleteBitmapUpdateLockMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse removeDeleteBitmapUpdateLock(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest request) {
      return blockingUnaryCall(
          getChannel(), getRemoveDeleteBitmapUpdateLockMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse removeDeleteBitmap(org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest request) {
      return blockingUnaryCall(
          getChannel(), getRemoveDeleteBitmapMethod(), getCallOptions(), request);
    }

    /**
     * <pre>
     * routine load progress
     * </pre>
     */
    public org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse getRlTaskCommitAttach(org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest request) {
      return blockingUnaryCall(
          getChannel(), getGetRlTaskCommitAttachMethod(), getCallOptions(), request);
    }

    /**
     */
    public org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse resetRlProgress(org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest request) {
      return blockingUnaryCall(
          getChannel(), getResetRlProgressMethod(), getCallOptions(), request);
    }

    /**
     * <pre>
     * check KV
     * </pre>
     */
    public org.apache.doris.cloud.proto.Cloud.CheckKVResponse checkKv(org.apache.doris.cloud.proto.Cloud.CheckKVRequest request) {
      return blockingUnaryCall(
          getChannel(), getCheckKvMethod(), getCallOptions(), request);
    }
  }

  /**
   */
  public static final class MetaServiceFutureStub extends io.grpc.stub.AbstractFutureStub<MetaServiceFutureStub> {
    private MetaServiceFutureStub(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected MetaServiceFutureStub build(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new MetaServiceFutureStub(channel, callOptions);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.BeginTxnResponse> beginTxn(
        org.apache.doris.cloud.proto.Cloud.BeginTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getBeginTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse> precommitTxn(
        org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getPrecommitTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CommitTxnResponse> commitTxn(
        org.apache.doris.cloud.proto.Cloud.CommitTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCommitTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AbortTxnResponse> abortTxn(
        org.apache.doris.cloud.proto.Cloud.AbortTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAbortTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetTxnResponse> getTxn(
        org.apache.doris.cloud.proto.Cloud.GetTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse> getCurrentMaxTxnId(
        org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetCurrentMaxTxnIdMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse> checkTxnConflict(
        org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCheckTxnConflictMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse> cleanTxnLabel(
        org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCleanTxnLabelMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse> getTxnId(
        org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetTxnIdMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse> beginSubTxn(
        org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getBeginSubTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse> abortSubTxn(
        org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAbortSubTxnMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse> abortTxnWithCoordinator(
        org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAbortTxnWithCoordinatorMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetVersionResponse> getVersion(
        org.apache.doris.cloud.proto.Cloud.GetVersionRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetVersionMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse> createTablets(
        org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCreateTabletsMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse> updateTablet(
        org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getUpdateTabletMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse> updateTabletSchema(
        org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getUpdateTabletSchemaMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetTabletResponse> getTablet(
        org.apache.doris.cloud.proto.Cloud.GetTabletRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetTabletMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> prepareRowset(
        org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getPrepareRowsetMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> commitRowset(
        org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCommitRowsetMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse> updateTmpRowset(
        org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getUpdateTmpRowsetMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetRowsetResponse> getRowset(
        org.apache.doris.cloud.proto.Cloud.GetRowsetRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetRowsetMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse> getSchemaDict(
        org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetSchemaDictMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.IndexResponse> prepareIndex(
        org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getPrepareIndexMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.IndexResponse> commitIndex(
        org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCommitIndexMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.IndexResponse> dropIndex(
        org.apache.doris.cloud.proto.Cloud.IndexRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getDropIndexMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.PartitionResponse> preparePartition(
        org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getPreparePartitionMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.PartitionResponse> commitPartition(
        org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCommitPartitionMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.PartitionResponse> dropPartition(
        org.apache.doris.cloud.proto.Cloud.PartitionRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getDropPartitionMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse> startTabletJob(
        org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getStartTabletJobMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse> finishTabletJob(
        org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getFinishTabletJobMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse> http(
        org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getHttpMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse> getObjStoreInfo(
        org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetObjStoreInfoMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> alterObjStoreInfo(
        org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterObjStoreInfoMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse> alterStorageVault(
        org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterStorageVaultMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse> updateAkSk(
        org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getUpdateAkSkMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse> createInstance(
        org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCreateInstanceMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse> alterInstance(
        org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterInstanceMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetInstanceResponse> getInstance(
        org.apache.doris.cloud.proto.Cloud.GetInstanceRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetInstanceMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterClusterResponse> alterCluster(
        org.apache.doris.cloud.proto.Cloud.AlterClusterRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterClusterMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetClusterResponse> getCluster(
        org.apache.doris.cloud.proto.Cloud.GetClusterRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetClusterMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse> getClusterStatus(
        org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetClusterStatusMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse> getTabletStats(
        org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetTabletStatsMethod(), getCallOptions()), request);
    }

    /**
     * <pre>
     * stage
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CreateStageResponse> createStage(
        org.apache.doris.cloud.proto.Cloud.CreateStageRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCreateStageMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetStageResponse> getStage(
        org.apache.doris.cloud.proto.Cloud.GetStageRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetStageMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.DropStageResponse> dropStage(
        org.apache.doris.cloud.proto.Cloud.DropStageRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getDropStageMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetIamResponse> getIam(
        org.apache.doris.cloud.proto.Cloud.GetIamRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetIamMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterIamResponse> alterIam(
        org.apache.doris.cloud.proto.Cloud.AlterIamRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterIamMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse> alterRamUser(
        org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getAlterRamUserMethod(), getCallOptions()), request);
    }

    /**
     * <pre>
     * copy into
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.BeginCopyResponse> beginCopy(
        org.apache.doris.cloud.proto.Cloud.BeginCopyRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getBeginCopyMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.FinishCopyResponse> finishCopy(
        org.apache.doris.cloud.proto.Cloud.FinishCopyRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getFinishCopyMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse> getCopyJob(
        org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetCopyJobMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse> getCopyFiles(
        org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetCopyFilesMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse> filterCopyFiles(
        org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getFilterCopyFilesMethod(), getCallOptions()), request);
    }

    /**
     * <pre>
     * delete bitmap
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse> updateDeleteBitmap(
        org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getUpdateDeleteBitmapMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse> getDeleteBitmap(
        org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetDeleteBitmapMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse> getDeleteBitmapUpdateLock(
        org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetDeleteBitmapUpdateLockMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse> removeDeleteBitmapUpdateLock(
        org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getRemoveDeleteBitmapUpdateLockMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse> removeDeleteBitmap(
        org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getRemoveDeleteBitmapMethod(), getCallOptions()), request);
    }

    /**
     * <pre>
     * routine load progress
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse> getRlTaskCommitAttach(
        org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getGetRlTaskCommitAttachMethod(), getCallOptions()), request);
    }

    /**
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse> resetRlProgress(
        org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getResetRlProgressMethod(), getCallOptions()), request);
    }

    /**
     * <pre>
     * check KV
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<org.apache.doris.cloud.proto.Cloud.CheckKVResponse> checkKv(
        org.apache.doris.cloud.proto.Cloud.CheckKVRequest request) {
      return futureUnaryCall(
          getChannel().newCall(getCheckKvMethod(), getCallOptions()), request);
    }
  }

  private static final int METHODID_BEGIN_TXN = 0;
  private static final int METHODID_PRECOMMIT_TXN = 1;
  private static final int METHODID_COMMIT_TXN = 2;
  private static final int METHODID_ABORT_TXN = 3;
  private static final int METHODID_GET_TXN = 4;
  private static final int METHODID_GET_CURRENT_MAX_TXN_ID = 5;
  private static final int METHODID_CHECK_TXN_CONFLICT = 6;
  private static final int METHODID_CLEAN_TXN_LABEL = 7;
  private static final int METHODID_GET_TXN_ID = 8;
  private static final int METHODID_BEGIN_SUB_TXN = 9;
  private static final int METHODID_ABORT_SUB_TXN = 10;
  private static final int METHODID_ABORT_TXN_WITH_COORDINATOR = 11;
  private static final int METHODID_GET_VERSION = 12;
  private static final int METHODID_CREATE_TABLETS = 13;
  private static final int METHODID_UPDATE_TABLET = 14;
  private static final int METHODID_UPDATE_TABLET_SCHEMA = 15;
  private static final int METHODID_GET_TABLET = 16;
  private static final int METHODID_PREPARE_ROWSET = 17;
  private static final int METHODID_COMMIT_ROWSET = 18;
  private static final int METHODID_UPDATE_TMP_ROWSET = 19;
  private static final int METHODID_GET_ROWSET = 20;
  private static final int METHODID_GET_SCHEMA_DICT = 21;
  private static final int METHODID_PREPARE_INDEX = 22;
  private static final int METHODID_COMMIT_INDEX = 23;
  private static final int METHODID_DROP_INDEX = 24;
  private static final int METHODID_PREPARE_PARTITION = 25;
  private static final int METHODID_COMMIT_PARTITION = 26;
  private static final int METHODID_DROP_PARTITION = 27;
  private static final int METHODID_START_TABLET_JOB = 28;
  private static final int METHODID_FINISH_TABLET_JOB = 29;
  private static final int METHODID_HTTP = 30;
  private static final int METHODID_GET_OBJ_STORE_INFO = 31;
  private static final int METHODID_ALTER_OBJ_STORE_INFO = 32;
  private static final int METHODID_ALTER_STORAGE_VAULT = 33;
  private static final int METHODID_UPDATE_AK_SK = 34;
  private static final int METHODID_CREATE_INSTANCE = 35;
  private static final int METHODID_ALTER_INSTANCE = 36;
  private static final int METHODID_GET_INSTANCE = 37;
  private static final int METHODID_ALTER_CLUSTER = 38;
  private static final int METHODID_GET_CLUSTER = 39;
  private static final int METHODID_GET_CLUSTER_STATUS = 40;
  private static final int METHODID_GET_TABLET_STATS = 41;
  private static final int METHODID_CREATE_STAGE = 42;
  private static final int METHODID_GET_STAGE = 43;
  private static final int METHODID_DROP_STAGE = 44;
  private static final int METHODID_GET_IAM = 45;
  private static final int METHODID_ALTER_IAM = 46;
  private static final int METHODID_ALTER_RAM_USER = 47;
  private static final int METHODID_BEGIN_COPY = 48;
  private static final int METHODID_FINISH_COPY = 49;
  private static final int METHODID_GET_COPY_JOB = 50;
  private static final int METHODID_GET_COPY_FILES = 51;
  private static final int METHODID_FILTER_COPY_FILES = 52;
  private static final int METHODID_UPDATE_DELETE_BITMAP = 53;
  private static final int METHODID_GET_DELETE_BITMAP = 54;
  private static final int METHODID_GET_DELETE_BITMAP_UPDATE_LOCK = 55;
  private static final int METHODID_REMOVE_DELETE_BITMAP_UPDATE_LOCK = 56;
  private static final int METHODID_REMOVE_DELETE_BITMAP = 57;
  private static final int METHODID_GET_RL_TASK_COMMIT_ATTACH = 58;
  private static final int METHODID_RESET_RL_PROGRESS = 59;
  private static final int METHODID_CHECK_KV = 60;

  private static final class MethodHandlers<Req, Resp> implements
      io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
      io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
      io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
      io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
    private final MetaServiceImplBase serviceImpl;
    private final int methodId;

    MethodHandlers(MetaServiceImplBase serviceImpl, int methodId) {
      this.serviceImpl = serviceImpl;
      this.methodId = methodId;
    }

    @java.lang.Override
    @java.lang.SuppressWarnings("unchecked")
    public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
      switch (methodId) {
        case METHODID_BEGIN_TXN:
          serviceImpl.beginTxn((org.apache.doris.cloud.proto.Cloud.BeginTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginTxnResponse>) responseObserver);
          break;
        case METHODID_PRECOMMIT_TXN:
          serviceImpl.precommitTxn((org.apache.doris.cloud.proto.Cloud.PrecommitTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PrecommitTxnResponse>) responseObserver);
          break;
        case METHODID_COMMIT_TXN:
          serviceImpl.commitTxn((org.apache.doris.cloud.proto.Cloud.CommitTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CommitTxnResponse>) responseObserver);
          break;
        case METHODID_ABORT_TXN:
          serviceImpl.abortTxn((org.apache.doris.cloud.proto.Cloud.AbortTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnResponse>) responseObserver);
          break;
        case METHODID_GET_TXN:
          serviceImpl.getTxn((org.apache.doris.cloud.proto.Cloud.GetTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnResponse>) responseObserver);
          break;
        case METHODID_GET_CURRENT_MAX_TXN_ID:
          serviceImpl.getCurrentMaxTxnId((org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCurrentMaxTxnResponse>) responseObserver);
          break;
        case METHODID_CHECK_TXN_CONFLICT:
          serviceImpl.checkTxnConflict((org.apache.doris.cloud.proto.Cloud.CheckTxnConflictRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckTxnConflictResponse>) responseObserver);
          break;
        case METHODID_CLEAN_TXN_LABEL:
          serviceImpl.cleanTxnLabel((org.apache.doris.cloud.proto.Cloud.CleanTxnLabelRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CleanTxnLabelResponse>) responseObserver);
          break;
        case METHODID_GET_TXN_ID:
          serviceImpl.getTxnId((org.apache.doris.cloud.proto.Cloud.GetTxnIdRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTxnIdResponse>) responseObserver);
          break;
        case METHODID_BEGIN_SUB_TXN:
          serviceImpl.beginSubTxn((org.apache.doris.cloud.proto.Cloud.BeginSubTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginSubTxnResponse>) responseObserver);
          break;
        case METHODID_ABORT_SUB_TXN:
          serviceImpl.abortSubTxn((org.apache.doris.cloud.proto.Cloud.AbortSubTxnRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortSubTxnResponse>) responseObserver);
          break;
        case METHODID_ABORT_TXN_WITH_COORDINATOR:
          serviceImpl.abortTxnWithCoordinator((org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AbortTxnWithCoordinatorResponse>) responseObserver);
          break;
        case METHODID_GET_VERSION:
          serviceImpl.getVersion((org.apache.doris.cloud.proto.Cloud.GetVersionRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetVersionResponse>) responseObserver);
          break;
        case METHODID_CREATE_TABLETS:
          serviceImpl.createTablets((org.apache.doris.cloud.proto.Cloud.CreateTabletsRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateTabletsResponse>) responseObserver);
          break;
        case METHODID_UPDATE_TABLET:
          serviceImpl.updateTablet((org.apache.doris.cloud.proto.Cloud.UpdateTabletRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletResponse>) responseObserver);
          break;
        case METHODID_UPDATE_TABLET_SCHEMA:
          serviceImpl.updateTabletSchema((org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateTabletSchemaResponse>) responseObserver);
          break;
        case METHODID_GET_TABLET:
          serviceImpl.getTablet((org.apache.doris.cloud.proto.Cloud.GetTabletRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletResponse>) responseObserver);
          break;
        case METHODID_PREPARE_ROWSET:
          serviceImpl.prepareRowset((org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>) responseObserver);
          break;
        case METHODID_COMMIT_ROWSET:
          serviceImpl.commitRowset((org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>) responseObserver);
          break;
        case METHODID_UPDATE_TMP_ROWSET:
          serviceImpl.updateTmpRowset((org.apache.doris.cloud.proto.Cloud.CreateRowsetRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateRowsetResponse>) responseObserver);
          break;
        case METHODID_GET_ROWSET:
          serviceImpl.getRowset((org.apache.doris.cloud.proto.Cloud.GetRowsetRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRowsetResponse>) responseObserver);
          break;
        case METHODID_GET_SCHEMA_DICT:
          serviceImpl.getSchemaDict((org.apache.doris.cloud.proto.Cloud.GetSchemaDictRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetSchemaDictResponse>) responseObserver);
          break;
        case METHODID_PREPARE_INDEX:
          serviceImpl.prepareIndex((org.apache.doris.cloud.proto.Cloud.IndexRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse>) responseObserver);
          break;
        case METHODID_COMMIT_INDEX:
          serviceImpl.commitIndex((org.apache.doris.cloud.proto.Cloud.IndexRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse>) responseObserver);
          break;
        case METHODID_DROP_INDEX:
          serviceImpl.dropIndex((org.apache.doris.cloud.proto.Cloud.IndexRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.IndexResponse>) responseObserver);
          break;
        case METHODID_PREPARE_PARTITION:
          serviceImpl.preparePartition((org.apache.doris.cloud.proto.Cloud.PartitionRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse>) responseObserver);
          break;
        case METHODID_COMMIT_PARTITION:
          serviceImpl.commitPartition((org.apache.doris.cloud.proto.Cloud.PartitionRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse>) responseObserver);
          break;
        case METHODID_DROP_PARTITION:
          serviceImpl.dropPartition((org.apache.doris.cloud.proto.Cloud.PartitionRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.PartitionResponse>) responseObserver);
          break;
        case METHODID_START_TABLET_JOB:
          serviceImpl.startTabletJob((org.apache.doris.cloud.proto.Cloud.StartTabletJobRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.StartTabletJobResponse>) responseObserver);
          break;
        case METHODID_FINISH_TABLET_JOB:
          serviceImpl.finishTabletJob((org.apache.doris.cloud.proto.Cloud.FinishTabletJobRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishTabletJobResponse>) responseObserver);
          break;
        case METHODID_HTTP:
          serviceImpl.http((org.apache.doris.cloud.proto.Cloud.MetaServiceHttpRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.MetaServiceHttpResponse>) responseObserver);
          break;
        case METHODID_GET_OBJ_STORE_INFO:
          serviceImpl.getObjStoreInfo((org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetObjStoreInfoResponse>) responseObserver);
          break;
        case METHODID_ALTER_OBJ_STORE_INFO:
          serviceImpl.alterObjStoreInfo((org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>) responseObserver);
          break;
        case METHODID_ALTER_STORAGE_VAULT:
          serviceImpl.alterStorageVault((org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterObjStoreInfoResponse>) responseObserver);
          break;
        case METHODID_UPDATE_AK_SK:
          serviceImpl.updateAkSk((org.apache.doris.cloud.proto.Cloud.UpdateAkSkRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateAkSkResponse>) responseObserver);
          break;
        case METHODID_CREATE_INSTANCE:
          serviceImpl.createInstance((org.apache.doris.cloud.proto.Cloud.CreateInstanceRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateInstanceResponse>) responseObserver);
          break;
        case METHODID_ALTER_INSTANCE:
          serviceImpl.alterInstance((org.apache.doris.cloud.proto.Cloud.AlterInstanceRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterInstanceResponse>) responseObserver);
          break;
        case METHODID_GET_INSTANCE:
          serviceImpl.getInstance((org.apache.doris.cloud.proto.Cloud.GetInstanceRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetInstanceResponse>) responseObserver);
          break;
        case METHODID_ALTER_CLUSTER:
          serviceImpl.alterCluster((org.apache.doris.cloud.proto.Cloud.AlterClusterRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterClusterResponse>) responseObserver);
          break;
        case METHODID_GET_CLUSTER:
          serviceImpl.getCluster((org.apache.doris.cloud.proto.Cloud.GetClusterRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterResponse>) responseObserver);
          break;
        case METHODID_GET_CLUSTER_STATUS:
          serviceImpl.getClusterStatus((org.apache.doris.cloud.proto.Cloud.GetClusterStatusRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetClusterStatusResponse>) responseObserver);
          break;
        case METHODID_GET_TABLET_STATS:
          serviceImpl.getTabletStats((org.apache.doris.cloud.proto.Cloud.GetTabletStatsRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetTabletStatsResponse>) responseObserver);
          break;
        case METHODID_CREATE_STAGE:
          serviceImpl.createStage((org.apache.doris.cloud.proto.Cloud.CreateStageRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CreateStageResponse>) responseObserver);
          break;
        case METHODID_GET_STAGE:
          serviceImpl.getStage((org.apache.doris.cloud.proto.Cloud.GetStageRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetStageResponse>) responseObserver);
          break;
        case METHODID_DROP_STAGE:
          serviceImpl.dropStage((org.apache.doris.cloud.proto.Cloud.DropStageRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.DropStageResponse>) responseObserver);
          break;
        case METHODID_GET_IAM:
          serviceImpl.getIam((org.apache.doris.cloud.proto.Cloud.GetIamRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetIamResponse>) responseObserver);
          break;
        case METHODID_ALTER_IAM:
          serviceImpl.alterIam((org.apache.doris.cloud.proto.Cloud.AlterIamRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterIamResponse>) responseObserver);
          break;
        case METHODID_ALTER_RAM_USER:
          serviceImpl.alterRamUser((org.apache.doris.cloud.proto.Cloud.AlterRamUserRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.AlterRamUserResponse>) responseObserver);
          break;
        case METHODID_BEGIN_COPY:
          serviceImpl.beginCopy((org.apache.doris.cloud.proto.Cloud.BeginCopyRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.BeginCopyResponse>) responseObserver);
          break;
        case METHODID_FINISH_COPY:
          serviceImpl.finishCopy((org.apache.doris.cloud.proto.Cloud.FinishCopyRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FinishCopyResponse>) responseObserver);
          break;
        case METHODID_GET_COPY_JOB:
          serviceImpl.getCopyJob((org.apache.doris.cloud.proto.Cloud.GetCopyJobRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyJobResponse>) responseObserver);
          break;
        case METHODID_GET_COPY_FILES:
          serviceImpl.getCopyFiles((org.apache.doris.cloud.proto.Cloud.GetCopyFilesRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetCopyFilesResponse>) responseObserver);
          break;
        case METHODID_FILTER_COPY_FILES:
          serviceImpl.filterCopyFiles((org.apache.doris.cloud.proto.Cloud.FilterCopyFilesRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.FilterCopyFilesResponse>) responseObserver);
          break;
        case METHODID_UPDATE_DELETE_BITMAP:
          serviceImpl.updateDeleteBitmap((org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.UpdateDeleteBitmapResponse>) responseObserver);
          break;
        case METHODID_GET_DELETE_BITMAP:
          serviceImpl.getDeleteBitmap((org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapResponse>) responseObserver);
          break;
        case METHODID_GET_DELETE_BITMAP_UPDATE_LOCK:
          serviceImpl.getDeleteBitmapUpdateLock((org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetDeleteBitmapUpdateLockResponse>) responseObserver);
          break;
        case METHODID_REMOVE_DELETE_BITMAP_UPDATE_LOCK:
          serviceImpl.removeDeleteBitmapUpdateLock((org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapUpdateLockResponse>) responseObserver);
          break;
        case METHODID_REMOVE_DELETE_BITMAP:
          serviceImpl.removeDeleteBitmap((org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.RemoveDeleteBitmapResponse>) responseObserver);
          break;
        case METHODID_GET_RL_TASK_COMMIT_ATTACH:
          serviceImpl.getRlTaskCommitAttach((org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.GetRLTaskCommitAttachResponse>) responseObserver);
          break;
        case METHODID_RESET_RL_PROGRESS:
          serviceImpl.resetRlProgress((org.apache.doris.cloud.proto.Cloud.ResetRLProgressRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.ResetRLProgressResponse>) responseObserver);
          break;
        case METHODID_CHECK_KV:
          serviceImpl.checkKv((org.apache.doris.cloud.proto.Cloud.CheckKVRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.doris.cloud.proto.Cloud.CheckKVResponse>) responseObserver);
          break;
        default:
          throw new AssertionError();
      }
    }

    @java.lang.Override
    @java.lang.SuppressWarnings("unchecked")
    public io.grpc.stub.StreamObserver<Req> invoke(
        io.grpc.stub.StreamObserver<Resp> responseObserver) {
      switch (methodId) {
        default:
          throw new AssertionError();
      }
    }
  }

  private static abstract class MetaServiceBaseDescriptorSupplier
      implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
    MetaServiceBaseDescriptorSupplier() {}

    @java.lang.Override
    public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
      return org.apache.doris.cloud.proto.Cloud.getDescriptor();
    }

    @java.lang.Override
    public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
      return getFileDescriptor().findServiceByName("MetaService");
    }
  }

  private static final class MetaServiceFileDescriptorSupplier
      extends MetaServiceBaseDescriptorSupplier {
    MetaServiceFileDescriptorSupplier() {}
  }

  private static final class MetaServiceMethodDescriptorSupplier
      extends MetaServiceBaseDescriptorSupplier
      implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
    private final String methodName;

    MetaServiceMethodDescriptorSupplier(String methodName) {
      this.methodName = methodName;
    }

    @java.lang.Override
    public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
      return getServiceDescriptor().findMethodByName(methodName);
    }
  }

  private static volatile io.grpc.ServiceDescriptor serviceDescriptor;

  public static io.grpc.ServiceDescriptor getServiceDescriptor() {
    io.grpc.ServiceDescriptor result = serviceDescriptor;
    if (result == null) {
      synchronized (MetaServiceGrpc.class) {
        result = serviceDescriptor;
        if (result == null) {
          serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
              .setSchemaDescriptor(new MetaServiceFileDescriptorSupplier())
              .addMethod(getBeginTxnMethod())
              .addMethod(getPrecommitTxnMethod())
              .addMethod(getCommitTxnMethod())
              .addMethod(getAbortTxnMethod())
              .addMethod(getGetTxnMethod())
              .addMethod(getGetCurrentMaxTxnIdMethod())
              .addMethod(getCheckTxnConflictMethod())
              .addMethod(getCleanTxnLabelMethod())
              .addMethod(getGetTxnIdMethod())
              .addMethod(getBeginSubTxnMethod())
              .addMethod(getAbortSubTxnMethod())
              .addMethod(getAbortTxnWithCoordinatorMethod())
              .addMethod(getGetVersionMethod())
              .addMethod(getCreateTabletsMethod())
              .addMethod(getUpdateTabletMethod())
              .addMethod(getUpdateTabletSchemaMethod())
              .addMethod(getGetTabletMethod())
              .addMethod(getPrepareRowsetMethod())
              .addMethod(getCommitRowsetMethod())
              .addMethod(getUpdateTmpRowsetMethod())
              .addMethod(getGetRowsetMethod())
              .addMethod(getGetSchemaDictMethod())
              .addMethod(getPrepareIndexMethod())
              .addMethod(getCommitIndexMethod())
              .addMethod(getDropIndexMethod())
              .addMethod(getPreparePartitionMethod())
              .addMethod(getCommitPartitionMethod())
              .addMethod(getDropPartitionMethod())
              .addMethod(getStartTabletJobMethod())
              .addMethod(getFinishTabletJobMethod())
              .addMethod(getHttpMethod())
              .addMethod(getGetObjStoreInfoMethod())
              .addMethod(getAlterObjStoreInfoMethod())
              .addMethod(getAlterStorageVaultMethod())
              .addMethod(getUpdateAkSkMethod())
              .addMethod(getCreateInstanceMethod())
              .addMethod(getAlterInstanceMethod())
              .addMethod(getGetInstanceMethod())
              .addMethod(getAlterClusterMethod())
              .addMethod(getGetClusterMethod())
              .addMethod(getGetClusterStatusMethod())
              .addMethod(getGetTabletStatsMethod())
              .addMethod(getCreateStageMethod())
              .addMethod(getGetStageMethod())
              .addMethod(getDropStageMethod())
              .addMethod(getGetIamMethod())
              .addMethod(getAlterIamMethod())
              .addMethod(getAlterRamUserMethod())
              .addMethod(getBeginCopyMethod())
              .addMethod(getFinishCopyMethod())
              .addMethod(getGetCopyJobMethod())
              .addMethod(getGetCopyFilesMethod())
              .addMethod(getFilterCopyFilesMethod())
              .addMethod(getUpdateDeleteBitmapMethod())
              .addMethod(getGetDeleteBitmapMethod())
              .addMethod(getGetDeleteBitmapUpdateLockMethod())
              .addMethod(getRemoveDeleteBitmapUpdateLockMethod())
              .addMethod(getRemoveDeleteBitmapMethod())
              .addMethod(getGetRlTaskCommitAttachMethod())
              .addMethod(getResetRlProgressMethod())
              .addMethod(getCheckKvMethod())
              .build();
        }
      }
    }
    return result;
  }
}