From 4128473735758ba41260d266dcce4421acd27060 Mon Sep 17 00:00:00 2001 From: cq-bot Date: Tue, 30 Jul 2024 14:11:01 +0000 Subject: [PATCH] fix: Generate Java Code from `plugin-pb` --- .../io/cloudquery/plugin/v3/PluginGrpc.java | 64 + .../plugin/v3/PluginOuterClass.java | 108 +- .../cloudquery/plugin/v3/TransformSchema.java | 1268 +++++++++++++++++ .../plugin/v3/TransformSchemaOrBuilder.java | 11 + .../java/io/cloudquery/plugin/v3/Write.java | 10 +- .../proto/cloudquery/plugin/v3/plugin.proto | 13 + 6 files changed, 1434 insertions(+), 40 deletions(-) create mode 100644 build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java create mode 100644 build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java diff --git a/build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java b/build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java index d40ae65..d89b401 100644 --- a/build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java +++ b/build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java @@ -294,6 +294,37 @@ io.cloudquery.plugin.v3.Transform.Response> getTransformMethod() { return getTransformMethod; } + private static volatile io.grpc.MethodDescriptor getTransformSchemaMethod; + + @io.grpc.stub.annotations.RpcMethod( + fullMethodName = SERVICE_NAME + '/' + "TransformSchema", + requestType = io.cloudquery.plugin.v3.TransformSchema.Request.class, + responseType = io.cloudquery.plugin.v3.TransformSchema.Response.class, + methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) + public static io.grpc.MethodDescriptor getTransformSchemaMethod() { + io.grpc.MethodDescriptor getTransformSchemaMethod; + if ((getTransformSchemaMethod = PluginGrpc.getTransformSchemaMethod) == null) { + synchronized (PluginGrpc.class) { + if ((getTransformSchemaMethod = PluginGrpc.getTransformSchemaMethod) == null) { + PluginGrpc.getTransformSchemaMethod = getTransformSchemaMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "TransformSchema")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.cloudquery.plugin.v3.TransformSchema.Request.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + io.cloudquery.plugin.v3.TransformSchema.Response.getDefaultInstance())) + .setSchemaDescriptor(new PluginMethodDescriptorSupplier("TransformSchema")) + .build(); + } + } + } + return getTransformSchemaMethod; + } + private static volatile io.grpc.MethodDescriptor getCloseMethod; @@ -497,6 +528,16 @@ default io.grpc.stub.StreamObserver t return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getTransformMethod(), responseObserver); } + /** + * 
+     * Transform schemas.
+     *
+ */ + default io.grpc.stub.StreamObserver transformSchema( + io.grpc.stub.StreamObserver responseObserver) { + return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getTransformSchemaMethod(), responseObserver); + } + /** * 
      * Send signal to flush and close open connections
@@ -647,6 +688,17 @@ public io.grpc.stub.StreamObserver tr
           getChannel().newCall(getTransformMethod(), getCallOptions()), responseObserver);
     }
 
+    /**
+     * 
+     * Transform schemas.
+     * 

+     */
+    public io.grpc.stub.StreamObserver transformSchema(
+        io.grpc.stub.StreamObserver responseObserver) {
+      return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
+          getChannel().newCall(getTransformSchemaMethod(), getCallOptions()), responseObserver);
+    }
+
     /**
      * 
      * Send signal to flush and close open connections
@@ -889,6 +941,7 @@ public com.google.common.util.concurrent.ListenableFuture implements
       io.grpc.stub.ServerCalls.UnaryMethod,
@@ -959,6 +1012,9 @@ public io.grpc.stub.StreamObserver invoke(
         case METHODID_TRANSFORM:
           return (io.grpc.stub.StreamObserver) serviceImpl.transform(
               (io.grpc.stub.StreamObserver) responseObserver);
+        case METHODID_TRANSFORM_SCHEMA:
+          return (io.grpc.stub.StreamObserver) serviceImpl.transformSchema(
+              (io.grpc.stub.StreamObserver) responseObserver);
         default:
           throw new AssertionError();
       }
@@ -1030,6 +1086,13 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser
               io.cloudquery.plugin.v3.Transform.Request,
               io.cloudquery.plugin.v3.Transform.Response>(
                 service, METHODID_TRANSFORM)))
+        .addMethod(
+          getTransformSchemaMethod(),
+          io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+            new MethodHandlers<
+              io.cloudquery.plugin.v3.TransformSchema.Request,
+              io.cloudquery.plugin.v3.TransformSchema.Response>(
+                service, METHODID_TRANSFORM_SCHEMA)))
         .addMethod(
           getCloseMethod(),
           io.grpc.stub.ServerCalls.asyncUnaryCall(
@@ -1101,6 +1164,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
               .addMethod(getReadMethod())
               .addMethod(getWriteMethod())
               .addMethod(getTransformMethod())
+              .addMethod(getTransformSchemaMethod())
               .addMethod(getCloseMethod())
               .addMethod(getTestConnectionMethod())
               .build();
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
index e5c31ec..7c03d59 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
@@ -215,6 +215,21 @@ public static void registerAllExtensions(
   static final 
     com.google.protobuf.GeneratedMessage.FieldAccessorTable
       internal_static_cloudquery_plugin_v3_Transform_Response_fieldAccessorTable;
+  static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_cloudquery_plugin_v3_TransformSchema_descriptor;
+  static final 
+    com.google.protobuf.GeneratedMessage.FieldAccessorTable
+      internal_static_cloudquery_plugin_v3_TransformSchema_fieldAccessorTable;
+  static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor;
+  static final 
+    com.google.protobuf.GeneratedMessage.FieldAccessorTable
+      internal_static_cloudquery_plugin_v3_TransformSchema_Request_fieldAccessorTable;
+  static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor;
+  static final 
+    com.google.protobuf.GeneratedMessage.FieldAccessorTable
+      internal_static_cloudquery_plugin_v3_TransformSchema_Response_fieldAccessorTable;
   static final com.google.protobuf.Descriptors.Descriptor
     internal_static_cloudquery_plugin_v3_Close_descriptor;
   static final 
@@ -313,39 +328,44 @@ public static void registerAllExtensions(
       "record\030\004 \001(\0132/.cloudquery.plugin.v3.Writ" +
       "e.MessageDeleteRecordH\000B\t\n\007message\032\n\n\010Re" +
       "sponse\"B\n\tTransform\032\031\n\007Request\022\016\n\006record" +
-      "\030\001 \001(\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014\"\036\n\005Cl" +
-      "ose\032\t\n\007Request\032\n\n\010Response\"y\n\016TestConnec" +
-      "tion\032\027\n\007Request\022\014\n\004spec\030\001 \001(\014\032N\n\010Respons" +
-      "e\022\017\n\007success\030\001 \001(\010\022\024\n\014failure_code\030\002 \001(\t" +
-      "\022\033\n\023failure_description\030\003 \001(\t2\205\010\n\006Plugin" +
-      "\022X\n\007GetName\022%.cloudquery.plugin.v3.GetNa" +
-      "me.Request\032&.cloudquery.plugin.v3.GetNam" +
-      "e.Response\022a\n\nGetVersion\022(.cloudquery.pl" +
-      "ugin.v3.GetVersion.Request\032).cloudquery." +
-      "plugin.v3.GetVersion.Response\022j\n\rGetSpec" +
-      "Schema\022+.cloudquery.plugin.v3.GetSpecSch" +
-      "ema.Request\032,.cloudquery.plugin.v3.GetSp" +
-      "ecSchema.Response\022O\n\004Init\022\".cloudquery.p" +
-      "lugin.v3.Init.Request\032#.cloudquery.plugi" +
-      "n.v3.Init.Response\022^\n\tGetTables\022\'.cloudq" +
-      "uery.plugin.v3.GetTables.Request\032(.cloud" +
-      "query.plugin.v3.GetTables.Response\022Q\n\004Sy" +
-      "nc\022\".cloudquery.plugin.v3.Sync.Request\032#" +
-      ".cloudquery.plugin.v3.Sync.Response0\001\022Q\n" +
-      "\004Read\022\".cloudquery.plugin.v3.Read.Reques" +
-      "t\032#.cloudquery.plugin.v3.Read.Response0\001" +
-      "\022T\n\005Write\022#.cloudquery.plugin.v3.Write.R" +
-      "equest\032$.cloudquery.plugin.v3.Write.Resp" +
-      "onse(\001\022b\n\tTransform\022\'.cloudquery.plugin." +
-      "v3.Transform.Request\032(.cloudquery.plugin" +
-      ".v3.Transform.Response(\0010\001\022R\n\005Close\022#.cl" +
-      "oudquery.plugin.v3.Close.Request\032$.cloud" +
-      "query.plugin.v3.Close.Response\022m\n\016TestCo" +
-      "nnection\022,.cloudquery.plugin.v3.TestConn" +
-      "ection.Request\032-.cloudquery.plugin.v3.Te" +
-      "stConnection.ResponseBS\n\027io.cloudquery.p" +
-      "lugin.v3P\001Z6github.com/cloudquery/plugin" +
-      "-pb-go/pb/plugin/v3;pluginb\006proto3"
+      "\030\001 \001(\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014\"H\n\017Tr" +
+      "ansformSchema\032\031\n\007Request\022\016\n\006schema\030\001 \001(\014" +
+      "\032\032\n\010Response\022\016\n\006schema\030\001 \001(\014\"\036\n\005Close\032\t\n" +
+      "\007Request\032\n\n\010Response\"y\n\016TestConnection\032\027" +
+      "\n\007Request\022\014\n\004spec\030\001 \001(\014\032N\n\010Response\022\017\n\007s" +
+      "uccess\030\001 \001(\010\022\024\n\014failure_code\030\002 \001(\t\022\033\n\023fa" +
+      "ilure_description\030\003 \001(\t2\373\010\n\006Plugin\022X\n\007Ge" +
+      "tName\022%.cloudquery.plugin.v3.GetName.Req" +
+      "uest\032&.cloudquery.plugin.v3.GetName.Resp" +
+      "onse\022a\n\nGetVersion\022(.cloudquery.plugin.v" +
+      "3.GetVersion.Request\032).cloudquery.plugin" +
+      ".v3.GetVersion.Response\022j\n\rGetSpecSchema" +
+      "\022+.cloudquery.plugin.v3.GetSpecSchema.Re" +
+      "quest\032,.cloudquery.plugin.v3.GetSpecSche" +
+      "ma.Response\022O\n\004Init\022\".cloudquery.plugin." +
+      "v3.Init.Request\032#.cloudquery.plugin.v3.I" +
+      "nit.Response\022^\n\tGetTables\022\'.cloudquery.p" +
+      "lugin.v3.GetTables.Request\032(.cloudquery." +
+      "plugin.v3.GetTables.Response\022Q\n\004Sync\022\".c" +
+      "loudquery.plugin.v3.Sync.Request\032#.cloud" +
+      "query.plugin.v3.Sync.Response0\001\022Q\n\004Read\022" +
+      "\".cloudquery.plugin.v3.Read.Request\032#.cl" +
+      "oudquery.plugin.v3.Read.Response0\001\022T\n\005Wr" +
+      "ite\022#.cloudquery.plugin.v3.Write.Request" +
+      "\032$.cloudquery.plugin.v3.Write.Response(\001" +
+      "\022b\n\tTransform\022\'.cloudquery.plugin.v3.Tra" +
+      "nsform.Request\032(.cloudquery.plugin.v3.Tr" +
+      "ansform.Response(\0010\001\022t\n\017TransformSchema\022" +
+      "-.cloudquery.plugin.v3.TransformSchema.R" +
+      "equest\032..cloudquery.plugin.v3.TransformS" +
+      "chema.Response(\0010\001\022R\n\005Close\022#.cloudquery" +
+      ".plugin.v3.Close.Request\032$.cloudquery.pl" +
+      "ugin.v3.Close.Response\022m\n\016TestConnection" +
+      "\022,.cloudquery.plugin.v3.TestConnection.R" +
+      "equest\032-.cloudquery.plugin.v3.TestConnec" +
+      "tion.ResponseBS\n\027io.cloudquery.plugin.v3" +
+      "P\001Z6github.com/cloudquery/plugin-pb-go/p" +
+      "b/plugin/v3;pluginb\006proto3"
     };
     descriptor = com.google.protobuf.Descriptors.FileDescriptor
       .internalBuildGeneratedFileFrom(descriptorData,
@@ -580,8 +600,26 @@ public static void registerAllExtensions(
       com.google.protobuf.GeneratedMessage.FieldAccessorTable(
         internal_static_cloudquery_plugin_v3_Transform_Response_descriptor,
         new java.lang.String[] { "Record", });
-    internal_static_cloudquery_plugin_v3_Close_descriptor =
+    internal_static_cloudquery_plugin_v3_TransformSchema_descriptor =
       getDescriptor().getMessageTypes().get(12);
+    internal_static_cloudquery_plugin_v3_TransformSchema_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+        internal_static_cloudquery_plugin_v3_TransformSchema_descriptor,
+        new java.lang.String[] { });
+    internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor =
+      internal_static_cloudquery_plugin_v3_TransformSchema_descriptor.getNestedTypes().get(0);
+    internal_static_cloudquery_plugin_v3_TransformSchema_Request_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+        internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor,
+        new java.lang.String[] { "Schema", });
+    internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor =
+      internal_static_cloudquery_plugin_v3_TransformSchema_descriptor.getNestedTypes().get(1);
+    internal_static_cloudquery_plugin_v3_TransformSchema_Response_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+        internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor,
+        new java.lang.String[] { "Schema", });
+    internal_static_cloudquery_plugin_v3_Close_descriptor =
+      getDescriptor().getMessageTypes().get(13);
     internal_static_cloudquery_plugin_v3_Close_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessage.FieldAccessorTable(
         internal_static_cloudquery_plugin_v3_Close_descriptor,
@@ -599,7 +637,7 @@ public static void registerAllExtensions(
         internal_static_cloudquery_plugin_v3_Close_Response_descriptor,
         new java.lang.String[] { });
     internal_static_cloudquery_plugin_v3_TestConnection_descriptor =
-      getDescriptor().getMessageTypes().get(13);
+      getDescriptor().getMessageTypes().get(14);
     internal_static_cloudquery_plugin_v3_TestConnection_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessage.FieldAccessorTable(
         internal_static_cloudquery_plugin_v3_TestConnection_descriptor,
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java
new file mode 100644
index 0000000..2fc2133
--- /dev/null
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java
@@ -0,0 +1,1268 @@
+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+// NO CHECKED-IN PROTOBUF GENCODE
+// source: cloudquery/plugin/v3/plugin.proto
+// Protobuf Java Version: 4.27.2
+
+package io.cloudquery.plugin.v3;
+
+/**
+ * Protobuf type {@code cloudquery.plugin.v3.TransformSchema}
+ */
+public final class TransformSchema extends
+    com.google.protobuf.GeneratedMessage implements
+    // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TransformSchema)
+    TransformSchemaOrBuilder {
+private static final long serialVersionUID = 0L;
+  static {
+    com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
+      com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
+      /* major= */ 4,
+      /* minor= */ 27,
+      /* patch= */ 2,
+      /* suffix= */ "",
+      TransformSchema.class.getName());
+  }
+  // Use TransformSchema.newBuilder() to construct.
+  private TransformSchema(com.google.protobuf.GeneratedMessage.Builder builder) {
+    super(builder);
+  }
+  private TransformSchema() {
+  }
+
+  public static final com.google.protobuf.Descriptors.Descriptor
+      getDescriptor() {
+    return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_descriptor;
+  }
+
+  @java.lang.Override
+  protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+      internalGetFieldAccessorTable() {
+    return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_fieldAccessorTable
+        .ensureFieldAccessorsInitialized(
+            io.cloudquery.plugin.v3.TransformSchema.class, io.cloudquery.plugin.v3.TransformSchema.Builder.class);
+  }
+
+  public interface RequestOrBuilder extends
+      // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TransformSchema.Request)
+      com.google.protobuf.MessageOrBuilder {
+
+    /**
+     * 
+     * marshalled arrow.Schema
+     * 

+     *
+     * bytes schema = 1;
+     * @return The schema.
+     */
+    com.google.protobuf.ByteString getSchema();
+  }
+  /**
+   * Protobuf type {@code cloudquery.plugin.v3.TransformSchema.Request}
+   */
+  public static final class Request extends
+      com.google.protobuf.GeneratedMessage implements
+      // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TransformSchema.Request)
+      RequestOrBuilder {
+  private static final long serialVersionUID = 0L;
+    static {
+      com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
+        com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
+        /* major= */ 4,
+        /* minor= */ 27,
+        /* patch= */ 2,
+        /* suffix= */ "",
+        Request.class.getName());
+    }
+    // Use Request.newBuilder() to construct.
+    private Request(com.google.protobuf.GeneratedMessage.Builder builder) {
+      super(builder);
+    }
+    private Request() {
+      schema_ = com.google.protobuf.ByteString.EMPTY;
+    }
+
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor;
+    }
+
+    @java.lang.Override
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Request_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              io.cloudquery.plugin.v3.TransformSchema.Request.class, io.cloudquery.plugin.v3.TransformSchema.Request.Builder.class);
+    }
+
+    public static final int SCHEMA_FIELD_NUMBER = 1;
+    private com.google.protobuf.ByteString schema_ = com.google.protobuf.ByteString.EMPTY;
+    /**
+     * 
+     * marshalled arrow.Schema
+     * 

+     *
+     * bytes schema = 1;
+     * @return The schema.
+     */
+    @java.lang.Override
+    public com.google.protobuf.ByteString getSchema() {
+      return schema_;
+    }
+
+    private byte memoizedIsInitialized = -1;
+    @java.lang.Override
+    public final boolean isInitialized() {
+      byte isInitialized = memoizedIsInitialized;
+      if (isInitialized == 1) return true;
+      if (isInitialized == 0) return false;
+
+      memoizedIsInitialized = 1;
+      return true;
+    }
+
+    @java.lang.Override
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (!schema_.isEmpty()) {
+        output.writeBytes(1, schema_);
+      }
+      getUnknownFields().writeTo(output);
+    }
+
+    @java.lang.Override
+    public int getSerializedSize() {
+      int size = memoizedSize;
+      if (size != -1) return size;
+
+      size = 0;
+      if (!schema_.isEmpty()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, schema_);
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSize = size;
+      return size;
+    }
+
+    @java.lang.Override
+    public boolean equals(final java.lang.Object obj) {
+      if (obj == this) {
+       return true;
+      }
+      if (!(obj instanceof io.cloudquery.plugin.v3.TransformSchema.Request)) {
+        return super.equals(obj);
+      }
+      io.cloudquery.plugin.v3.TransformSchema.Request other = (io.cloudquery.plugin.v3.TransformSchema.Request) obj;
+
+      if (!getSchema()
+          .equals(other.getSchema())) return false;
+      if (!getUnknownFields().equals(other.getUnknownFields())) return false;
+      return true;
+    }
+
+    @java.lang.Override
+    public int hashCode() {
+      if (memoizedHashCode != 0) {
+        return memoizedHashCode;
+      }
+      int hash = 41;
+      hash = (19 * hash) + getDescriptor().hashCode();
+      hash = (37 * hash) + SCHEMA_FIELD_NUMBER;
+      hash = (53 * hash) + getSchema().hashCode();
+      hash = (29 * hash) + getUnknownFields().hashCode();
+      memoizedHashCode = hash;
+      return hash;
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        java.nio.ByteBuffer data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        java.nio.ByteBuffer data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseDelimitedWithIOException(PARSER, input);
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Request parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    @java.lang.Override
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder() {
+      return DEFAULT_INSTANCE.toBuilder();
+    }
+    public static Builder newBuilder(io.cloudquery.plugin.v3.TransformSchema.Request prototype) {
+      return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+    }
+    @java.lang.Override
+    public Builder toBuilder() {
+      return this == DEFAULT_INSTANCE
+          ? new Builder() : new Builder().mergeFrom(this);
+    }
+
+    @java.lang.Override
+    protected Builder newBuilderForType(
+        com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+      Builder builder = new Builder(parent);
+      return builder;
+    }
+    /**
+     * Protobuf type {@code cloudquery.plugin.v3.TransformSchema.Request}
+     */
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder implements
+        // @@protoc_insertion_point(builder_implements:cloudquery.plugin.v3.TransformSchema.Request)
+        io.cloudquery.plugin.v3.TransformSchema.RequestOrBuilder {
+      public static final com.google.protobuf.Descriptors.Descriptor
+          getDescriptor() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor;
+      }
+
+      @java.lang.Override
+      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+          internalGetFieldAccessorTable() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Request_fieldAccessorTable
+            .ensureFieldAccessorsInitialized(
+                io.cloudquery.plugin.v3.TransformSchema.Request.class, io.cloudquery.plugin.v3.TransformSchema.Request.Builder.class);
+      }
+
+      // Construct using io.cloudquery.plugin.v3.TransformSchema.Request.newBuilder()
+      private Builder() {
+
+      }
+
+      private Builder(
+          com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+        super(parent);
+
+      }
+      @java.lang.Override
+      public Builder clear() {
+        super.clear();
+        bitField0_ = 0;
+        schema_ = com.google.protobuf.ByteString.EMPTY;
+        return this;
+      }
+
+      @java.lang.Override
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Request_descriptor;
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Request getDefaultInstanceForType() {
+        return io.cloudquery.plugin.v3.TransformSchema.Request.getDefaultInstance();
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Request build() {
+        io.cloudquery.plugin.v3.TransformSchema.Request result = buildPartial();
+        if (!result.isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return result;
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Request buildPartial() {
+        io.cloudquery.plugin.v3.TransformSchema.Request result = new io.cloudquery.plugin.v3.TransformSchema.Request(this);
+        if (bitField0_ != 0) { buildPartial0(result); }
+        onBuilt();
+        return result;
+      }
+
+      private void buildPartial0(io.cloudquery.plugin.v3.TransformSchema.Request result) {
+        int from_bitField0_ = bitField0_;
+        if (((from_bitField0_ & 0x00000001) != 0)) {
+          result.schema_ = schema_;
+        }
+      }
+
+      @java.lang.Override
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof io.cloudquery.plugin.v3.TransformSchema.Request) {
+          return mergeFrom((io.cloudquery.plugin.v3.TransformSchema.Request)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+
+      public Builder mergeFrom(io.cloudquery.plugin.v3.TransformSchema.Request other) {
+        if (other == io.cloudquery.plugin.v3.TransformSchema.Request.getDefaultInstance()) return this;
+        if (other.getSchema() != com.google.protobuf.ByteString.EMPTY) {
+          setSchema(other.getSchema());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        onChanged();
+        return this;
+      }
+
+      @java.lang.Override
+      public final boolean isInitialized() {
+        return true;
+      }
+
+      @java.lang.Override
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        if (extensionRegistry == null) {
+          throw new java.lang.NullPointerException();
+        }
+        try {
+          boolean done = false;
+          while (!done) {
+            int tag = input.readTag();
+            switch (tag) {
+              case 0:
+                done = true;
+                break;
+              case 10: {
+                schema_ = input.readBytes();
+                bitField0_ |= 0x00000001;
+                break;
+              } // case 10
+              default: {
+                if (!super.parseUnknownField(input, extensionRegistry, tag)) {
+                  done = true; // was an endgroup tag
+                }
+                break;
+              } // default:
+            } // switch (tag)
+          } // while (!done)
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          throw e.unwrapIOException();
+        } finally {
+          onChanged();
+        } // finally
+        return this;
+      }
+      private int bitField0_;
+
+      private com.google.protobuf.ByteString schema_ = com.google.protobuf.ByteString.EMPTY;
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @return The schema.
+       */
+      @java.lang.Override
+      public com.google.protobuf.ByteString getSchema() {
+        return schema_;
+      }
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @param value The schema to set.
+       * @return This builder for chaining.
+       */
+      public Builder setSchema(com.google.protobuf.ByteString value) {
+        if (value == null) { throw new NullPointerException(); }
+        schema_ = value;
+        bitField0_ |= 0x00000001;
+        onChanged();
+        return this;
+      }
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @return This builder for chaining.
+       */
+      public Builder clearSchema() {
+        bitField0_ = (bitField0_ & ~0x00000001);
+        schema_ = getDefaultInstance().getSchema();
+        onChanged();
+        return this;
+      }
+
+      // @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.TransformSchema.Request)
+    }
+
+    // @@protoc_insertion_point(class_scope:cloudquery.plugin.v3.TransformSchema.Request)
+    private static final io.cloudquery.plugin.v3.TransformSchema.Request DEFAULT_INSTANCE;
+    static {
+      DEFAULT_INSTANCE = new io.cloudquery.plugin.v3.TransformSchema.Request();
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Request getDefaultInstance() {
+      return DEFAULT_INSTANCE;
+    }
+
+    private static final com.google.protobuf.Parser
+        PARSER = new com.google.protobuf.AbstractParser() {
+      @java.lang.Override
+      public Request parsePartialFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        Builder builder = newBuilder();
+        try {
+          builder.mergeFrom(input, extensionRegistry);
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          throw e.setUnfinishedMessage(builder.buildPartial());
+        } catch (com.google.protobuf.UninitializedMessageException e) {
+          throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
+        } catch (java.io.IOException e) {
+          throw new com.google.protobuf.InvalidProtocolBufferException(e)
+              .setUnfinishedMessage(builder.buildPartial());
+        }
+        return builder.buildPartial();
+      }
+    };
+
+    public static com.google.protobuf.Parser parser() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Parser getParserForType() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public io.cloudquery.plugin.v3.TransformSchema.Request getDefaultInstanceForType() {
+      return DEFAULT_INSTANCE;
+    }
+
+  }
+
+  public interface ResponseOrBuilder extends
+      // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TransformSchema.Response)
+      com.google.protobuf.MessageOrBuilder {
+
+    /**
+     * 
+     * marshalled arrow.Schema
+     * 

+     *
+     * bytes schema = 1;
+     * @return The schema.
+     */
+    com.google.protobuf.ByteString getSchema();
+  }
+  /**
+   * Protobuf type {@code cloudquery.plugin.v3.TransformSchema.Response}
+   */
+  public static final class Response extends
+      com.google.protobuf.GeneratedMessage implements
+      // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TransformSchema.Response)
+      ResponseOrBuilder {
+  private static final long serialVersionUID = 0L;
+    static {
+      com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
+        com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
+        /* major= */ 4,
+        /* minor= */ 27,
+        /* patch= */ 2,
+        /* suffix= */ "",
+        Response.class.getName());
+    }
+    // Use Response.newBuilder() to construct.
+    private Response(com.google.protobuf.GeneratedMessage.Builder builder) {
+      super(builder);
+    }
+    private Response() {
+      schema_ = com.google.protobuf.ByteString.EMPTY;
+    }
+
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor;
+    }
+
+    @java.lang.Override
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Response_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              io.cloudquery.plugin.v3.TransformSchema.Response.class, io.cloudquery.plugin.v3.TransformSchema.Response.Builder.class);
+    }
+
+    public static final int SCHEMA_FIELD_NUMBER = 1;
+    private com.google.protobuf.ByteString schema_ = com.google.protobuf.ByteString.EMPTY;
+    /**
+     * 
+     * marshalled arrow.Schema
+     * 

+     *
+     * bytes schema = 1;
+     * @return The schema.
+     */
+    @java.lang.Override
+    public com.google.protobuf.ByteString getSchema() {
+      return schema_;
+    }
+
+    private byte memoizedIsInitialized = -1;
+    @java.lang.Override
+    public final boolean isInitialized() {
+      byte isInitialized = memoizedIsInitialized;
+      if (isInitialized == 1) return true;
+      if (isInitialized == 0) return false;
+
+      memoizedIsInitialized = 1;
+      return true;
+    }
+
+    @java.lang.Override
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (!schema_.isEmpty()) {
+        output.writeBytes(1, schema_);
+      }
+      getUnknownFields().writeTo(output);
+    }
+
+    @java.lang.Override
+    public int getSerializedSize() {
+      int size = memoizedSize;
+      if (size != -1) return size;
+
+      size = 0;
+      if (!schema_.isEmpty()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, schema_);
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSize = size;
+      return size;
+    }
+
+    @java.lang.Override
+    public boolean equals(final java.lang.Object obj) {
+      if (obj == this) {
+       return true;
+      }
+      if (!(obj instanceof io.cloudquery.plugin.v3.TransformSchema.Response)) {
+        return super.equals(obj);
+      }
+      io.cloudquery.plugin.v3.TransformSchema.Response other = (io.cloudquery.plugin.v3.TransformSchema.Response) obj;
+
+      if (!getSchema()
+          .equals(other.getSchema())) return false;
+      if (!getUnknownFields().equals(other.getUnknownFields())) return false;
+      return true;
+    }
+
+    @java.lang.Override
+    public int hashCode() {
+      if (memoizedHashCode != 0) {
+        return memoizedHashCode;
+      }
+      int hash = 41;
+      hash = (19 * hash) + getDescriptor().hashCode();
+      hash = (37 * hash) + SCHEMA_FIELD_NUMBER;
+      hash = (53 * hash) + getSchema().hashCode();
+      hash = (29 * hash) + getUnknownFields().hashCode();
+      memoizedHashCode = hash;
+      return hash;
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        java.nio.ByteBuffer data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        java.nio.ByteBuffer data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseDelimitedWithIOException(PARSER, input);
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.cloudquery.plugin.v3.TransformSchema.Response parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessage
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    @java.lang.Override
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder() {
+      return DEFAULT_INSTANCE.toBuilder();
+    }
+    public static Builder newBuilder(io.cloudquery.plugin.v3.TransformSchema.Response prototype) {
+      return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+    }
+    @java.lang.Override
+    public Builder toBuilder() {
+      return this == DEFAULT_INSTANCE
+          ? new Builder() : new Builder().mergeFrom(this);
+    }
+
+    @java.lang.Override
+    protected Builder newBuilderForType(
+        com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+      Builder builder = new Builder(parent);
+      return builder;
+    }
+    /**
+     * Protobuf type {@code cloudquery.plugin.v3.TransformSchema.Response}
+     */
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder implements
+        // @@protoc_insertion_point(builder_implements:cloudquery.plugin.v3.TransformSchema.Response)
+        io.cloudquery.plugin.v3.TransformSchema.ResponseOrBuilder {
+      public static final com.google.protobuf.Descriptors.Descriptor
+          getDescriptor() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor;
+      }
+
+      @java.lang.Override
+      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+          internalGetFieldAccessorTable() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Response_fieldAccessorTable
+            .ensureFieldAccessorsInitialized(
+                io.cloudquery.plugin.v3.TransformSchema.Response.class, io.cloudquery.plugin.v3.TransformSchema.Response.Builder.class);
+      }
+
+      // Construct using io.cloudquery.plugin.v3.TransformSchema.Response.newBuilder()
+      private Builder() {
+
+      }
+
+      private Builder(
+          com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+        super(parent);
+
+      }
+      @java.lang.Override
+      public Builder clear() {
+        super.clear();
+        bitField0_ = 0;
+        schema_ = com.google.protobuf.ByteString.EMPTY;
+        return this;
+      }
+
+      @java.lang.Override
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_Response_descriptor;
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Response getDefaultInstanceForType() {
+        return io.cloudquery.plugin.v3.TransformSchema.Response.getDefaultInstance();
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Response build() {
+        io.cloudquery.plugin.v3.TransformSchema.Response result = buildPartial();
+        if (!result.isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return result;
+      }
+
+      @java.lang.Override
+      public io.cloudquery.plugin.v3.TransformSchema.Response buildPartial() {
+        io.cloudquery.plugin.v3.TransformSchema.Response result = new io.cloudquery.plugin.v3.TransformSchema.Response(this);
+        if (bitField0_ != 0) { buildPartial0(result); }
+        onBuilt();
+        return result;
+      }
+
+      private void buildPartial0(io.cloudquery.plugin.v3.TransformSchema.Response result) {
+        int from_bitField0_ = bitField0_;
+        if (((from_bitField0_ & 0x00000001) != 0)) {
+          result.schema_ = schema_;
+        }
+      }
+
+      @java.lang.Override
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof io.cloudquery.plugin.v3.TransformSchema.Response) {
+          return mergeFrom((io.cloudquery.plugin.v3.TransformSchema.Response)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+
+      public Builder mergeFrom(io.cloudquery.plugin.v3.TransformSchema.Response other) {
+        if (other == io.cloudquery.plugin.v3.TransformSchema.Response.getDefaultInstance()) return this;
+        if (other.getSchema() != com.google.protobuf.ByteString.EMPTY) {
+          setSchema(other.getSchema());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        onChanged();
+        return this;
+      }
+
+      @java.lang.Override
+      public final boolean isInitialized() {
+        return true;
+      }
+
+      @java.lang.Override
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        if (extensionRegistry == null) {
+          throw new java.lang.NullPointerException();
+        }
+        try {
+          boolean done = false;
+          while (!done) {
+            int tag = input.readTag();
+            switch (tag) {
+              case 0:
+                done = true;
+                break;
+              case 10: {
+                schema_ = input.readBytes();
+                bitField0_ |= 0x00000001;
+                break;
+              } // case 10
+              default: {
+                if (!super.parseUnknownField(input, extensionRegistry, tag)) {
+                  done = true; // was an endgroup tag
+                }
+                break;
+              } // default:
+            } // switch (tag)
+          } // while (!done)
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          throw e.unwrapIOException();
+        } finally {
+          onChanged();
+        } // finally
+        return this;
+      }
+      private int bitField0_;
+
+      private com.google.protobuf.ByteString schema_ = com.google.protobuf.ByteString.EMPTY;
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @return The schema.
+       */
+      @java.lang.Override
+      public com.google.protobuf.ByteString getSchema() {
+        return schema_;
+      }
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @param value The schema to set.
+       * @return This builder for chaining.
+       */
+      public Builder setSchema(com.google.protobuf.ByteString value) {
+        if (value == null) { throw new NullPointerException(); }
+        schema_ = value;
+        bitField0_ |= 0x00000001;
+        onChanged();
+        return this;
+      }
+      /**
+       * 
+       * marshalled arrow.Schema
+       * 

+       *
+       * bytes schema = 1;
+       * @return This builder for chaining.
+       */
+      public Builder clearSchema() {
+        bitField0_ = (bitField0_ & ~0x00000001);
+        schema_ = getDefaultInstance().getSchema();
+        onChanged();
+        return this;
+      }
+
+      // @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.TransformSchema.Response)
+    }
+
+    // @@protoc_insertion_point(class_scope:cloudquery.plugin.v3.TransformSchema.Response)
+    private static final io.cloudquery.plugin.v3.TransformSchema.Response DEFAULT_INSTANCE;
+    static {
+      DEFAULT_INSTANCE = new io.cloudquery.plugin.v3.TransformSchema.Response();
+    }
+
+    public static io.cloudquery.plugin.v3.TransformSchema.Response getDefaultInstance() {
+      return DEFAULT_INSTANCE;
+    }
+
+    private static final com.google.protobuf.Parser
+        PARSER = new com.google.protobuf.AbstractParser() {
+      @java.lang.Override
+      public Response parsePartialFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        Builder builder = newBuilder();
+        try {
+          builder.mergeFrom(input, extensionRegistry);
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          throw e.setUnfinishedMessage(builder.buildPartial());
+        } catch (com.google.protobuf.UninitializedMessageException e) {
+          throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
+        } catch (java.io.IOException e) {
+          throw new com.google.protobuf.InvalidProtocolBufferException(e)
+              .setUnfinishedMessage(builder.buildPartial());
+        }
+        return builder.buildPartial();
+      }
+    };
+
+    public static com.google.protobuf.Parser parser() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Parser getParserForType() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public io.cloudquery.plugin.v3.TransformSchema.Response getDefaultInstanceForType() {
+      return DEFAULT_INSTANCE;
+    }
+
+  }
+
+  private byte memoizedIsInitialized = -1;
+  @java.lang.Override
+  public final boolean isInitialized() {
+    byte isInitialized = memoizedIsInitialized;
+    if (isInitialized == 1) return true;
+    if (isInitialized == 0) return false;
+
+    memoizedIsInitialized = 1;
+    return true;
+  }
+
+  @java.lang.Override
+  public void writeTo(com.google.protobuf.CodedOutputStream output)
+                      throws java.io.IOException {
+    getUnknownFields().writeTo(output);
+  }
+
+  @java.lang.Override
+  public int getSerializedSize() {
+    int size = memoizedSize;
+    if (size != -1) return size;
+
+    size = 0;
+    size += getUnknownFields().getSerializedSize();
+    memoizedSize = size;
+    return size;
+  }
+
+  @java.lang.Override
+  public boolean equals(final java.lang.Object obj) {
+    if (obj == this) {
+     return true;
+    }
+    if (!(obj instanceof io.cloudquery.plugin.v3.TransformSchema)) {
+      return super.equals(obj);
+    }
+    io.cloudquery.plugin.v3.TransformSchema other = (io.cloudquery.plugin.v3.TransformSchema) obj;
+
+    if (!getUnknownFields().equals(other.getUnknownFields())) return false;
+    return true;
+  }
+
+  @java.lang.Override
+  public int hashCode() {
+    if (memoizedHashCode != 0) {
+      return memoizedHashCode;
+    }
+    int hash = 41;
+    hash = (19 * hash) + getDescriptor().hashCode();
+    hash = (29 * hash) + getUnknownFields().hashCode();
+    memoizedHashCode = hash;
+    return hash;
+  }
+
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      java.nio.ByteBuffer data)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      java.nio.ByteBuffer data,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data, extensionRegistry);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      com.google.protobuf.ByteString data)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      com.google.protobuf.ByteString data,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data, extensionRegistry);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(byte[] data)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      byte[] data,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws com.google.protobuf.InvalidProtocolBufferException {
+    return PARSER.parseFrom(data, extensionRegistry);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(java.io.InputStream input)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseWithIOException(PARSER, input);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      java.io.InputStream input,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseWithIOException(PARSER, input, extensionRegistry);
+  }
+
+  public static io.cloudquery.plugin.v3.TransformSchema parseDelimitedFrom(java.io.InputStream input)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseDelimitedWithIOException(PARSER, input);
+  }
+
+  public static io.cloudquery.plugin.v3.TransformSchema parseDelimitedFrom(
+      java.io.InputStream input,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      com.google.protobuf.CodedInputStream input)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseWithIOException(PARSER, input);
+  }
+  public static io.cloudquery.plugin.v3.TransformSchema parseFrom(
+      com.google.protobuf.CodedInputStream input,
+      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+      throws java.io.IOException {
+    return com.google.protobuf.GeneratedMessage
+        .parseWithIOException(PARSER, input, extensionRegistry);
+  }
+
+  @java.lang.Override
+  public Builder newBuilderForType() { return newBuilder(); }
+  public static Builder newBuilder() {
+    return DEFAULT_INSTANCE.toBuilder();
+  }
+  public static Builder newBuilder(io.cloudquery.plugin.v3.TransformSchema prototype) {
+    return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+  }
+  @java.lang.Override
+  public Builder toBuilder() {
+    return this == DEFAULT_INSTANCE
+        ? new Builder() : new Builder().mergeFrom(this);
+  }
+
+  @java.lang.Override
+  protected Builder newBuilderForType(
+      com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+    Builder builder = new Builder(parent);
+    return builder;
+  }
+  /**
+   * Protobuf type {@code cloudquery.plugin.v3.TransformSchema}
+   */
+  public static final class Builder extends
+      com.google.protobuf.GeneratedMessage.Builder implements
+      // @@protoc_insertion_point(builder_implements:cloudquery.plugin.v3.TransformSchema)
+      io.cloudquery.plugin.v3.TransformSchemaOrBuilder {
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_descriptor;
+    }
+
+    @java.lang.Override
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              io.cloudquery.plugin.v3.TransformSchema.class, io.cloudquery.plugin.v3.TransformSchema.Builder.class);
+    }
+
+    // Construct using io.cloudquery.plugin.v3.TransformSchema.newBuilder()
+    private Builder() {
+
+    }
+
+    private Builder(
+        com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+      super(parent);
+
+    }
+    @java.lang.Override
+    public Builder clear() {
+      super.clear();
+      return this;
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Descriptors.Descriptor
+        getDescriptorForType() {
+      return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_TransformSchema_descriptor;
+    }
+
+    @java.lang.Override
+    public io.cloudquery.plugin.v3.TransformSchema getDefaultInstanceForType() {
+      return io.cloudquery.plugin.v3.TransformSchema.getDefaultInstance();
+    }
+
+    @java.lang.Override
+    public io.cloudquery.plugin.v3.TransformSchema build() {
+      io.cloudquery.plugin.v3.TransformSchema result = buildPartial();
+      if (!result.isInitialized()) {
+        throw newUninitializedMessageException(result);
+      }
+      return result;
+    }
+
+    @java.lang.Override
+    public io.cloudquery.plugin.v3.TransformSchema buildPartial() {
+      io.cloudquery.plugin.v3.TransformSchema result = new io.cloudquery.plugin.v3.TransformSchema(this);
+      onBuilt();
+      return result;
+    }
+
+    @java.lang.Override
+    public Builder mergeFrom(com.google.protobuf.Message other) {
+      if (other instanceof io.cloudquery.plugin.v3.TransformSchema) {
+        return mergeFrom((io.cloudquery.plugin.v3.TransformSchema)other);
+      } else {
+        super.mergeFrom(other);
+        return this;
+      }
+    }
+
+    public Builder mergeFrom(io.cloudquery.plugin.v3.TransformSchema other) {
+      if (other == io.cloudquery.plugin.v3.TransformSchema.getDefaultInstance()) return this;
+      this.mergeUnknownFields(other.getUnknownFields());
+      onChanged();
+      return this;
+    }
+
+    @java.lang.Override
+    public final boolean isInitialized() {
+      return true;
+    }
+
+    @java.lang.Override
+    public Builder mergeFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      if (extensionRegistry == null) {
+        throw new java.lang.NullPointerException();
+      }
+      try {
+        boolean done = false;
+        while (!done) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              done = true;
+              break;
+            default: {
+              if (!super.parseUnknownField(input, extensionRegistry, tag)) {
+                done = true; // was an endgroup tag
+              }
+              break;
+            } // default:
+          } // switch (tag)
+        } // while (!done)
+      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+        throw e.unwrapIOException();
+      } finally {
+        onChanged();
+      } // finally
+      return this;
+    }
+
+    // @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.TransformSchema)
+  }
+
+  // @@protoc_insertion_point(class_scope:cloudquery.plugin.v3.TransformSchema)
+  private static final io.cloudquery.plugin.v3.TransformSchema DEFAULT_INSTANCE;
+  static {
+    DEFAULT_INSTANCE = new io.cloudquery.plugin.v3.TransformSchema();
+  }
+
+  public static io.cloudquery.plugin.v3.TransformSchema getDefaultInstance() {
+    return DEFAULT_INSTANCE;
+  }
+
+  private static final com.google.protobuf.Parser
+      PARSER = new com.google.protobuf.AbstractParser() {
+    @java.lang.Override
+    public TransformSchema parsePartialFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      Builder builder = newBuilder();
+      try {
+        builder.mergeFrom(input, extensionRegistry);
+      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+        throw e.setUnfinishedMessage(builder.buildPartial());
+      } catch (com.google.protobuf.UninitializedMessageException e) {
+        throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
+      } catch (java.io.IOException e) {
+        throw new com.google.protobuf.InvalidProtocolBufferException(e)
+            .setUnfinishedMessage(builder.buildPartial());
+      }
+      return builder.buildPartial();
+    }
+  };
+
+  public static com.google.protobuf.Parser parser() {
+    return PARSER;
+  }
+
+  @java.lang.Override
+  public com.google.protobuf.Parser getParserForType() {
+    return PARSER;
+  }
+
+  @java.lang.Override
+  public io.cloudquery.plugin.v3.TransformSchema getDefaultInstanceForType() {
+    return DEFAULT_INSTANCE;
+  }
+
+}
+
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java
new file mode 100644
index 0000000..d2b17b8
--- /dev/null
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java
@@ -0,0 +1,11 @@
+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+// NO CHECKED-IN PROTOBUF GENCODE
+// source: cloudquery/plugin/v3/plugin.proto
+// Protobuf Java Version: 4.27.2
+
+package io.cloudquery.plugin.v3;
+
+public interface TransformSchemaOrBuilder extends
+    // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TransformSchema)
+    com.google.protobuf.MessageOrBuilder {
+}
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
index b672977..d652335 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
@@ -1036,7 +1036,7 @@ public interface MessageDeleteStaleOrBuilder extends
      *
      * bytes table = 1 [deprecated = true];
      * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-     *     See cloudquery/plugin/v3/plugin.proto;l=173
+     *     See cloudquery/plugin/v3/plugin.proto;l=175
      * @return The table.
      */
     @java.lang.Deprecated com.google.protobuf.ByteString getTable();
@@ -1130,7 +1130,7 @@ private MessageDeleteStale() {
      *
      * bytes table = 1 [deprecated = true];
      * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-     *     See cloudquery/plugin/v3/plugin.proto;l=173
+     *     See cloudquery/plugin/v3/plugin.proto;l=175
      * @return The table.
      */
     @java.lang.Override
@@ -1636,7 +1636,7 @@ public Builder mergeFrom(
        *
        * bytes table = 1 [deprecated = true];
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=173
+       *     See cloudquery/plugin/v3/plugin.proto;l=175
        * @return The table.
        */
       @java.lang.Override
@@ -1650,7 +1650,7 @@ public Builder mergeFrom(
        *
        * bytes table = 1 [deprecated = true];
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=173
+       *     See cloudquery/plugin/v3/plugin.proto;l=175
        * @param value The table to set.
        * @return This builder for chaining.
        */
@@ -1668,7 +1668,7 @@ public Builder mergeFrom(
        *
        * bytes table = 1 [deprecated = true];
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=173
+       *     See cloudquery/plugin/v3/plugin.proto;l=175
        * @return This builder for chaining.
        */
       @java.lang.Deprecated public Builder clearTable() {
diff --git a/src/main/proto/cloudquery/plugin/v3/plugin.proto b/src/main/proto/cloudquery/plugin/v3/plugin.proto
index 55484a8..8cbddcf 100644
--- a/src/main/proto/cloudquery/plugin/v3/plugin.proto
+++ b/src/main/proto/cloudquery/plugin/v3/plugin.proto
@@ -29,6 +29,8 @@ service Plugin {
   rpc Write(stream Write.Request) returns (Write.Response);
   // Transform resources.
   rpc Transform(stream Transform.Request) returns (stream Transform.Response);
+  // Transform schemas.
+  rpc TransformSchema(stream TransformSchema.Request) returns (stream TransformSchema.Response);
   // Send signal to flush and close open connections
   rpc Close(Close.Request) returns (Close.Response);
   // Validate and test the connections used by the plugin
@@ -203,6 +205,17 @@ message Transform {
   }
 }
 
+message TransformSchema {
+  message Request {
+    // marshalled arrow.Schema
+    bytes schema = 1;
+  }
+  message Response {
+    // marshalled arrow.Schema
+    bytes schema = 1;
+  }
+}
+
 message Close {
   message Request {}
   message Response {}