Uses of Interface
org.apache.paimon.fs.FileIO

Packages that use FileIO

Package	Description
org.apache.paimon
org.apache.paimon.append
org.apache.paimon.catalog
org.apache.paimon.consumer
org.apache.paimon.deletionvectors
org.apache.paimon.fileindex
org.apache.paimon.flink
org.apache.paimon.format
org.apache.paimon.format.avro
org.apache.paimon.format.fs
org.apache.paimon.format.orc
org.apache.paimon.format.orc.filter
org.apache.paimon.format.parquet
org.apache.paimon.fs
org.apache.paimon.fs.hadoop
org.apache.paimon.fs.local
org.apache.paimon.hive
org.apache.paimon.hive.migrate
org.apache.paimon.iceberg
org.apache.paimon.iceberg.manifest
org.apache.paimon.iceberg.metadata
org.apache.paimon.index
org.apache.paimon.io
org.apache.paimon.jdbc
org.apache.paimon.manifest
org.apache.paimon.migrate
org.apache.paimon.operation
org.apache.paimon.oss
org.apache.paimon.partition.actions
org.apache.paimon.partition.file
org.apache.paimon.privilege
org.apache.paimon.s3
org.apache.paimon.schema
org.apache.paimon.service
org.apache.paimon.stats
org.apache.paimon.table
org.apache.paimon.table.system
org.apache.paimon.tag
org.apache.paimon.utils

Uses of FileIO in org.apache.paimon

Methods in org.apache.paimon with parameters of type FileIO

Modifier and Type	Method and Description
static Changelog	Changelog.fromPath(FileIO fileIO, Path path)
static Snapshot	Snapshot.fromPath(FileIO fileIO, Path path)

Constructors in org.apache.paimon with parameters of type FileIO

Constructor and Description
AppendOnlyFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType rowType, String tableName, CatalogEnvironment catalogEnvironment)
KeyValueFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, boolean crossPartitionUpdate, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType keyType, RowType valueType, KeyValueFieldsExtractor keyValueFieldsExtractor, MergeFunctionFactory<KeyValue> mfFactory, String tableName, CatalogEnvironment catalogEnvironment)

Uses of FileIO in org.apache.paimon.append

Constructors in org.apache.paimon.append with parameters of type FileIO

Constructor and Description

AppendOnlyWriter(FileIO fileIO, IOManager ioManager, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, long maxSequenceNumber, CompactManager compactManager, IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead, boolean forceCompact, DataFilePathFactory pathFactory, CommitIncrement increment, boolean useWriteBuffer, boolean spillable, String fileCompression, CompressOptions spillCompression, SimpleColStatsCollector.Factory[] statsCollectors, MemorySize maxDiskSize, FileIndexOptions fileIndexOptions, boolean asyncFileWrite)

Uses of FileIO in org.apache.paimon.catalog

Fields in org.apache.paimon.catalog declared as FileIO

Modifier and Type	Field and Description
protected FileIO	AbstractCatalog.fileIO

Methods in org.apache.paimon.catalog that return FileIO

Modifier and Type	Method and Description
FileIO	Catalog.fileIO()
FileIO	AbstractCatalog.fileIO()
FileIO	DelegateCatalog.fileIO()

Methods in org.apache.paimon.catalog with parameters of type FileIO

Modifier and Type	Method and Description
default Catalog	CatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)
Catalog	FileSystemCatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)

Constructors in org.apache.paimon.catalog with parameters of type FileIO

Constructor and Description
AbstractCatalog(FileIO fileIO)
AbstractCatalog(FileIO fileIO, Options options)
FileSystemCatalog(FileIO fileIO, Path warehouse)
FileSystemCatalog(FileIO fileIO, Path warehouse, Options options)

Uses of FileIO in org.apache.paimon.consumer

Methods in org.apache.paimon.consumer with parameters of type FileIO

Modifier and Type	Method and Description
static Optional<Consumer>	Consumer.fromPath(FileIO fileIO, Path path)

Constructors in org.apache.paimon.consumer with parameters of type FileIO

Constructor and Description
ConsumerManager(FileIO fileIO, Path tablePath)
ConsumerManager(FileIO fileIO, Path tablePath, String branchName)

Uses of FileIO in org.apache.paimon.deletionvectors

Methods in org.apache.paimon.deletionvectors with parameters of type FileIO

Modifier and Type	Method and Description
static DeletionVector.Factory	DeletionVector.factory(FileIO fileIO, List<DataFileMeta> files, List<DeletionFile> deletionFiles)
static DeletionVector	DeletionVector.read(FileIO fileIO, DeletionFile deletionFile)

Constructors in org.apache.paimon.deletionvectors with parameters of type FileIO

Constructor and Description
DeletionVectorIndexFileWriter(FileIO fileIO, PathFactory pathFactory, MemorySize targetSizePerIndexFile)
DeletionVectorsIndexFile(FileIO fileIO, PathFactory pathFactory, MemorySize targetSizePerIndexFile)

Uses of FileIO in org.apache.paimon.fileindex

Constructors in org.apache.paimon.fileindex with parameters of type FileIO

Constructor and Description
FileIndexPredicate(Path path, FileIO fileIO, RowType fileRowType)

Uses of FileIO in org.apache.paimon.flink

Classes in org.apache.paimon.flink that implement FileIO

Modifier and Type	Class and Description
class	FlinkFileIO Flink FileIO to use FileSystem.

Methods in org.apache.paimon.flink that return FileIO

Modifier and Type	Method and Description
FileIO	FlinkFileIOLoader.load(Path path)

Uses of FileIO in org.apache.paimon.format

Methods in org.apache.paimon.format that return FileIO

Modifier and Type	Method and Description
FileIO	FormatReaderContext.fileIO()
FileIO	FormatReaderFactory.Context.fileIO()

Methods in org.apache.paimon.format with parameters of type FileIO

Modifier and Type	Method and Description
SimpleColStats[]	SimpleStatsExtractor.extract(FileIO fileIO, Path path)
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	SimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Constructors in org.apache.paimon.format with parameters of type FileIO

Constructor and Description
FormatReaderContext(FileIO fileIO, Path file, long fileSize)
OrcFormatReaderContext(FileIO fileIO, Path filePath, long fileSize, int poolSize)

Uses of FileIO in org.apache.paimon.format.avro

Methods in org.apache.paimon.format.avro with parameters of type FileIO

Modifier and Type	Method and Description
SimpleColStats[]	AvroSimpleStatsExtractor.extract(FileIO fileIO, Path path)
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	AvroSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.format.fs

Constructors in org.apache.paimon.format.fs with parameters of type FileIO

Constructor and Description
HadoopReadOnlyFileSystem(FileIO fileIO)

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

Methods in org.apache.paimon.format.orc with parameters of type FileIO

Modifier and Type	Method and Description
static org.apache.orc.Reader	OrcReaderFactory.createReader(org.apache.hadoop.conf.Configuration conf, FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.format.orc.filter

Methods in org.apache.paimon.format.orc.filter with parameters of type FileIO

Modifier and Type	Method and Description
SimpleColStats[]	OrcSimpleStatsExtractor.extract(FileIO fileIO, Path path)
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	OrcSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.format.parquet

Methods in org.apache.paimon.format.parquet with parameters of type FileIO

Modifier and Type	Method and Description
SimpleColStats[]	ParquetSimpleStatsExtractor.extract(FileIO fileIO, Path path)
static Pair<Map<String,org.apache.parquet.column.statistics.Statistics<?>>,SimpleStatsExtractor.FileInfo>	ParquetUtil.extractColumnStats(FileIO fileIO, Path path) Extract stats from specified Parquet files path.
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	ParquetSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)
static ParquetInputFile	ParquetInputFile.fromPath(FileIO fileIO, Path path)
static ParquetFileReader	ParquetUtil.getParquetReader(FileIO fileIO, Path path) Generate ParquetFileReader instance to read the Parquet files at the given path.

Uses of FileIO in org.apache.paimon.fs

Classes in org.apache.paimon.fs that implement FileIO

Modifier and Type	Class and Description
class	PluginFileIO A FileIO for plugin jar.

Methods in org.apache.paimon.fs that return FileIO

Modifier and Type	Method and Description
protected abstract FileIO	PluginFileIO.createFileIO(Path path)
static FileIO	FileIO.get(Path path, CatalogContext config) Returns a reference to the FileIO instance for accessing the file system identified by the given path.
FileIO	FileIOLoader.load(Path path)

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

Classes in org.apache.paimon.fs.hadoop that implement FileIO

Modifier and Type	Class and Description
class	HadoopFileIO Hadoop FileIO.

Uses of FileIO in org.apache.paimon.fs.local

Classes in org.apache.paimon.fs.local that implement FileIO

Modifier and Type	Class and Description
class	LocalFileIO FileIO for local file.

Uses of FileIO in org.apache.paimon.hive

Methods in org.apache.paimon.hive with parameters of type FileIO

Modifier and Type	Method and Description
void	TBPropertiesLocationHelper.createPathIfRequired(Path path, FileIO fileIO)
void	LocationHelper.createPathIfRequired(Path dbPath, FileIO fileIO)
void	StorageLocationHelper.createPathIfRequired(Path dbPath, FileIO fileIO)
void	TBPropertiesLocationHelper.dropPathIfRequired(Path path, FileIO fileIO)
void	LocationHelper.dropPathIfRequired(Path path, FileIO fileIO)
void	StorageLocationHelper.dropPathIfRequired(Path path, FileIO fileIO)

Constructors in org.apache.paimon.hive with parameters of type FileIO

Constructor and Description
HiveCatalog(FileIO fileIO, org.apache.hadoop.hive.conf.HiveConf hiveConf, String clientClassName, Options options, String warehouse)
HiveCatalog(FileIO fileIO, org.apache.hadoop.hive.conf.HiveConf hiveConf, String clientClassName, String warehouse)

Uses of FileIO in org.apache.paimon.hive.migrate

Methods in org.apache.paimon.hive.migrate with parameters of type FileIO

Modifier and Type	Method and Description
HiveMigrator.MigrateTask	HiveMigrator.importUnPartitionedTableTask(FileIO fileIO, org.apache.hadoop.hive.metastore.api.Table sourceTable, FileStoreTable paimonTable, Map<Path,Path> rollback)

Constructors in org.apache.paimon.hive.migrate with parameters of type FileIO

Constructor and Description
MigrateTask(FileIO fileIO, String format, String location, FileStoreTable paimonTable, BinaryRow partitionRow, Path newDir, Map<Path,Path> rollback)

Uses of FileIO in org.apache.paimon.iceberg

Methods in org.apache.paimon.iceberg with parameters of type FileIO

Modifier and Type	Method and Description
java.util.stream.Stream<Path>	IcebergPathFactory.getAllMetadataPathBefore(FileIO fileIO, long snapshotId)

Uses of FileIO in org.apache.paimon.iceberg.manifest

Constructors in org.apache.paimon.iceberg.manifest with parameters of type FileIO

Constructor and Description
IcebergManifestFile(FileIO fileIO, RowType partitionType, FormatReaderFactory readerFactory, FormatWriterFactory writerFactory, String compression, PathFactory pathFactory, MemorySize targetFileSize)
IcebergManifestList(FileIO fileIO, FormatReaderFactory readerFactory, FormatWriterFactory writerFactory, String compression, PathFactory pathFactory)

Uses of FileIO in org.apache.paimon.iceberg.metadata

Methods in org.apache.paimon.iceberg.metadata with parameters of type FileIO

Modifier and Type	Method and Description
static IcebergMetadata	IcebergMetadata.fromPath(FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.index

Fields in org.apache.paimon.index declared as FileIO

Modifier and Type	Field and Description
protected FileIO	IndexFile.fileIO

Constructors in org.apache.paimon.index with parameters of type FileIO

Constructor and Description
HashIndexFile(FileIO fileIO, PathFactory pathFactory)
IndexFile(FileIO fileIO, PathFactory pathFactory)

Uses of FileIO in org.apache.paimon.io

Fields in org.apache.paimon.io declared as FileIO

Modifier and Type	Field and Description
protected FileIO	SingleFileWriter.fileIO

Methods in org.apache.paimon.io that return FileIO

Modifier and Type	Method and Description
FileIO	KeyValueFileReaderFactory.Builder.fileIO()
FileIO	KeyValueFileWriterFactory.getFileIO()

Methods in org.apache.paimon.io with parameters of type FileIO

Modifier and Type	Method and Description
static KeyValueFileWriterFactory.Builder	KeyValueFileWriterFactory.builder(FileIO fileIO, long schemaId, RowType keyType, RowType valueType, FileFormat fileFormat, Map<String,FileStorePathFactory> format2PathFactory, long suggestedFileSize)
static KeyValueFileReaderFactory.Builder	KeyValueFileReaderFactory.builder(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType keyType, RowType valueType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, KeyValueFieldsExtractor extractor, CoreOptions options)
static DataFileIndexWriter	DataFileIndexWriter.create(FileIO fileIO, Path path, RowType rowType, FileIndexOptions fileIndexOptions)
static DataFileIndexWriter	DataFileIndexWriter.create(FileIO fileIO, Path path, RowType rowType, FileIndexOptions fileIndexOptions, Map<String,String> colNameMapping)
static boolean	FileIndexSkipper.skip(FileIO fileIO, TableSchema dataSchema, List<Predicate> dataFilter, DataFilePathFactory dataFilePathFactory, DataFileMeta file)

Constructors in org.apache.paimon.io with parameters of type FileIO

Constructor and Description
DataFileIndexWriter(FileIO fileIO, Path path, RowType rowType, FileIndexOptions fileIndexOptions, Map<String,String> colNameMapping)
KeyValueDataFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, SimpleStatsExtractor simpleStatsExtractor, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource)
RowDataFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, RowType writeSchema, SimpleStatsExtractor simpleStatsExtractor, long schemaId, LongCounter seqNumCounter, String fileCompression, SimpleColStatsCollector.Factory[] statsCollectors, FileIndexOptions fileIndexOptions, FileSource fileSource, boolean asyncFileWrite)
RowDataRollingFileWriter(FileIO fileIO, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, DataFilePathFactory pathFactory, LongCounter seqNumCounter, String fileCompression, SimpleColStatsCollector.Factory[] statsCollectors, FileIndexOptions fileIndexOptions, FileSource fileSource, boolean asyncFileWrite)
SingleFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<T,InternalRow> converter, String compression, boolean asyncWrite)
StatsCollectingSingleFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<T,InternalRow> converter, RowType writeSchema, SimpleStatsExtractor simpleStatsExtractor, String compression, SimpleColStatsCollector.Factory[] statsCollectors, boolean asyncWrite)

Uses of FileIO in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc with parameters of type FileIO

Modifier and Type	Method and Description
Catalog	JdbcCatalogFactory.create(FileIO fileIO, Path warehouse, CatalogContext context)

Constructors in org.apache.paimon.jdbc with parameters of type FileIO

Constructor and Description
JdbcCatalog(FileIO fileIO, String catalogKey, Options options, String warehouse)

Uses of FileIO in org.apache.paimon.manifest

Constructors in org.apache.paimon.manifest with parameters of type FileIO

Constructor and Description
Factory(FileIO fileIO, FileFormat fileFormat, String compression, FileStorePathFactory pathFactory, SegmentsCache<Path> cache)
Factory(FileIO fileIO, FileFormat fileFormat, String compression, FileStorePathFactory pathFactory, SegmentsCache<Path> cache)
Factory(FileIO fileIO, SchemaManager schemaManager, RowType partitionType, FileFormat fileFormat, String compression, FileStorePathFactory pathFactory, long suggestedFileSize, SegmentsCache<Path> cache)

Uses of FileIO in org.apache.paimon.migrate

Methods in org.apache.paimon.migrate with parameters of type FileIO

Modifier and Type	Method and Description
static List<DataFileMeta>	FileMetaUtils.construct(FileIO fileIO, String format, String location, Table paimonTable, java.util.function.Predicate<FileStatus> filter, Path dir, Map<Path,Path> rollback)

Uses of FileIO in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as FileIO

Modifier and Type	Field and Description
protected FileIO	FileDeletionBase.fileIO

Methods in org.apache.paimon.operation that return FileIO

Modifier and Type	Method and Description
FileIO	FileStoreCommitImpl.fileIO()
FileIO	FileStoreCommit.fileIO()

Constructors in org.apache.paimon.operation with parameters of type FileIO

Constructor and Description
AppendOnlyFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, BucketMode bucketMode, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
ChangelogDeletion(FileIO fileIO, FileStorePathFactory pathFactory, ManifestFile manifestFile, ManifestList manifestList, IndexFileHandler indexFileHandler, StatsFileHandler statsFileHandler, boolean cleanEmptyDirectories, int deleteFileThreadNum)
FileDeletionBase(FileIO fileIO, FileStorePathFactory pathFactory, ManifestFile manifestFile, ManifestList manifestList, IndexFileHandler indexFileHandler, StatsFileHandler statsFileHandler, boolean cleanEmptyDirectories, int deleteFileThreadNum)
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, String commitUser, RowType partitionType, String partitionDefaultName, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, IndexManifestFile.Factory indexManifestFileFactory, FileStoreScan scan, int numBucket, MemorySize manifestTargetSize, MemorySize manifestFullCompactionSize, int manifestMergeMinCount, boolean dynamicPartitionOverwrite, Comparator<InternalRow> keyComparator, String branchName, StatsFileHandler statsFileHandler, BucketMode bucketMode, Integer manifestReadParallelism, List<CommitCallback> commitCallbacks, int commitMaxRetries)
KeyValueFileStoreWrite(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier, java.util.function.Supplier<FieldsComparator> udsComparatorSupplier, java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier, MergeFunctionFactory<KeyValue> mfFactory, FileStorePathFactory pathFactory, Map<String,FileStorePathFactory> format2PathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)
RawFileSplitRead(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType rowType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, boolean fileIndexReadEnabled)
SnapshotDeletion(FileIO fileIO, FileStorePathFactory pathFactory, ManifestFile manifestFile, ManifestList manifestList, IndexFileHandler indexFileHandler, StatsFileHandler statsFileHandler, boolean produceChangelog, boolean cleanEmptyDirectories, int deleteFileThreadNum)
TagDeletion(FileIO fileIO, FileStorePathFactory pathFactory, ManifestFile manifestFile, ManifestList manifestList, IndexFileHandler indexFileHandler, StatsFileHandler statsFileHandler, boolean cleanEmptyDirectories, int deleteFileThreadNum)

Uses of FileIO in org.apache.paimon.oss

Classes in org.apache.paimon.oss that implement FileIO

Modifier and Type	Class and Description
class	OSSFileIO OSS FileIO.

Methods in org.apache.paimon.oss that return FileIO

Modifier and Type	Method and Description
FileIO	OSSLoader.load(Path path)

Uses of FileIO in org.apache.paimon.partition.actions

Methods in org.apache.paimon.partition.actions with parameters of type FileIO

Modifier and Type	Method and Description
static SuccessFile	SuccessFileMarkDoneAction.safelyFromPath(FileIO fileIO, Path path)

Constructors in org.apache.paimon.partition.actions with parameters of type FileIO

Constructor and Description
SuccessFileMarkDoneAction(FileIO fileIO, Path tablePath)

Uses of FileIO in org.apache.paimon.partition.file

Methods in org.apache.paimon.partition.file with parameters of type FileIO

Modifier and Type	Method and Description
static SuccessFile	SuccessFile.fromPath(FileIO fileIO, Path path)
static SuccessFile	SuccessFile.safelyFromPath(FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.privilege

Constructors in org.apache.paimon.privilege with parameters of type FileIO

Constructor and Description
FileBasedPrivilegeManager(String warehouse, FileIO fileIO, String user, String password)

Uses of FileIO in org.apache.paimon.s3

Classes in org.apache.paimon.s3 that implement FileIO

Modifier and Type	Class and Description
class	HadoopCompliantFileIO Hadoop FileIO.
class	S3FileIO S3 FileIO.

Methods in org.apache.paimon.s3 that return FileIO

Modifier and Type	Method and Description
FileIO	S3Loader.load(Path path)

Uses of FileIO in org.apache.paimon.schema

Methods in org.apache.paimon.schema with parameters of type FileIO

Modifier and Type	Method and Description
static TableSchema	SchemaManager.fromPath(FileIO fileIO, Path path)
static TableSchema	TableSchema.fromPath(FileIO fileIO, Path path)

Constructors in org.apache.paimon.schema with parameters of type FileIO

Constructor and Description
SchemaManager(FileIO fileIO, Path tableRoot)
SchemaManager(FileIO fileIO, Path tableRoot, String branch) Specify the default branch for data writing.

Uses of FileIO in org.apache.paimon.service

Constructors in org.apache.paimon.service with parameters of type FileIO

Constructor and Description
ServiceManager(FileIO fileIO, Path tablePath)

Uses of FileIO in org.apache.paimon.stats

Methods in org.apache.paimon.stats with parameters of type FileIO

Modifier and Type	Method and Description
static Statistics	Statistics.fromPath(FileIO fileIO, Path path)

Constructors in org.apache.paimon.stats with parameters of type FileIO

Constructor and Description
StatsFile(FileIO fileIO, PathFactory pathFactory)

Uses of FileIO in org.apache.paimon.table

Methods in org.apache.paimon.table that return FileIO

Modifier and Type	Method and Description
FileIO	DataTable.fileIO()
FileIO	DelegatedFileStoreTable.fileIO()

Methods in org.apache.paimon.table with parameters of type FileIO

Modifier and Type	Method and Description
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Options options)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path path)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, CatalogEnvironment catalogEnvironment)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, Options dynamicOptions, CatalogEnvironment catalogEnvironment)

Constructors in org.apache.paimon.table with parameters of type FileIO

Constructor and Description
RollbackHelper(SnapshotManager snapshotManager, TagManager tagManager, FileIO fileIO, SnapshotDeletion snapshotDeletion, ChangelogDeletion changelogDeletion, TagDeletion tagDeletion)

Uses of FileIO in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return FileIO

Modifier and Type	Method and Description
FileIO	FileMonitorTable.fileIO()
FileIO	CompactBucketsTable.fileIO()
FileIO	AuditLogTable.fileIO()
FileIO	ReadOptimizedTable.fileIO()

Methods in org.apache.paimon.table.system with parameters of type FileIO

Modifier and Type	Method and Description
static Table	SystemTableLoader.loadGlobal(String tableName, FileIO fileIO, java.util.function.Supplier<Map<String,Map<String,Path>>> allTablePaths, Options catalogOptions, LineageMetaFactory lineageMetaFactory)
protected static Map<String,Map<String,Map<String,String>>>	AllTableOptionsTable.options(FileIO fileIO, Map<String,Map<String,Path>> allTablePaths)

Constructors in org.apache.paimon.table.system with parameters of type FileIO

Constructor and Description
AggregationFieldsTable(FileIO fileIO, Path location, String branchName)
AllTableOptionsTable(FileIO fileIO, Map<String,Map<String,Path>> allTablePaths)
BranchesTable(FileIO fileIO, Path location)
ConsumersTable(FileIO fileIO, Path location, String branchName)
OptionsTable(FileIO fileIO, Path location, String branchName)
SchemasTable(FileIO fileIO, Path location, String branchName)
SnapshotsTable(FileIO fileIO, Path location, FileStoreTable dataTable, String branchName)
StatisticTable(FileIO fileIO, Path location, FileStoreTable dataTable)
TagsTable(FileIO fileIO, Path location, String branchName)

Uses of FileIO in org.apache.paimon.tag

Methods in org.apache.paimon.tag with parameters of type FileIO

Modifier and Type	Method and Description
static Tag	Tag.fromPath(FileIO fileIO, Path path)
static Tag	Tag.safelyFromPath(FileIO fileIO, Path path)

Uses of FileIO in org.apache.paimon.utils

Fields in org.apache.paimon.utils declared as FileIO

Modifier and Type	Field and Description
protected FileIO	ObjectsFile.fileIO

Methods in org.apache.paimon.utils that return FileIO

Modifier and Type	Method and Description
FileIO	ObjectsFile.fileIO()
FileIO	SnapshotManager.fileIO()

Methods in org.apache.paimon.utils with parameters of type FileIO

Modifier and Type	Method and Description
static void	FileUtils.checkExists(FileIO fileIO, Path file)
static RecordReader<InternalRow>	FileUtils.createFormatReader(FileIO fileIO, FormatReaderFactory format, Path file, Long fileSize)
static java.util.stream.Stream<String>	FileUtils.listOriginalVersionedFiles(FileIO fileIO, Path dir, String prefix) List original versioned files for the directory.
static java.util.stream.Stream<FileStatus>	FileUtils.listVersionedDirectories(FileIO fileIO, Path dir, String prefix) List versioned directories for the directory.
static java.util.stream.Stream<Long>	FileUtils.listVersionedFiles(FileIO fileIO, Path dir, String prefix) List versioned files for the directory.
static java.util.stream.Stream<FileStatus>	FileUtils.listVersionedFileStatus(FileIO fileIO, Path dir, String prefix) List versioned file status for the directory.
static IntIterator	IntFileUtils.readInts(FileIO fileIO, Path path)
static void	IntFileUtils.writeInts(FileIO fileIO, Path path, IntIterator input)

Constructors in org.apache.paimon.utils with parameters of type FileIO

Constructor and Description
BranchManager(FileIO fileIO, Path path, SnapshotManager snapshotManager, TagManager tagManager, SchemaManager schemaManager)
ObjectsFile(FileIO fileIO, ObjectSerializer<T> serializer, RowType formatType, FormatReaderFactory readerFactory, FormatWriterFactory writerFactory, String compression, PathFactory pathFactory, SegmentsCache<Path> cache)
SnapshotManager(FileIO fileIO, Path tablePath)
SnapshotManager(FileIO fileIO, Path tablePath, String branchName) Specify the default branch for data writing.
TagManager(FileIO fileIO, Path tablePath)
TagManager(FileIO fileIO, Path tablePath, String branch) Specify the default branch for data writing.