Uses of Class
org.apache.paimon.annotation.VisibleForTesting

Packages that use VisibleForTesting

Package	Description
org.apache.paimon
org.apache.paimon.append
org.apache.paimon.compact
org.apache.paimon.deletionvectors
org.apache.paimon.disk
org.apache.paimon.flink
org.apache.paimon.flink.action
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.query
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.source
org.apache.paimon.format
org.apache.paimon.format.orc
org.apache.paimon.fs.hadoop
org.apache.paimon.hive
org.apache.paimon.index
org.apache.paimon.io
org.apache.paimon.io.cache
org.apache.paimon.jdbc
org.apache.paimon.manifest
org.apache.paimon.memory
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.operation
org.apache.paimon.operation.metrics
org.apache.paimon.schema
org.apache.paimon.sort
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.utils

Uses of VisibleForTesting in org.apache.paimon

Methods in org.apache.paimon with annotations of type VisibleForTesting

Modifier and Type	Method and Description
KeyValue	KeyValue.copy(InternalRowSerializer keySerializer, InternalRowSerializer valueSerializer)
static CoreOptions.StreamingReadMode	CoreOptions.StreamingReadMode.fromValue(String value)
static CoreOptions.IncrementalBetweenScanMode	CoreOptions.IncrementalBetweenScanMode.fromValue(String value)
String	KeyValue.toString(RowType keyType, RowType valueType)

Uses of VisibleForTesting in org.apache.paimon.append

Methods in org.apache.paimon.append with annotations of type VisibleForTesting

Modifier and Type	Method and Description
RowBuffer	AppendOnlyWriter.getWriteBuffer()

Uses of VisibleForTesting in org.apache.paimon.compact

Methods in org.apache.paimon.compact with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected CompactResult	CompactFutureManager.obtainCompactResult()

Uses of VisibleForTesting in org.apache.paimon.deletionvectors

Methods in org.apache.paimon.deletionvectors with annotations of type VisibleForTesting

Modifier and Type	Method and Description
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition)
Map<String,DeletionVector>	DeletionVectorsMaintainer.deletionVectors()

Uses of VisibleForTesting in org.apache.paimon.disk

Methods in org.apache.paimon.disk with annotations of type VisibleForTesting

Modifier and Type	Method and Description
List<ChannelWithMeta>	ExternalBuffer.getSpillChannels()

Uses of VisibleForTesting in org.apache.paimon.flink

Methods in org.apache.paimon.flink with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static FlinkGenericCatalog	FlinkGenericCatalogFactory.createCatalog(ClassLoader cl, Map<String,String> optionMap, String name, org.apache.flink.table.catalog.Catalog flinkCatalog)
org.apache.flink.table.factories.CatalogFactory.Context	FlinkGenericCatalogFactory.filterContextOptions(org.apache.flink.table.factories.CatalogFactory.Context context, org.apache.flink.table.factories.CatalogFactory catalogFactory)

Uses of VisibleForTesting in org.apache.paimon.flink.action

Methods in org.apache.paimon.flink.action with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Map<String,String>	ActionBase.catalogConfig()

Uses of VisibleForTesting in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
FileStoreTable	SyncTableActionBase.fileStoreTable()
Map<String,String>	SynchronizationActionBase.tableConfig()

Uses of VisibleForTesting in org.apache.paimon.flink.action.cdc.mysql

Methods in org.apache.paimon.flink.action.cdc.mysql with annotations of type VisibleForTesting

Modifier and Type	Method and Description
List<Identifier>	MySqlSyncDatabaseAction.excludedTables()
List<Identifier>	MySqlSyncDatabaseAction.monitoredTables()

Uses of VisibleForTesting in org.apache.paimon.flink.query

Methods in org.apache.paimon.flink.query with annotations of type VisibleForTesting

Modifier and Type	Method and Description
CompletableFuture<Void>	RemoteTableQuery.cancel()

Uses of VisibleForTesting in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink with annotations of type VisibleForTesting

Modifier and Type	Method and Description
CommitterMetrics	StoreCommitter.getCommitterMetrics()
org.apache.flink.metrics.Counter	CommitterMetrics.getNumBytesOutCounter()
org.apache.flink.metrics.Counter	CommitterMetrics.getNumRecordsOutCounter()
StoreSinkWrite	TableWriteOperator.getWrite()
TableWriteImpl<?>	StoreSinkWriteImpl.getWrite()

Uses of VisibleForTesting in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
String	CdcRecordStoreMultiWriteOperator.commitUser()
Map<Identifier,FileStoreTable>	CdcRecordStoreMultiWriteOperator.tables()
Map<Identifier,StoreSinkWrite>	CdcRecordStoreMultiWriteOperator.writes()

Uses of VisibleForTesting in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source with annotations of type VisibleForTesting

Modifier and Type	Method and Description
SplitAssigner	StaticFileStoreSplitEnumerator.getSplitAssigner()

Uses of VisibleForTesting in org.apache.paimon.format

Methods in org.apache.paimon.format with annotations of type VisibleForTesting

Modifier and Type	Method and Description
static FileFormat	FileFormat.fromIdentifier(String identifier, Options options)

Constructors in org.apache.paimon.format with annotations of type VisibleForTesting

Constructor and Description
FormatContext(Options formatOptions, int readBatchSize, int writeBatchSize)

Uses of VisibleForTesting in org.apache.paimon.format.orc

Methods in org.apache.paimon.format.orc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected OrcFile.WriterOptions	OrcWriterFactory.getWriterOptions()
Properties	OrcFileFormat.orcProperties()
int	OrcFileFormat.readBatchSize()

Uses of VisibleForTesting in org.apache.paimon.fs.hadoop

Methods in org.apache.paimon.fs.hadoop with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	HadoopFileIO.setFileSystem(Path path, org.apache.hadoop.fs.FileSystem fs)

Uses of VisibleForTesting in org.apache.paimon.hive

Methods in org.apache.paimon.hive with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.hadoop.hive.metastore.IMetaStoreClient	HiveCatalog.getHmsClient()

Uses of VisibleForTesting in org.apache.paimon.index

Methods in org.apache.paimon.index with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	HashIndexMaintainer.isEmpty()

Uses of VisibleForTesting in org.apache.paimon.io

Methods in org.apache.paimon.io with annotations of type VisibleForTesting

Modifier and Type	Method and Description
DataFilePathFactory	KeyValueFileWriterFactory.pathFactory(int level)
long	RollingFileWriter.targetFileSize()
String	DataFilePathFactory.uuid()

Uses of VisibleForTesting in org.apache.paimon.io.cache

Methods in org.apache.paimon.io.cache with annotations of type VisibleForTesting

Modifier and Type	Method and Description
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<CacheKey,?>	CacheManager.cache()

Uses of VisibleForTesting in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc with annotations of type VisibleForTesting

Modifier and Type	Method and Description
JdbcClientPool	JdbcCatalog.getConnections()

Uses of VisibleForTesting in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest with annotations of type VisibleForTesting

Modifier and Type	Method and Description
long	ManifestFile.suggestedFileSize()

Uses of VisibleForTesting in org.apache.paimon.memory

Methods in org.apache.paimon.memory with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Iterable<MemoryOwner>	MemoryPoolFactory.memoryOwners()

Uses of VisibleForTesting in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	SortedRun.validate(Comparator<InternalRow> comparator)

Uses of VisibleForTesting in org.apache.paimon.mergetree.compact

Methods in org.apache.paimon.mergetree.compact with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Levels	MergeTreeCompactManager.levels()

Uses of VisibleForTesting in org.apache.paimon.operation

Classes in org.apache.paimon.operation with annotations of type VisibleForTesting

Modifier and Type	Class and Description
static class	AbstractFileStoreWrite.WriterContainer<T> RecordWriter with the snapshot id it is created upon and the identifier of its last modified commit.

Methods in org.apache.paimon.operation with annotations of type VisibleForTesting

Modifier and Type	Method and Description
boolean	KeyValueFileStoreWrite.bufferSpillable()
AbstractFileStoreWrite.WriterContainer<T>	AbstractFileStoreWrite.createWriterContainer(BinaryRow partition, int bucket, boolean ignorePreviousFiles)
ExecutorService	AbstractFileStoreWrite.getCompactExecutor()

Uses of VisibleForTesting in org.apache.paimon.operation.metrics

Methods in org.apache.paimon.operation.metrics with annotations of type VisibleForTesting

Modifier and Type	Method and Description
protected static Map<BinaryRow,Set<Integer>>	CommitStats.changedPartBuckets(List<ManifestEntry>... changes)
protected static List<BinaryRow>	CommitStats.changedPartitions(List<ManifestEntry>... changes)
protected int	CommitStats.getAttempts()
protected long	CommitStats.getChangelogFilesAppended()
protected long	CommitStats.getChangelogFilesCompacted()
protected long	CommitStats.getChangelogRecordsAppended()
protected long	CommitStats.getChangelogRecordsCompacted()
protected long	CommitStats.getDeltaRecordsAppended()
protected long	CommitStats.getDeltaRecordsCompacted()
protected long	ScanStats.getDuration()
protected long	CommitStats.getDuration()
protected long	CommitStats.getGeneratedSnapshots()
MetricGroup	CompactionMetrics.getMetricGroup()
MetricGroup	CommitMetrics.getMetricGroup()
MetricGroup	ScanMetrics.getMetricGroup()
protected long	CommitStats.getNumBucketsWritten()
protected long	CommitStats.getNumPartitionsWritten()
protected long	ScanStats.getResultedTableFiles()
protected long	ScanStats.getScannedManifests()
protected long	ScanStats.getSkippedByBucketAndLevelFilter()
protected long	ScanStats.getSkippedByPartitionAndStats()
protected long	ScanStats.getSkippedByWholeBucketFiles()
protected long	ScanStats.getSkippedTableFiles()
protected long	CommitStats.getTableFilesAdded()
protected long	CommitStats.getTableFilesAppended()
protected long	CommitStats.getTableFilesCompacted()
protected long	CommitStats.getTableFilesDeleted()
protected static long	CommitStats.numChangedBuckets(List<ManifestEntry>... changes)
protected static long	CommitStats.numChangedPartitions(List<ManifestEntry>... changes)

Uses of VisibleForTesting in org.apache.paimon.schema

Methods in org.apache.paimon.schema with annotations of type VisibleForTesting

Modifier and Type	Method and Description
Path	SchemaManager.toSchemaPath(long schemaId)

Uses of VisibleForTesting in org.apache.paimon.sort

Methods in org.apache.paimon.sort with annotations of type VisibleForTesting

Modifier and Type	Method and Description
void	BinaryExternalSortBuffer.write(MutableObjectIterator<BinaryRow> iterator)

Uses of VisibleForTesting in org.apache.paimon.table

Methods in org.apache.paimon.table with annotations of type VisibleForTesting

Modifier and Type	Method and Description
int	ExpireSnapshotsImpl.expireUntil(long earliestId, long endExclusiveId)
SnapshotDeletion	ExpireSnapshotsImpl.snapshotDeletion()

Uses of VisibleForTesting in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with annotations of type VisibleForTesting

Modifier and Type	Method and Description
ExecutorService	TableCommitImpl.getExpireMainExecutor()
FileStoreWrite<T>	TableWriteImpl.getWrite()

Constructors in org.apache.paimon.table.sink with annotations of type VisibleForTesting

Constructor and Description
CommitMessageImpl(BinaryRow partition, int bucket, DataIncrement dataIncrement, CompactIncrement compactIncrement)

Uses of VisibleForTesting in org.apache.paimon.table.source

Methods in org.apache.paimon.table.source with annotations of type VisibleForTesting

Modifier and Type	Method and Description
AbstractDataTableScan	AbstractDataTableScan.withBucket(int bucket)

Uses of VisibleForTesting in org.apache.paimon.utils

Methods in org.apache.paimon.utils with annotations of type VisibleForTesting

Modifier and Type	Method and Description
List<String>	TagManager.allTagNames()
static RoaringBitmap32	RoaringBitmap32.bitmapOf(int... dat)
static RoaringBitmap64	RoaringBitmap64.bitmapOf(long... dat)
BloomFilter	BloomFilter.Builder.getFilter()
static InternalRowPartitionComputer	FileStorePathFactory.getPartitionComputer(RowType partitionType, String defaultPartValue)
static byte[]	HllSketchUtil.sketchOf(int... values)
static byte[]	ThetaSketch.sketchOf(int... values)
String	FileStorePathFactory.uuid()