FileStore (Paimon : 1.0-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()`
`List<TagCallback>`	`createTagCallbacks()`
`IndexManifestFile.Factory`	`indexManifestFileFactory()`
`ManifestFile.Factory`	`manifestFileFactory()`
`ManifestList.Factory`	`manifestListFactory()`
`boolean`	`mergeSchema(RowType rowType, boolean allowExplicitCast)`
`ChangelogDeletion`	`newChangelogDeletion()`
`FileStoreCommit`	`newCommit(String commitUser)`
`FileStoreCommit`	`newCommit(String commitUser, List<CommitCallback> callbacks)`
`IndexFileHandler`	`newIndexFileHandler()`
`PartitionExpire`	`newPartitionExpire(String commitUser)`
`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()
```

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)

newCommit

FileStoreCommit newCommit(String commitUser,
                          List<CommitCallback> callbacks)

newSnapshotDeletion
```
SnapshotDeletion newSnapshotDeletion()
```

newChangelogDeletion

ChangelogDeletion newChangelogDeletion()

newTagManager
```
TagManager newTagManager()
```

newTagDeletion
```
TagDeletion newTagDeletion()
```

newPartitionExpire

@Nullable
PartitionExpire newPartitionExpire(String commitUser)

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

partitionType

options

bucketMode

newScan

manifestListFactory

manifestFileFactory

indexManifestFileFactory

newIndexFileHandler

newStatsFileHandler

newRead

newWrite

newWrite

newCommit

newCommit

newSnapshotDeletion

newChangelogDeletion

newTagManager

newTagDeletion

newPartitionExpire

newTagCreationManager

newServiceManager

mergeSchema

createTagCallbacks

setManifestCache

setSnapshotCache

Back to Paimon Website