FileStore (Paimon : 1.1-SNAPSHOT API)

Type Parameters:

T - type of record to read and write.

All Known Implementing Classes:

AppendOnlyFileStore, KeyValueFileStore, PrivilegedFileStore
```
public interface FileStore<T>
```
File store interface.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`BucketMode`	`bucketMode()`
`ChangelogManager`	`changelogManager()`
`List<TagCallback>`	`createTagCallbacks()`
`IndexManifestFile.Factory`	`indexManifestFileFactory()`
`ManifestFile.Factory`	`manifestFileFactory()`
`ManifestList.Factory`	`manifestListFactory()`
`boolean`	`mergeSchema(RowType rowType, boolean allowExplicitCast)`
`ChangelogDeletion`	`newChangelogDeletion()`
`FileStoreCommit`	`newCommit(String commitUser, FileStoreTable table)`
`IndexFileHandler`	`newIndexFileHandler()`
`PartitionExpire`	`newPartitionExpire(String commitUser, FileStoreTable table)`
`PartitionExpire`	`newPartitionExpire(String commitUser, FileStoreTable table, java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy expireStrategy)`
`SplitRead<T>`	`newRead()`
`FileStoreScan`	`newScan()`
`ServiceManager`	`newServiceManager()`
`SnapshotDeletion`	`newSnapshotDeletion()`
`StatsFileHandler`	`newStatsFileHandler()`
`TagAutoManager`	`newTagCreationManager()`
`TagDeletion`	`newTagDeletion()`
`TagManager`	`newTagManager()`
`FileStoreWrite<T>`	`newWrite(String commitUser)`
`FileStoreWrite<T>`	`newWrite(String commitUser, ManifestCacheFilter manifestFilter)`
`CoreOptions`	`options()`
`RowType`	`partitionType()`
`FileStorePathFactory`	`pathFactory()`
`void`	`setManifestCache(SegmentsCache<Path> manifestCache)`
`void`	`setSnapshotCache(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Path,Snapshot> cache)`
`SnapshotManager`	`snapshotManager()`

Method Detail

pathFactory
```
FileStorePathFactory pathFactory()
```

snapshotManager
```
SnapshotManager snapshotManager()
```

changelogManager
```
ChangelogManager changelogManager()
```

partitionType
```
RowType partitionType()
```

options
```
CoreOptions options()
```

bucketMode
```
BucketMode bucketMode()
```

newScan
```
FileStoreScan newScan()
```

manifestListFactory

ManifestList.Factory manifestListFactory()

manifestFileFactory

ManifestFile.Factory manifestFileFactory()

indexManifestFileFactory

IndexManifestFile.Factory indexManifestFileFactory()

newIndexFileHandler
```
IndexFileHandler newIndexFileHandler()
```

newStatsFileHandler
```
StatsFileHandler newStatsFileHandler()
```

newRead
```
SplitRead<T> newRead()
```

newWrite

FileStoreWrite<T> newWrite(String commitUser)

newWrite

FileStoreWrite<T> newWrite(String commitUser,
                           ManifestCacheFilter manifestFilter)

newCommit

FileStoreCommit newCommit(String commitUser,
                          FileStoreTable table)

newSnapshotDeletion
```
SnapshotDeletion newSnapshotDeletion()
```

newChangelogDeletion

ChangelogDeletion newChangelogDeletion()

newTagManager
```
TagManager newTagManager()
```

newTagDeletion
```
TagDeletion newTagDeletion()
```

newPartitionExpire

@Nullable
PartitionExpire newPartitionExpire(String commitUser,
                                             FileStoreTable table)

newPartitionExpire

@Nullable
PartitionExpire newPartitionExpire(String commitUser,
                                             FileStoreTable table,
                                             java.time.Duration expirationTime,
                                             java.time.Duration checkInterval,
                                             PartitionExpireStrategy expireStrategy)

newTagCreationManager
```
TagAutoManager newTagCreationManager()
```

newServiceManager
```
ServiceManager newServiceManager()
```

mergeSchema

boolean mergeSchema(RowType rowType,
                    boolean allowExplicitCast)

createTagCallbacks
```
List<TagCallback> createTagCallbacks()
```

setManifestCache

void setManifestCache(SegmentsCache<Path> manifestCache)

setSnapshotCache

void setSnapshotCache(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Path,Snapshot> cache)

Back to Paimon Website

Interface FileStore<T>

Method Summary

Method Detail

pathFactory

snapshotManager

changelogManager

partitionType

options

bucketMode

newScan

manifestListFactory

manifestFileFactory

indexManifestFileFactory

newIndexFileHandler

newStatsFileHandler

newRead

newWrite

newWrite

newCommit

newSnapshotDeletion

newChangelogDeletion

newTagManager

newTagDeletion

newPartitionExpire

newPartitionExpire

newTagCreationManager

newServiceManager

mergeSchema

createTagCallbacks

setManifestCache

setSnapshotCache

Back to Paimon Website