This is an automated email from the ASF dual-hosted git repository.
huaxingao pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 0d83e6fa3d Core, Parquet, AWS: Remove deprecations for 1.13.0 (#18334)
0d83e6fa3d is described below
commit 0d83e6fa3d2e35f3757519ce777420ae3eeb8efc
Author: Yuya Ebihara <[email protected]>
AuthorDate: Wed Oct 7 02:01:35 2026 +0900
Core, Parquet, AWS: Remove deprecations for 1.13.0 (#18334)
---
.palantir/revapi.yml | 68 ++++++++++++++++++++
.../aws/s3/signer/S3V4RestSignerClient.java | 30 ++-------
.../aws/s3/signer/TestS3V4RestSignerClient.java | 48 --------------
.../java/org/apache/iceberg/MetricsConfig.java | 11 ----
.../org/apache/iceberg/RewriteTablePathUtil.java | 73 ----------------------
.../apache/iceberg/deletes/BaseDVFileWriter.java | 12 ----
.../encryption/StandardEncryptionManager.java | 12 ----
.../apache/iceberg/io/BasePositionDeltaWriter.java | 3 +-
.../org/apache/iceberg/io/PositionDeltaWriter.java | 21 +------
.../apache/iceberg/rest/RESTCatalogProperties.java | 17 -----
.../apache/iceberg/rest/RESTSessionCatalog.java | 26 --------
.../apache/iceberg/parquet/ParquetFormatModel.java | 21 -------
12 files changed, 74 insertions(+), 268 deletions(-)
diff --git a/.palantir/revapi.yml b/.palantir/revapi.yml
index ccde81f8b1..81d5fa6072 100644
--- a/.palantir/revapi.yml
+++ b/.palantir/revapi.yml
@@ -1039,6 +1039,74 @@ acceptedBreaks:
\ extends org.apache.iceberg.StructLike>"
justification: "Removing deprecated createStructReader overload
scheduled for\
\ removal in 1.12.0"
+ "1.12.0":
+ org.apache.iceberg:iceberg-core:
+ - code: "java.field.removedWithConstant"
+ old: "field
org.apache.iceberg.rest.RESTCatalogProperties.SIGNER_ENDPOINT"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.field.removedWithConstant"
+ old: "field org.apache.iceberg.rest.RESTCatalogProperties.SIGNER_URI"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.noLongerDefault"
+ old: "method void
org.apache.iceberg.io.PositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ new: "method void
org.apache.iceberg.io.PositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.nowAbstract"
+ old: "method void
org.apache.iceberg.io.PositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ new: "method void
org.apache.iceberg.io.PositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method java.lang.String
org.apache.iceberg.encryption.StandardEncryptionManager::addManifestListKeyMetadata(org.apache.iceberg.encryption.NativeEncryptionKeyMetadata)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method org.apache.iceberg.MetricsConfig
org.apache.iceberg.MetricsConfig::fromProperties(java.util.Map<java.lang.String,\
+ \ java.lang.String>)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method
org.apache.iceberg.RewriteTablePathUtil.RewriteResult<org.apache.iceberg.DeleteFile>\
+ \
org.apache.iceberg.RewriteTablePathUtil::rewriteDeleteManifest(org.apache.iceberg.ManifestFile,\
+ \ java.util.Set<java.lang.Long>, org.apache.iceberg.io.OutputFile,
org.apache.iceberg.io.FileIO,\
+ \ int, java.util.Map<java.lang.Integer,
org.apache.iceberg.PartitionSpec>,\
+ \ java.lang.String, java.lang.String, java.lang.String) throws
java.io.IOException"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method org.apache.iceberg.rest.RESTTableOperations
org.apache.iceberg.rest.RESTSessionCatalog::newTableOps(org.apache.iceberg.rest.RESTClient,\
+ \ java.lang.String,
java.util.function.Supplier<java.util.Map<java.lang.String,\
+ \ java.lang.String>>,
java.util.function.Supplier<java.util.Map<java.lang.String,\
+ \ java.lang.String>>, org.apache.iceberg.io.FileIO,
org.apache.iceberg.TableMetadata,\
+ \ java.util.Set<org.apache.iceberg.rest.Endpoint>)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method void
org.apache.iceberg.RewriteTablePathUtil::rewritePositionDeleteFile(org.apache.iceberg.DeleteFile,\
+ \ org.apache.iceberg.io.OutputFile, org.apache.iceberg.io.FileIO,
org.apache.iceberg.PartitionSpec,\
+ \ java.lang.String, java.lang.String,
org.apache.iceberg.RewriteTablePathUtil.PositionDeleteReaderWriter)\
+ \ throws java.io.IOException"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method void
org.apache.iceberg.deletes.BaseDVFileWriter::<init>(java.util.function.Supplier<org.apache.iceberg.io.OutputFile>,\
+ \ java.util.function.Function<java.lang.String,
org.apache.iceberg.deletes.PositionDeleteIndex>)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method void
org.apache.iceberg.io.BasePositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, T, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ justification: "Removing deprecations for 1.13.0"
+ - code: "java.method.removed"
+ old: "method void
org.apache.iceberg.io.PositionDeltaWriter<T>::delete(java.lang.CharSequence,\
+ \ long, T, org.apache.iceberg.PartitionSpec,
org.apache.iceberg.StructLike)"
+ justification: "Removing deprecations for 1.13.0"
+ org.apache.iceberg:iceberg-parquet:
+ - code: "java.method.removed"
+ old: "method <D, S> org.apache.iceberg.parquet.ParquetFormatModel<D,
S, org.apache.iceberg.parquet.ParquetValueReader<?>>\
+ \ org.apache.iceberg.parquet.ParquetFormatModel<D, S,
R>::create(java.lang.Class<D>,\
+ \ java.lang.Class<S>,
org.apache.iceberg.formats.BaseFormatModel.WriterFunction<org.apache.iceberg.parquet.ParquetValueWriter<?>,\
+ \ S, org.apache.parquet.schema.MessageType>,
org.apache.iceberg.formats.BaseFormatModel.ReaderFunction<org.apache.iceberg.parquet.ParquetValueReader<?>,\
+ \ S, org.apache.parquet.schema.MessageType>,
org.apache.iceberg.parquet.VariantShreddingAnalyzer<D,\
+ \ S>, java.util.function.UnaryOperator<D>)"
+ justification: "Removing deprecations for 1.13.0"
"1.2.0":
org.apache.iceberg:iceberg-api:
- code: "java.field.constantValueChanged"
diff --git
a/aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3V4RestSignerClient.java
b/aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3V4RestSignerClient.java
index b3d24e5afa..2d28841172 100644
---
a/aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3V4RestSignerClient.java
+++
b/aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3V4RestSignerClient.java
@@ -105,17 +105,12 @@ public abstract class S3V4RestSignerClient
@Value.Lazy
public String baseSignerUri() {
- return properties()
- .getOrDefault(RESTCatalogProperties.SIGNER_URI,
properties().get(CatalogProperties.URI));
+ return properties().get(CatalogProperties.URI);
}
@Value.Lazy
public String endpoint() {
- String endpointPath =
- properties()
- .getOrDefault(
- RESTCatalogProperties.SIGNER_ENDPOINT,
-
properties().get(RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT));
+ String endpointPath =
properties().get(RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT);
return RESTUtil.resolveEndpoint(baseSignerUri(), endpointPath);
}
@@ -225,28 +220,11 @@ public abstract class S3V4RestSignerClient
@Value.Check
protected void check() {
Preconditions.checkArgument(
- properties().containsKey(RESTCatalogProperties.SIGNER_ENDPOINT)
- ||
properties().containsKey(RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT),
+
properties().containsKey(RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT),
"Remote signing endpoint is required");
Preconditions.checkArgument(
- properties().containsKey(RESTCatalogProperties.SIGNER_URI)
- || properties().containsKey(CatalogProperties.URI),
- "S3 signer service URI is required");
-
- if (properties().containsKey(RESTCatalogProperties.SIGNER_URI)) {
- LOG.warn(
- "S3 signer URI is configured via deprecated property {}, this won't
be supported in future releases. "
- + "Please remove this property to let the signer use the default
URI instead.",
- RESTCatalogProperties.SIGNER_URI);
- }
-
- if (properties().containsKey(RESTCatalogProperties.SIGNER_ENDPOINT)) {
- LOG.warn(
- "Signer endpoint is configured via deprecated property {}, this
won't be supported in future releases. "
- + "Please remove this property to let the signer use the default
endpoint instead.",
- RESTCatalogProperties.SIGNER_ENDPOINT);
- }
+ properties().containsKey(CatalogProperties.URI), "S3 signer service
URI is required");
}
@Override
diff --git
a/aws/src/test/java/org/apache/iceberg/aws/s3/signer/TestS3V4RestSignerClient.java
b/aws/src/test/java/org/apache/iceberg/aws/s3/signer/TestS3V4RestSignerClient.java
index c566196469..f7a9d013f5 100644
---
a/aws/src/test/java/org/apache/iceberg/aws/s3/signer/TestS3V4RestSignerClient.java
+++
b/aws/src/test/java/org/apache/iceberg/aws/s3/signer/TestS3V4RestSignerClient.java
@@ -262,52 +262,4 @@ class TestS3V4RestSignerClient {
"custom",
"token"));
}
-
- @ParameterizedTest
- @MethodSource("legacySignerProperties")
- void legacySignerProperties(
- Map<String, String> properties, String expectedBaseSignerUri, String
expectedEndpoint)
- throws Exception {
- try (S3V4RestSignerClient client =
-
ImmutableS3V4RestSignerClient.builder().properties(properties).build()) {
- assertThat(client.baseSignerUri()).isEqualTo(expectedBaseSignerUri);
- assertThat(client.endpoint()).isEqualTo(expectedEndpoint);
- }
- }
-
- @SuppressWarnings("deprecation")
- public static Stream<Arguments> legacySignerProperties() {
- return Stream.of(
- // Only legacy properties
- Arguments.of(
- Map.of(
- RESTCatalogProperties.SIGNER_URI,
- "https://legacy-signer.com";,
- RESTCatalogProperties.SIGNER_ENDPOINT,
- "v1/legacy/sign"),
- "https://legacy-signer.com";,
- "https://legacy-signer.com/v1/legacy/sign";),
- // Only new properties
- Arguments.of(
- Map.of(
- CatalogProperties.URI,
- "https://new-signer.com";,
- RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT,
- "v1/new/sign"),
- "https://new-signer.com";,
- "https://new-signer.com/v1/new/sign";),
- // Mixed properties: legacy properties take precedence
- Arguments.of(
- Map.of(
- CatalogProperties.URI,
- "https://new-signer.com";,
- RESTCatalogProperties.REMOTE_SIGNING_ENDPOINT,
- "v1/new/sign",
- RESTCatalogProperties.SIGNER_URI,
- "https://legacy-signer.com";,
- RESTCatalogProperties.SIGNER_ENDPOINT,
- "v1/legacy/sign"),
- "https://legacy-signer.com";,
- "https://legacy-signer.com/v1/legacy/sign";));
- }
}
diff --git a/core/src/main/java/org/apache/iceberg/MetricsConfig.java
b/core/src/main/java/org/apache/iceberg/MetricsConfig.java
index 5bb5d9bcc7..d7bb2430be 100644
--- a/core/src/main/java/org/apache/iceberg/MetricsConfig.java
+++ b/core/src/main/java/org/apache/iceberg/MetricsConfig.java
@@ -90,17 +90,6 @@ public final class MetricsConfig implements Serializable {
return POSITION_DELETE_MODE;
}
- /**
- * Creates a metrics config from table configuration.
- *
- * @param props table configuration
- * @deprecated use {@link MetricsConfig#forTable(Table)}. Will be removed in
1.13.0
- */
- @Deprecated
- public static MetricsConfig fromProperties(Map<String, String> props) {
- return from(props, null, null);
- }
-
/**
* Validates metrics config properties with the given schema.
*
diff --git a/core/src/main/java/org/apache/iceberg/RewriteTablePathUtil.java
b/core/src/main/java/org/apache/iceberg/RewriteTablePathUtil.java
index de9217259c..f685680d43 100644
--- a/core/src/main/java/org/apache/iceberg/RewriteTablePathUtil.java
+++ b/core/src/main/java/org/apache/iceberg/RewriteTablePathUtil.java
@@ -49,7 +49,6 @@ import org.apache.iceberg.puffin.PuffinReader;
import org.apache.iceberg.puffin.PuffinWriter;
import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
import org.apache.iceberg.relocated.com.google.common.collect.ImmutableList;
-import org.apache.iceberg.relocated.com.google.common.collect.ImmutableMap;
import org.apache.iceberg.relocated.com.google.common.collect.Lists;
import org.apache.iceberg.relocated.com.google.common.collect.Maps;
import org.apache.iceberg.relocated.com.google.common.collect.Sets;
@@ -400,50 +399,6 @@ public class RewriteTablePathUtil {
return result;
}
- /**
- * Rewrite a delete manifest, replacing path references.
- *
- * @param manifestFile source delete manifest to rewrite
- * @param snapshotIds snapshot ids for filtering returned delete manifest
entries
- * @param outputFile output file to rewrite manifest file to
- * @param io file io
- * @param format format of the manifest file
- * @param specsById map of partition specs by id
- * @param sourcePrefix source prefix that will be replaced
- * @param targetPrefix target prefix that will replace it
- * @param stagingLocation staging location for rewritten files (referred
delete file will be
- * rewritten here)
- * @return a copy plan of content files in the manifest that was rewritten
- * @deprecated since 1.12.0, will be removed in 1.13.0; use the overload
that accepts the map of
- * rewritten position delete file sizes. This overload records the
original {@code
- * file_size_in_bytes}, which can be inconsistent with the rewritten
file size on disk once
- * embedded data file paths change length.
- */
- @Deprecated
- public static RewriteResult<DeleteFile> rewriteDeleteManifest(
- ManifestFile manifestFile,
- Set<Long> snapshotIds,
- OutputFile outputFile,
- FileIO io,
- int format,
- Map<Integer, PartitionSpec> specsById,
- String sourcePrefix,
- String targetPrefix,
- String stagingLocation)
- throws IOException {
- return rewriteDeleteManifest(
- manifestFile,
- snapshotIds,
- outputFile,
- io,
- format,
- specsById,
- sourcePrefix,
- targetPrefix,
- stagingLocation,
- ImmutableMap.of());
- }
-
/**
* Rewrite a delete manifest, replacing path references.
*
@@ -688,34 +643,6 @@ public class RewriteTablePathUtil {
throws IOException;
}
- /**
- * Rewrite a position delete file, replacing path references.
- *
- * @param deleteFile source delete file to be rewritten
- * @param outputFile output file to rewrite delete file to
- * @param io file io
- * @param spec spec of delete file
- * @param sourcePrefix source prefix that will be replaced
- * @param targetPrefix target prefix to replace it
- * @param posDeleteReaderWriter class to read and write position delete files
- * @deprecated since 1.12.0, will be removed in 1.13.0; use {@link
#rewritePositionDelete} which
- * returns the size of the rewritten file so callers can record an
accurate {@code
- * file_size_in_bytes}.
- */
- @Deprecated
- public static void rewritePositionDeleteFile(
- DeleteFile deleteFile,
- OutputFile outputFile,
- FileIO io,
- PartitionSpec spec,
- String sourcePrefix,
- String targetPrefix,
- PositionDeleteReaderWriter posDeleteReaderWriter)
- throws IOException {
- rewritePositionDelete(
- deleteFile, outputFile, io, spec, sourcePrefix, targetPrefix,
posDeleteReaderWriter);
- }
-
/**
* Rewrite a position delete file, replacing path references, and return the
size of the rewritten
* file.
diff --git
a/core/src/main/java/org/apache/iceberg/deletes/BaseDVFileWriter.java
b/core/src/main/java/org/apache/iceberg/deletes/BaseDVFileWriter.java
index b62cbdd479..ebd18fb15d 100644
--- a/core/src/main/java/org/apache/iceberg/deletes/BaseDVFileWriter.java
+++ b/core/src/main/java/org/apache/iceberg/deletes/BaseDVFileWriter.java
@@ -31,12 +31,10 @@ import org.apache.iceberg.IcebergBuild;
import org.apache.iceberg.MetadataColumns;
import org.apache.iceberg.PartitionSpec;
import org.apache.iceberg.StructLike;
-import org.apache.iceberg.encryption.EncryptedFiles;
import org.apache.iceberg.encryption.EncryptedOutputFile;
import org.apache.iceberg.encryption.EncryptionKeyMetadata;
import org.apache.iceberg.encryption.NativeEncryptionKeyMetadata;
import org.apache.iceberg.io.DeleteWriteResult;
-import org.apache.iceberg.io.OutputFile;
import org.apache.iceberg.io.OutputFileFactory;
import org.apache.iceberg.puffin.Blob;
import org.apache.iceberg.puffin.BlobMetadata;
@@ -68,16 +66,6 @@ public class BaseDVFileWriter implements DVFileWriter {
this(loadPreviousDeletes, fileFactory::newOutputFile);
}
- /**
- * @deprecated since 1.12.0 and will be removed in 1.13.0
- */
- @Deprecated
- public BaseDVFileWriter(
- Supplier<OutputFile> dvOutputFile,
- Function<String, PositionDeleteIndex> loadPreviousDeletes) {
- this(loadPreviousDeletes, () ->
EncryptedFiles.plainAsEncryptedOutput(dvOutputFile.get()));
- }
-
BaseDVFileWriter(
Function<String, PositionDeleteIndex> loadPreviousDeletes,
Supplier<EncryptedOutputFile> dvOutputFile) {
diff --git
a/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java
b/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java
index ec1719a0b4..edff9327bd 100644
---
a/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java
+++
b/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java
@@ -184,18 +184,6 @@ public class StandardEncryptionManager implements
EncryptionManager {
return unwrappedKeyCache().get(encryptedKeyMetadata.encryptedById());
}
- /**
- * Encrypts and registers manifest-list key metadata.
- *
- * @return the ID of the encrypted metadata
- * @deprecated since 1.12.0, will be removed in 1.13.0; use {@link
- * #registerKeyMetadata(NativeEncryptionKeyMetadata)} instead.
- */
- @Deprecated
- public String addManifestListKeyMetadata(NativeEncryptionKeyMetadata
keyMetadata) {
- return registerKeyMetadata(keyMetadata).fileKey().keyId();
- }
-
/**
* Encrypts and registers key metadata.
*
diff --git
a/core/src/main/java/org/apache/iceberg/io/BasePositionDeltaWriter.java
b/core/src/main/java/org/apache/iceberg/io/BasePositionDeltaWriter.java
index bde97cb038..d68b1b2255 100644
--- a/core/src/main/java/org/apache/iceberg/io/BasePositionDeltaWriter.java
+++ b/core/src/main/java/org/apache/iceberg/io/BasePositionDeltaWriter.java
@@ -65,9 +65,8 @@ public class BasePositionDeltaWriter<T> implements
PositionDeltaWriter<T> {
updateWriter.write(row, spec, partition);
}
- @Deprecated
@Override
- public void delete(CharSequence path, long pos, T row, PartitionSpec spec,
StructLike partition) {
+ public void delete(CharSequence path, long pos, PartitionSpec spec,
StructLike partition) {
positionDelete.set(path, pos);
deleteWriter.write(positionDelete, spec, partition);
}
diff --git a/core/src/main/java/org/apache/iceberg/io/PositionDeltaWriter.java
b/core/src/main/java/org/apache/iceberg/io/PositionDeltaWriter.java
index 06a859b5ff..09f19e2142 100644
--- a/core/src/main/java/org/apache/iceberg/io/PositionDeltaWriter.java
+++ b/core/src/main/java/org/apache/iceberg/io/PositionDeltaWriter.java
@@ -64,26 +64,7 @@ public interface PositionDeltaWriter<T> extends Closeable {
* @param spec a partition spec
* @param partition a partition or null if the spec is unpartitioned
*/
- default void delete(CharSequence path, long pos, PartitionSpec spec,
StructLike partition) {
- delete(path, pos, null, spec, partition);
- }
-
- /**
- * Deletes a position in the provided spec/partition.
- *
- * <p>The {@code row} is ignored: position deletes that include row data are
no longer supported.
- *
- * @param path a data file path
- * @param pos a position
- * @param row a deleted row, ignored
- * @param spec a partition spec
- * @param partition a partition or null if the spec is unpartitioned
- * @deprecated since 1.12.0, will be removed in 1.13.0; use {@link
#delete(CharSequence, long,
- * PartitionSpec, StructLike)} instead, which will become the method
implementations must
- * override.
- */
- @Deprecated
- void delete(CharSequence path, long pos, T row, PartitionSpec spec,
StructLike partition);
+ void delete(CharSequence path, long pos, PartitionSpec spec, StructLike
partition);
/**
* Returns a result that contains information about written {@link
DataFile}s or {@link
diff --git
a/core/src/main/java/org/apache/iceberg/rest/RESTCatalogProperties.java
b/core/src/main/java/org/apache/iceberg/rest/RESTCatalogProperties.java
index fbb122e4e1..0d9907f4eb 100644
--- a/core/src/main/java/org/apache/iceberg/rest/RESTCatalogProperties.java
+++ b/core/src/main/java/org/apache/iceberg/rest/RESTCatalogProperties.java
@@ -22,7 +22,6 @@ import java.util.Arrays;
import java.util.Locale;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
-import org.apache.iceberg.CatalogProperties;
public final class RESTCatalogProperties {
@@ -108,22 +107,6 @@ public final class RESTCatalogProperties {
}
}
- /**
- * The base URI of the remote signer endpoint. Optional, defaults to {@link
- * CatalogProperties#URI}.
- *
- * @deprecated since 1.12.0, will be removed in 1.13.0; there is no
replacement
- */
- @Deprecated public static final String SIGNER_URI = "signer.uri";
-
- /**
- * The endpoint path of the remote signer endpoint. If remote signing has
been requested, this
- * must be set.
- *
- * @deprecated since 1.12.0, will be removed in 1.13.0; there is no
replacement
- */
- @Deprecated public static final String SIGNER_ENDPOINT = "signer.endpoint";
-
/**
* The remote signing endpoint path, as computed by {@link
* ResourcePaths#remoteSign(org.apache.iceberg.catalog.TableIdentifier)}.
diff --git a/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
b/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
index d63f358390..56bed57e32 100644
--- a/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
+++ b/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
@@ -1381,32 +1381,6 @@ public class RESTSessionCatalog extends
BaseViewSessionCatalog
return newFileIO(context, fullConf.buildKeepingLast(), storageCredentials);
}
- /**
- * Create a new {@link RESTTableOperations} instance for simple table
operations.
- *
- * @deprecated since 1.12.0, will be removed in 1.13.0; use {@link
#newTableOps(RESTClient,
- * String, Supplier, Supplier, FileIO, TableMetadata, Set, Map)} instead.
- */
- @Deprecated
- protected RESTTableOperations newTableOps(
- RESTClient restClient,
- String path,
- Supplier<Map<String, String>> readHeaders,
- Supplier<Map<String, String>> mutationHeaderSupplier,
- FileIO fileIO,
- TableMetadata current,
- Set<Endpoint> supportedEndpoints) {
- return newTableOps(
- restClient,
- path,
- readHeaders,
- mutationHeaderSupplier,
- fileIO,
- current,
- supportedEndpoints,
- Map.of());
- }
-
/**
* Create a new {@link RESTTableOperations} instance for simple table
operations.
*
diff --git
a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetFormatModel.java
b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetFormatModel.java
index b097df8fc6..9bbbf7bb9c 100644
--- a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetFormatModel.java
+++ b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetFormatModel.java
@@ -71,27 +71,6 @@ public class ParquetFormatModel<D, S, R>
type, schemaType, writerFunction, readerFunction, false, null, null);
}
- /**
- * @deprecated Will be removed in 1.13.0; use {@link #create(Class, Class,
WriterFunction,
- * ReaderFunction, VariantShreddingAnalyzer, Function)} instead.
- */
- @Deprecated
- public static <D, S> ParquetFormatModel<D, S, ParquetValueReader<?>> create(
- Class<D> type,
- Class<S> schemaType,
- WriterFunction<ParquetValueWriter<?>, S, MessageType> writerFunction,
- ReaderFunction<ParquetValueReader<?>, S, MessageType> readerFunction,
- VariantShreddingAnalyzer<D, S> variantAnalyzer,
- UnaryOperator<D> copyFunc) {
- return create(
- type,
- schemaType,
- writerFunction,
- readerFunction,
- variantAnalyzer,
- (Function<S, UnaryOperator<D>>) unused -> copyFunc);
- }
-
public static <D, S> ParquetFormatModel<D, S, ParquetValueReader<?>> create(
Class<D> type,
Class<S> schemaType,
