Add javadoc

extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/output/AzureStorageConnectorProvider.java

@@ -54,9 +54,9 @@ public AzureStorageConnectorProvider(
   }
 
   @Override
-  public StorageConnector createStorageConnector(final File tempDir)
+  public StorageConnector createStorageConnector(final File defaultTempDir)
   {
-    AzureOutputConfig config = this.getTempDir() == null ? this.withTempDir(tempDir) : this;
+    AzureOutputConfig config = this.getTempDir() == null ? this.withTempDir(defaultTempDir) : this;
     config.validateTempDirectory();
     return new AzureStorageConnector(config, azureStorage);
   }

extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/output/GoogleStorageConnectorProvider.java

@@ -56,9 +56,9 @@ public GoogleStorageConnectorProvider(
   }
 
   @Override
-  public StorageConnector createStorageConnector(File tempDir)
+  public StorageConnector createStorageConnector(File defaultTempDir)
   {
-    GoogleOutputConfig config = this.getTempDir() == null ? this.withTempDir(tempDir) : this;
+    GoogleOutputConfig config = this.getTempDir() == null ? this.withTempDir(defaultTempDir) : this;
     return new GoogleStorageConnector(config, googleStorage, googleInputDataConfig);
   }
 }

extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java

@@ -109,7 +109,10 @@ WorkerManager newWorkerManager(
   /**
    * Fetch a directory for temporary outputs
    */
-  File taskTempDir();
+  default File taskTempDir()
+  {
+    throw new UnsupportedOperationException();
+  }
 
   /**
    * Client for communicating with workers.

extensions-core/s3-extensions/src/main/java/org/apache/druid/storage/s3/output/S3StorageConnectorProvider.java

@@ -55,9 +55,9 @@ public S3StorageConnectorProvider(
   }
 
   @Override
-  public StorageConnector createStorageConnector(File tempDir)
+  public StorageConnector createStorageConnector(File defaultTempDir)
   {
-    S3OutputConfig config = this.getTempDir() == null ? this.withTempDir(tempDir) : this;
+    S3OutputConfig config = this.getTempDir() == null ? this.withTempDir(defaultTempDir) : this;
     return new S3StorageConnector(config, s3, s3UploadManager);
   }
 }

processing/src/main/java/org/apache/druid/storage/StorageConnectorProvider.java

@@ -26,5 +26,14 @@
 @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type")
 public interface StorageConnectorProvider
 {
-  StorageConnector createStorageConnector(File tempDir);
+  /**
+   * Returns the storage connector. Takes a parameter defaultTempDir to be possibly used as the temporary directory, if the
+   * storage connector requires one. This StorageConnectorProvider is not guaranteed to use this value, even if the
+   * StorageConnectorProvider requires one, as it gives priority to a value of defaultTempDir configured as a runtime
+   * configuration.
+   * <br>
+   * This value needs to be passed instead of injected by Jackson as the default temporary directory is dependent on the
+   * task id, and such dynamic task specific bindings is not possible on indexers.
+   */
+  StorageConnector createStorageConnector(File defaultTempDir);
 }

processing/src/main/java/org/apache/druid/storage/local/LocalFileStorageConnectorProvider.java

@@ -45,7 +45,7 @@ public LocalFileStorageConnectorProvider(@JsonProperty(value = "basePath", requi
   }
 
   @Override
-  public StorageConnector createStorageConnector(File tempDir)
+  public StorageConnector createStorageConnector(File defaultTempDir)
   {
     try {
       return new LocalFileStorageConnector(basePath);