add user-agent parameter

README.md

@@ -12,6 +12,9 @@ Databricks output plugin for Embulk loads records to Databricks Delta Table.
 
 - **driver_path**: path to the jar file of the JDBC driver. If not set, [the bundled JDBC driver](https://docs.databricks.com/en/integrations/jdbc/index.html) will be used. (string, optional)
 - **options**: extra JDBC properties (hash, default: {})
+- **user_agent**: set user agent property to JDBC and SDK connection. If 'UserAgentEntry' property is specified in the **options**, it will be overwritten by this value. (hash, optional)
+  - **product_name**: product name of user agent (string)
+  - **product_version**: product version of user agent (string)
 - **server_hostname**: The Databricks compute resource’s Server Hostname value, see [Compute settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/compute.html). (string, required)
 - **http_path**: The Databricks compute resource’s HTTP Path value, see [Compute settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/compute.html). (string, required)
 - **personal_access_token**: The Databaricks personal_access_token, see [Authentication settings for the Databricks JDBC Driver](https://docs.databricks.com/en/integrations/jdbc/authentication.html#authentication-pat). (string, required)

src/main/java/org/embulk/output/DatabricksOutputPlugin.java

@@ -52,6 +52,10 @@ public interface DatabricksPluginTask extends PluginTask {
     @Config("delete_stage_on_error")
     @ConfigDefault("false")
     public boolean getDeleteStageOnError();
+
+    @Config("user_agent")
+    @ConfigDefault("null")
+    public Optional<Map<String, String>> getUserAgent();
   }
 
   @Override
@@ -92,6 +96,14 @@ protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMet
     props.put("ConnCatalog", t.getCatalogName());
     props.put("ConnSchema", t.getSchemaName());
     props.putAll(t.getOptions());
+    // overwrite UserAgentEntry property if the same property is set in options
+    if (t.getUserAgent().isPresent()) {
+      String product_name = t.getUserAgent().get().get("product_name");
+      String product_version = t.getUserAgent().get().get("product_version");
+
+      props.put("UserAgentEntry", product_name + "/" + product_version);
+    }
+
     logConnectionProperties(url, props);
     return new DatabricksOutputConnector(
         url, props, t.getTransactionIsolation(), t.getCatalogName(), t.getSchemaName());

src/main/java/org/embulk/output/databricks/DatabricksAPIClient.java

@@ -2,6 +2,7 @@
 
 import com.databricks.sdk.WorkspaceClient;
 import com.databricks.sdk.core.DatabricksConfig;
+import com.databricks.sdk.core.UserAgent;
 import com.databricks.sdk.service.catalog.VolumeType;
 import java.io.InputStream;
 import java.text.SimpleDateFormat;
@@ -11,9 +12,18 @@
 
 public class DatabricksAPIClient {
   public static DatabricksAPIClient create(DatabricksOutputPlugin.DatabricksPluginTask task) {
+    SetUserAgent(task);
+
     return new DatabricksAPIClient(createDatabricksConfig(task));
   }
 
+  private static void SetUserAgent(DatabricksOutputPlugin.DatabricksPluginTask task) {
+    String name = task.getUserAgent().get().get("product_name");
+    String version = task.getUserAgent().get().get("product_version");
+
+    UserAgent.withProduct(name, version);
+  }
+
   private final WorkspaceClient workspaceClient;
 
   public DatabricksAPIClient(DatabricksConfig config) {