Remove experimental annotation from exchange interface

The experimental designation for exchanges had an ETA of 9/1/23 and can now be removed.
trinodb · Jan 19, 2024 · 292c101 · 292c101
1 parent 664a39f
commit 292c101
Show file tree

Hide file tree

Showing 11 changed files with 0 additions and 28 deletions.
diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeContext.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeContext.java
@@ -14,10 +14,8 @@
 package io.trino.spi.exchange;
 
 import io.opentelemetry.api.trace.Span;
-import io.trino.spi.Experimental;
 import io.trino.spi.QueryId;
 
-@Experimental(eta = "2023-09-01")
 public interface ExchangeContext
 {
     QueryId getQueryId();

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeId.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeId.java
@@ -15,7 +15,6 @@
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonValue;
-import io.trino.spi.Experimental;
 
 import java.util.Objects;
 import java.util.regex.Pattern;
@@ -25,7 +24,6 @@
 import static java.util.Objects.requireNonNull;
 import static java.util.UUID.randomUUID;
 
-@Experimental(eta = "2023-09-01")
 public class ExchangeId
 {
     private static final long INSTANCE_SIZE = instanceSize(ExchangeId.class);

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManager.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManager.java
@@ -15,7 +15,6 @@
 
 import com.google.errorprone.annotations.ThreadSafe;
 import io.airlift.slice.Slice;
-import io.trino.spi.Experimental;
 
 /**
  * Service provider interface for an external exchange
@@ -37,7 +36,6 @@
  * data written by other instances must be safely discarded
  */
 @ThreadSafe
-@Experimental(eta = "2023-09-01")
 public interface ExchangeManager
 {
     /**

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManagerFactory.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManagerFactory.java
@@ -13,11 +13,8 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
 import java.util.Map;
 
-@Experimental(eta = "2023-09-01")
 public interface ExchangeManagerFactory
 {
     String getName();

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManagerHandleResolver.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeManagerHandleResolver.java
@@ -13,9 +13,6 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
-@Experimental(eta = "2023-09-01")
 public interface ExchangeManagerHandleResolver
 {
     Class<? extends ExchangeSinkInstanceHandle> getExchangeSinkInstanceHandleClass();

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSink.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSink.java
@@ -15,12 +15,10 @@
 
 import com.google.errorprone.annotations.ThreadSafe;
 import io.airlift.slice.Slice;
-import io.trino.spi.Experimental;
 
 import java.util.concurrent.CompletableFuture;
 
 @ThreadSafe
-@Experimental(eta = "2023-09-01")
 public interface ExchangeSink
 {
     CompletableFuture<Void> NOT_BLOCKED = CompletableFuture.completedFuture(null);

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSinkHandle.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSinkHandle.java
@@ -13,12 +13,9 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
 /*
  * Implementation is expected to be Jackson serializable
  */
-@Experimental(eta = "2023-09-01")
 public interface ExchangeSinkHandle
 {
 }
diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSinkInstanceHandle.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSinkInstanceHandle.java
@@ -13,9 +13,6 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
-@Experimental(eta = "2023-09-01")
 public interface ExchangeSinkInstanceHandle
 {
 }
diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSource.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSource.java
@@ -15,15 +15,13 @@
 
 import com.google.errorprone.annotations.ThreadSafe;
 import io.airlift.slice.Slice;
-import io.trino.spi.Experimental;
 import jakarta.annotation.Nullable;
 
 import java.io.Closeable;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
 @ThreadSafe
-@Experimental(eta = "2023-09-01")
 public interface ExchangeSource
         extends Closeable
 {

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSourceHandle.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSourceHandle.java
@@ -13,12 +13,9 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
 /*
  * Implementation is expected to be Jackson serializable
  */
-@Experimental(eta = "2023-09-01")
 public interface ExchangeSourceHandle
 {
     int getPartitionId();

diff --git a/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSourceStatistics.java b/core/trino-spi/src/main/java/io/trino/spi/exchange/ExchangeSourceStatistics.java
@@ -13,9 +13,6 @@
  */
 package io.trino.spi.exchange;
 
-import io.trino.spi.Experimental;
-
-@Experimental(eta = "2023-09-01")
 public class ExchangeSourceStatistics
 {
     private final long sizeInBytes;