Deprecated API
Contents
-
Deprecated InterfacesInterfaceDescriptionthe API will be removed in v2.0.0 (replaced with KeyManagementClient interface).since 1.10.0, will be removed in 2.0.0will be removed in 2.0.0, use
Counterinstead.
-
Deprecated ClassesClassDescriptionwill be removed in 2.0.0; use
PlannedDataReaderinstead.since 1.10.0, will be removed in 1.11.0; usePartitionStatsHandlerfrom core modulesince 1.7.0, will be removed in 2.0.0. UseIcebergSourceinstead, which implement the newer FLIP-27 source interface. This class implements the oldSourceFunctionthat has been marked as deprecated in Flink since Aug 2023.since 1.7.0. Will be removed in 2.0.0; useIcebergSource.forOutputType(RowDataConverter)andAvroGenericRecordConverterinstead.useParquetWritersince 1.10.0, will be removed in 1.11.0; usePartitionStatsHandlerdirectlysince 1.10.0, will be removed in 1.11.0; useThreadPools.authRefreshPool().UseSystemConfigsinstead; will be removed in 2.0.0
-
Deprecated FieldsFieldDescriptionwill be removed in 2.0.0; use name mapping insteadwill be removed in 2.0.0, writing manifest lists is always enabledwill be removed in 2.0.0, writing manifest lists is always enabledwill be removed in 2.0.0, use
TableProperties.WRITE_DATA_LOCATIONinstead.will be removed in 2.0.0, useTableProperties.WRITE_DATA_LOCATIONinstead.UseWORKER_THREAD_POOL_SIZEinstead; will be removed in 2.0.0UseIcebergSqlExtensionsLexer.VOCABULARYinstead.UseIcebergSqlExtensionsParser.VOCABULARYinstead.
-
Deprecated MethodsMethodDescriptionwill be removed in 2.0.0; use applyNameMapping and pruneColumns(Schema, Set) instead.Not for public use. To configure the endpoint for a client, please use
S3FileIOProperties.applyEndpointConfigurations(S3BaseClientBuilder),AwsProperties.applyGlueEndpointConfigurations(GlueClientBuilder), orAwsProperties.applyDynamoDbEndpointConfigurations(DynamoDbClientBuilder)accordingly. It will be removed in 2.0.0Not for public use. To configure the httpClient for a client, please useHttpClientProperties.applyHttpClientConfigurations(AwsSyncClientBuilder). It will be removed in 2.0.0Not for public use. To build an S3Configuration object, use S3Configuration.builder() directly. It will be removed in 2.0.0since 1.10.0, will be removed in 1.11.0; useS3InputFile.fromLocation(String, long, PrefixedS3Client, MetricsContext)instead.since 1.10.0, will be removed in 1.11.0; useS3InputFile.fromLocation(String, long, PrefixedS3Client, MetricsContext)instead.since 1.10.0, will be removed in 1.11.0; useS3InputFile.fromLocation(String, PrefixedS3Client, MetricsContext)instead.since 1.10.0, will be removed in 1.11.0; useS3InputFile.fromLocation(String, PrefixedS3Client, MetricsContext)instead.since 1.10.0, will be removed in 1.11.0; useS3OutputFile.fromLocation(String, PrefixedS3Client, MetricsContext)instead.since 1.10.0, will be removed in 1.11.0; useS3OutputFile.fromLocation(String, PrefixedS3Client, MetricsContext)instead.will be removed in 2.0.0. UseCommitter.open(Catalog, IcebergSinkConfig, SinkTaskContext, Collection)instead.will be removed in 2.0.0. UseCommitter.close(Collection)instead.since 1.7.0, will be removed in 2.0.0; useContentFile.location()instead.will be removed in 1.11.0; useEncryptionUtil.createEncryptionManager(List, Map, KeyManagementClient)instead.will be removed in 2.0.0; useFlinkSchemaUtil.convert(ResolvedSchema)instead.since 1.10.0, will be removed in 2.0.0. UseFlinkSchemaUtil.convert(Schema, ResolvedSchema)instead.since 1.10.0, will be removed in 2.0.0. UseFlinkSchemaUtil.toResolvedSchema(RowType)insteadsince 1.10.0, will be removed in 2.0.0. UseFlinkSchemaUtil.toResolvedSchema(Schema)insteadsince 1.10.0, will be removed in 2.0.0. UseFlinkSink.forRow(DataStream, ResolvedSchema)instead.UseIcebergSink.forRow(DataStream, ResolvedSchema)instead.since 1.7.0. Will be removed in 2.0.0; useIcebergSource.forRowData()orIcebergSource.forOutputType(RowDataConverter)insteadsince 1.10.0, will be removed in 2.0.0. UseIcebergSource.Builder.project(ResolvedSchema)instead.will be removed in 2.0.0; useIcebergSource.Builder.setAll(java.util.Map<java.lang.String, java.lang.String>)instead.since 1.7.0. Will be removed in 2.0.0; useIcebergSource.forOutputType(RowDataConverter)instead to produce output type other thanRowData.since 1.10.0, will be removed in 2.0.0.since 1.7.0, will be removed in 2.0.0; This method does only best-effort invalidation and is susceptible to a race condition. If the caller changed the state that could be cached (perhaps files on the storage) and calls this method, there is no guarantee that the cache will not contain stale entries some time after this method returns.will be removed in 2.0.0, useCounterinstead.will be removed in 2.0.0, useMetricsContext.counter(String, Unit)instead.will be removed in 2.0.0; useParquet.ReadBuilder.createReaderFunc(Function)insteadwill be removed in 2.0.0; useParquet.ReadBuilder.createReaderFunc(Function)insteadsince 1.10.0, visibility will be reduced in 1.11.0since 1.10.0, visibility will be reduced in 1.11.0since 1.10.0, visibility will be reduced in 1.11.0since 1.10.0, will be removed in 1.11.0. UsePartitionStatsHandler.schema(StructType, int)instead.since 1.10.0, will be removed in 1.11.0; useOAuth2Util.exchangeToken(RESTClient, Map, String, String, String, String, String, String, Map)instead.since 1.10.0, will be removed in 1.11.0; useOAuth2Util.exchangeToken(RESTClient, Map, String, String, String, String, String, String, Map)instead.since 1.10.0, will be removed in 1.11.0; useOAuth2Util.fetchToken(RESTClient, Map, String, String, String, Map)instead.since 1.10.0, will be removed in 1.11.0; useOAuth2Util.fetchToken(RESTClient, Map, String, String, String, Map)instead.since 1.3.0, will be removed in 2.0.0since 1.3.0, will be removed in 2.0.0since 1.3.0, will be removed in 2.0.0since 1.10.0, will be removed in 1.11.0since 1.10.0, will be removed in 1.11.0since 1.10.0, will be removed in 1.11.0. UseRewriteTablePathUtil.stagingPath(String, String, String)instead to avoid filename conflictssince 1.10.0, will be removed in 1.11.0; useTableMetadataParser.read(InputFile)instead.since 1.0.0, will be removed in 2.0.0; useTable.newIncrementalAppendScan()instead.since 1.0.0, will be removed in 2.0.0; useTable.newIncrementalAppendScan()instead.useTransform.bind(Type)instead; will be removed in 2.0.0useTransform.toHumanString(Type, Object)instead; will be removed in 2.0.0useTransforms.bucket(int)instead; will be removed in 2.0.0useTransforms.day()instead; will be removed in 2.0.0useTransforms.identity()instead; will be removed in 2.0.0useTransforms.hour()instead; will be removed in 2.0.0useTransforms.identity()instead; will be removed in 2.0.0useTransforms.month()instead; will be removed in 2.0.0useTransforms.truncate(int)instead; will be removed in 2.0.0useTransforms.year()instead; will be removed in 2.0.0will be removed in 2.0.0; useUnknownTransform.bind(Type)insteadwill be removed in 2.0.0; useTypes.NestedField.Builder.withInitialDefault(Literal)instead.will be removed in 2.0.0; useTypes.NestedField.Builder.withWriteDefault(Literal)instead.will be removed in 2.0.0; useTypes.NestedField.builder()instead.will be removed in 2.0.0; useTypes.NestedField.builder()instead.will be removed in 2.0.0; useTypes.NestedField.Builder.withId(int)insteadwill be removed in 2.0.0; useTypeUtil.SchemaVisitor.variant(Types.VariantType)instead.since 1.8.0, will be removed in 2.0.0, useUpdateStatistics.setStatistics(StatisticsFile).will be removed in 2.0.0, useSnapshotUtil.newFilesBetween(Long, long, Function, FileIO)instead.will be removed in 2.0.0. UseThreadPools.newExitingWorkerPool(String, int)for long-lived thread pools that require a shutdown hook, orThreadPools.newFixedThreadPool(String, int)for short-lived thread pools where you manage the lifecycle.will be removed in 2.0.0. UseThreadPools.newExitingWorkerPool(String, int)for long-lived thread pools that require a shutdown hook, orThreadPools.newFixedThreadPool(String, int)for short-lived thread pools where you manage the lifecycle.
-
Deprecated ConstructorsConstructorDescriptionsince 1.10.0, will be removed in 1.11.0; use
S3FileIO(SerializableSupplier)withS3FileIO.initialize(Map)insteadsince 1.10.0, will be removed in 1.11.0; useS3FileIO(SerializableSupplier, SerializableSupplier)withS3FileIO.initialize(Map)insteadwill be removed in 2.0.0; useRawDecoder.create(org.apache.iceberg.Schema, Function, Schema)insteadsince 1.10.0, will be removed in 2.0.0. UseIcebergTableSink(TableLoader, ResolvedSchema, ReadableConfig, Map)insteadsince 1.10.0, will be removed in 1.11.0; useGCSFileIO(SerializableSupplier)withGCSFileIO.initialize(Map)instead