Document ConnectorSplitSource thread-safety requirements

Note that some existing implementations are not thread-safe. For example `IcebergSplitSource.scannedFiles` is accessed without any synchronization.
trinodb · May 5, 2023 · 9054f64 · 9054f64
1 parent a3af0e1
commit 9054f64
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorSplitSource.java b/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorSplitSource.java
@@ -20,6 +20,11 @@
 
 import static java.util.Objects.requireNonNull;
 
+/**
+ * Source of splits to be processed.
+ * <p>
+ * Thread-safety: the implementations are not required to be thread-safe.
+ */
 public interface ConnectorSplitSource
         extends Closeable
 {