Deprecated API

Contents

• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Classes

Class and Description
org.apache.paimon.flink.procedure.DropPartitionProcedure use ALTER TABLE DROP PARTITION
org.apache.flink.table.hive.LegacyHiveClasses
org.apache.flink.table.store.hive.TableStoreHiveStorageHandler
org.apache.flink.table.store.mapred.TableStoreInputFormat
org.apache.flink.table.store.mapred.TableStoreOutputFormat
org.apache.flink.table.store.hive.TableStoreSerDe

Deprecated Fields

Field and Description
org.apache.paimon.flink.FlinkConnectorOptions.CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL
org.apache.paimon.codegen.codesplit.JavaParser.tokenNames Use JavaParser.VOCABULARY instead.
org.apache.paimon.codegen.codesplit.JavaLexer.tokenNames Use JavaLexer.VOCABULARY instead.
org.apache.paimon.codegen.codesplit.JavaLexer.tokenNames Use JavaLexer.VOCABULARY instead.
org.apache.paimon.codegen.codesplit.JavaParser.tokenNames Use JavaParser.VOCABULARY instead.

Deprecated Methods

Method and Description
org.apache.paimon.options.ConfigOptions.OptionBuilder.defaultValue(T) define the type explicitly first with one of the intType(), stringType(), etc.
org.apache.paimon.options.ConfigOption.deprecatedKeys() Replaced by ConfigOption.fallbackKeys()
org.apache.orc.OrcFile.ReaderOptions.fileMetadata(FileMetadata) Use OrcFile.ReaderOptions.orcTail(OrcTail) instead.
org.apache.paimon.data.Timestamp.fromInstant(Instant) use LocalZoneTimestamp.
org.apache.paimon.io.DataOutputSerializer.getByteArray() Replaced by DataOutputSerializer.getSharedBuffer() for a better, safer name.
org.apache.orc.OrcConf.getInt(Configuration, int) Use OrcConf.getInt(Configuration) instead. This method was incorrectly added and shouldn't be used anymore.
org.apache.parquet.hadoop.ParquetFileReader.getPath() will be removed in 2.0.0; use ParquetFileReader.getFile() instead
org.apache.paimon.codegen.codesplit.JavaParser.getTokenNames()
org.apache.paimon.codegen.codesplit.JavaLexer.getTokenNames()
org.apache.paimon.codegen.codesplit.JavaLexer.getTokenNames()
org.apache.paimon.codegen.codesplit.JavaParser.getTokenNames()
org.apache.paimon.options.ConfigOption.hasDeprecatedKeys() Replaced by ConfigOption.hasFallbackKeys()
org.apache.paimon.options.ConfigOptions.OptionBuilder.noDefaultValue() define the type explicitly first with one of the intType(), stringType(), etc.
org.apache.paimon.data.BinaryArrayWriter.setNullAt(int, DataType) Use BinaryArrayWriter.createNullSetter(DataType) for avoiding logical types during runtime.
org.apache.paimon.data.Timestamp.toInstant() use LocalZoneTimestamp.
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder.withCatalogLoader(Catalog.Loader) Use RichCdcSinkBuilder.catalogLoader.
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder.withIdentifier(Identifier) Use RichCdcSinkBuilder.identifier.
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder.withInput(DataStream<RichCdcRecord>) Use RichCdcSinkBuilder.forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<org.apache.paimon.flink.sink.cdc.RichCdcRecord>).
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder.withParallelism(Integer) Use RichCdcSinkBuilder.parallelism.
org.apache.paimon.table.source.InnerTableRead.withProjection(int[])
org.apache.paimon.table.source.ReadBuilder.withProjection(int[][])
org.apache.parquet.hadoop.ParquetWriter.Builder.withRowGroupSize(int) Use ParquetWriter.Builder.withRowGroupSize(long) instead
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder.withTable(Table) Use constructor to pass Table.
org.apache.paimon.data.BinaryWriter.write(BinaryWriter, int, Object, DataType, Serializer<?>) Use #createValueSetter(DataType) for avoiding logical types during runtime.

Deprecated Constructors

Constructor and Description
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder() Use constructor to pass table.