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 index 9d7e2a1850ef..363a39bbb6ac 100644 --- 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 index 0e7daf373ac3..d2d68d705ddd 100644 --- 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 index 431904072539..5c8348ef2a86 100644 --- 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 index e66e1c24168a..f4079441850f 100644 --- 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 index 58484e065f39..b349c6165206 100644 --- 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 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 index 6cf893baafcb..51fe583251bb 100644 --- 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 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 index 2c9d0de98323..cb853176ae2f 100644 --- 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 index cee6657750b4..6c68b733b1b5 100644 --- 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 index 039788af0216..0141923833f2 100644 --- 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,7 +15,6 @@ import com.google.errorprone.annotations.ThreadSafe; import io.airlift.slice.Slice; -import io.trino.spi.Experimental; import jakarta.annotation.Nullable; import java.io.Closeable; @@ -23,7 +22,6 @@ 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 index e37b506b3bce..5583c99a6b05 100644 --- 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 index 20ee790db21e..ca52fcc203d7 100644 --- 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;