Storage Files and Directories
StorageFileNameProvider fileNameProvider = StorageFileNameProvider.Builder()
.setChannelDirectoryPrefix("canal_")
.setDataFilePrefix ("canal_")
.setDataFileSuffix (".bin")
.setTransactionsFilePrefix("events_")
.setTransactionsFileSuffix(".bin")
.setTypeDictionaryFileName("typeDictionary.txt")
.createFileNameProvider ()
;
NioFileSystem fileSystem = NioFileSystem.New();
StorageLiveFileProvider fileProvider = Storage
.FileProviderBuilder (fileSystem)
.setDirectory (fileSystem.ensureDirectoryPath(WORKINGDIR))
.setDeletionDirectory (fileSystem.ensureDirectoryPath(DELETIONDIR))
.setTruncationDirectory(fileSystem.ensureDirectoryPath(TRUNCATIONDIR))
.setFileNameProvider (fileNameProvider)
.createFileProvider ()
;Last updated