Uses of Class
org.apache.cassandra.io.util.File
-
-
Uses of File in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache that return File Modifier and Type Method Description FileAutoSavingCache. getCacheCrcPath(java.lang.String version)FileAutoSavingCache. getCacheDataPath(java.lang.String version)Methods in org.apache.cassandra.cache with parameters of type File Modifier and Type Method Description java.io.InputStreamAutoSavingCache.IStreamFactory. getInputStream(File dataPath, File crcPath)java.io.OutputStreamAutoSavingCache.IStreamFactory. getOutputStream(File dataPath, File crcPath) -
Uses of File in org.apache.cassandra.config
Methods in org.apache.cassandra.config that return File Modifier and Type Method Description static FileDatabaseDescriptor. getHintsDirectory()static FileDatabaseDescriptor. getSerializedCachePath(CacheService.CacheType cacheType, java.lang.String version, java.lang.String extension) -
Uses of File in org.apache.cassandra.db
Fields in org.apache.cassandra.db declared as File Modifier and Type Field Description FileDirectories.DataDirectory. locationMethods in org.apache.cassandra.db that return File Modifier and Type Method Description static FileDirectories. getBackupsDirectory(Descriptor desc)static FileDirectories. getBackupsDirectory(File location)FileDirectories. getDirectoryForNewSSTables()Basically the same as callingDirectories.getWriteableLocationAsFile(long)with an unknown size (-1L), which may return any allowed directory - even a data directory that has no usable space.FileDirectories. getLocationForDisk(Directories.DataDirectory dataDirectory)Returns SSTable location which is inside given data directory.FileDirectories. getNewEphemeralSnapshotMarkerFile(java.lang.String snapshotName)static FileDirectories. getSnapshotDirectory(Descriptor desc, java.lang.String snapshotName)static FileDirectories. getSnapshotDirectory(File location, java.lang.String snapshotName)Returns directory to write snapshot.FileDirectories. getSnapshotManifestFile(java.lang.String snapshotName)static FileDirectories. getSnapshotManifestFile(File snapshotDir)FileDirectories. getSnapshotSchemaFile(java.lang.String snapshotName)static FileDirectories. getSnapshotSchemaFile(File snapshotDir)FileDirectories. getTemporaryWriteableDirectoryAsFile(long writeSize)Returns a temporary subdirectory on allowed data directory that _currently_ haswriteSizebytes as usable space.FileDirectories. getWriteableLocationAsFile(long writeSize)Returns an allowed directory that _currently_ haswriteSizebytes as usable space.FileDirectories. getWriteableLocationToLoadFile(File sourceFile)Returns a data directory to load the filesourceFile.static FileDisallowedDirectories. maybeMarkUnreadable(File path)Adds parent directory of the file (or the file itself, if it is a directory) to the set of unreadable directories.static FileDisallowedDirectories. maybeMarkUnwritable(File path)Adds parent directory of the file (or the file itself, if it is a directory) to the set of unwritable directories.Methods in org.apache.cassandra.db that return types with arguments of type File Modifier and Type Method Description java.util.List<File>Directories. getCFDirectories()static java.util.List<File>Directories. getKSChildDirectories(java.lang.String ksName)java.util.List<File>Directories.SSTableLister. listFiles()java.util.List<File>Directories.SSTableLister. listFiles(boolean includeForeignTables)protected java.util.Map<java.lang.String,java.util.Set<File>>Directories. listSnapshotDirsByTag()Methods in org.apache.cassandra.db with parameters of type File Modifier and Type Method Description static FileDirectories. getBackupsDirectory(File location)static FileDirectories. getSnapshotDirectory(File location, java.lang.String snapshotName)Returns directory to write snapshot.static FileDirectories. getSnapshotManifestFile(File snapshotDir)static FileDirectories. getSnapshotSchemaFile(File snapshotDir)longDirectories. getTrueAllocatedSizeIn(File snapshotDir)FileDirectories. getWriteableLocationToLoadFile(File sourceFile)Returns a data directory to load the filesourceFile.static booleanDirectories.FileAction. hasPrivilege(File file, Directories.FileAction action)static booleanDirectories. isSecondaryIndexFolder(File dir)static booleanDisallowedDirectories. isUnreadable(File directory)Tells whether or not the directory is disallowed for reads.static booleanDisallowedDirectories. isUnwritable(File directory)Tells whether or not the directory is disallowed for writes.static FileDisallowedDirectories. maybeMarkUnreadable(File path)Adds parent directory of the file (or the file itself, if it is a directory) to the set of unreadable directories.static FileDisallowedDirectories. maybeMarkUnwritable(File path)Adds parent directory of the file (or the file itself, if it is a directory) to the set of unwritable directories.DescriptorColumnFamilyStore. newSSTableDescriptor(File directory)DescriptorColumnFamilyStore. newSSTableDescriptor(File directory, SSTableFormat.Type format)DescriptorColumnFamilyStore. newSSTableDescriptor(File directory, Version version, SSTableFormat.Type format)static voidDirectories. removeSnapshotDirectory(com.google.common.util.concurrent.RateLimiter snapshotRateLimiter, File snapshotDir)static voidKeyspace. removeUnreadableSSTables(File directory)Removes every SSTable in the directory from the appropriate Tracker's view.Directories.SSTableListerDirectories. sstableLister(File directory, Directories.OnTxnErr onTxnErr)static booleanDirectories. verifyFullPermissions(File dir, java.lang.String dataDir)Checks whether Cassandra has RWX permissions to the specified directory.Method parameters in org.apache.cassandra.db with type arguments of type File Modifier and Type Method Description protected TableSnapshotDirectories. buildSnapshot(java.lang.String tag, SnapshotManifest manifest, java.util.Set<File> snapshotDirs)static voidDirectories. clearSnapshot(java.lang.String snapshotName, java.util.List<File> tableDirectories, com.google.common.util.concurrent.RateLimiter snapshotRateLimiter)protected static SnapshotManifestDirectories. maybeLoadManifest(java.lang.String keyspace, java.lang.String table, java.lang.String tag, java.util.Set<File> snapshotDirs)Constructors in org.apache.cassandra.db with parameters of type File Constructor Description DataDirectory(File location) -
Uses of File in org.apache.cassandra.db.commitlog
Methods in org.apache.cassandra.db.commitlog that return File Modifier and Type Method Description FileCommitLogSegment. getCDCFile()FileCommitLogSegment. getCDCIndexFile()File[]CommitLog. getUnmanagedFiles()static FileCommitLogDescriptor. inferCdcIndexFile(File cdcCommitLogSegment)Infer the corresponding cdc index file using its cdc commitlog fileMethods in org.apache.cassandra.db.commitlog with parameters of type File Modifier and Type Method Description intCommitLogSegment.CommitLogSegmentFileComparator. compare(File f, File f2)static CommitLogDescriptorCommitLogDescriptor. fromHeader(File file, EncryptionContext encryptionContext)static FileCommitLogDescriptor. inferCdcIndexFile(File cdcCommitLogSegment)Infer the corresponding cdc index file using its cdc commitlog filevoidCommitLogReader. readAllFiles(CommitLogReadHandler handler, File[] files)Reads all passed in files with no minimum, no start, and no mutation limit.voidCommitLogReader. readAllFiles(CommitLogReadHandler handler, File[] files, CommitLogPosition minPosition)Reads all passed in files with minPosition, no start, and no mutation limit.voidCommitLogReader. readCommitLogSegment(CommitLogReadHandler handler, File file, boolean tolerateTruncation)Reads passed in file fullyvoidCommitLogReader. readCommitLogSegment(CommitLogReadHandler handler, File file, int mutationLimit, boolean tolerateTruncation)Reads passed in file fully, up to mutationLimit countvoidCommitLogReader. readCommitLogSegment(CommitLogReadHandler handler, File file, CommitLogPosition minPosition, boolean tolerateTruncation)Reads all mutations from passed in file from minPositionvoidCommitLogReader. readCommitLogSegment(CommitLogReadHandler handler, File file, CommitLogPosition minPosition, int mutationLimit, boolean tolerateTruncation)Reads mutations from file, handing them off to handlerintCommitLog. recoverFiles(File... clogs)Perform recovery on a list of commit log files.voidCommitLogReplayer. replayFiles(File[] clogs)voidCommitLogReplayer. replayPath(File file, boolean tolerateTruncation) -
Uses of File in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type File Modifier and Type Method Description static SSTableWriterCompactionManager. createWriter(ColumnFamilyStore cfs, File compactionFileLocation, long expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableReader sstable, LifecycleTransaction txn)static SSTableWriterCompactionManager. createWriterForAntiCompaction(ColumnFamilyStore cfs, File compactionFileLocation, int expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, java.util.Collection<SSTableReader> sstables, ILifecycleTransaction txn) -
Uses of File in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle that return types with arguments of type File Modifier and Type Method Description static java.util.List<File>LifecycleTransaction. getFiles(java.nio.file.Path folder, java.util.function.BiPredicate<File,Directories.FileType> filter, Directories.OnTxnErr onTxnErr)Get the files in the folder specified, provided that the filter returns true.Methods in org.apache.cassandra.db.lifecycle with parameters of type File Modifier and Type Method Description voidTracker. removeUnreadableSSTables(File directory)Removes every SSTable in the directory from the Tracker's view.Method parameters in org.apache.cassandra.db.lifecycle with type arguments of type File Modifier and Type Method Description static java.util.List<File>LifecycleTransaction. getFiles(java.nio.file.Path folder, java.util.function.BiPredicate<File,Directories.FileType> filter, Directories.OnTxnErr onTxnErr)Get the files in the folder specified, provided that the filter returns true. -
Uses of File in org.apache.cassandra.hints
Methods in org.apache.cassandra.hints with parameters of type File Modifier and Type Method Description static ChecksummedDataInputChecksummedDataInput. open(File file)Constructors in org.apache.cassandra.hints with parameters of type File Constructor Description CompressedHintsWriter(File directory, org.apache.cassandra.hints.HintsDescriptor descriptor, File file, java.nio.channels.FileChannel channel, int fd, java.util.zip.CRC32 globalCRC)EncryptedHintsWriter(File directory, org.apache.cassandra.hints.HintsDescriptor descriptor, File file, java.nio.channels.FileChannel channel, int fd, java.util.zip.CRC32 globalCRC) -
Uses of File in org.apache.cassandra.index.sasi
Constructors in org.apache.cassandra.index.sasi with parameters of type File Constructor Description SSTableIndex(ColumnIndex index, File indexFile, SSTableReader referent) -
Uses of File in org.apache.cassandra.index.sasi.disk
Methods in org.apache.cassandra.index.sasi.disk with parameters of type File Modifier and Type Method Description protected booleanOnDiskIndexBuilder. finish(Descriptor descriptor, File file)protected voidOnDiskIndexBuilder. finish(Descriptor descriptor, Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, File file, TermIterator terms)booleanOnDiskIndexBuilder. finish(File indexFile)Finishes up index building process by creating/populating index file.voidOnDiskIndexBuilder. finish(Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, File file, TermIterator terms)Constructors in org.apache.cassandra.index.sasi.disk with parameters of type File Constructor Description OnDiskIndex(File index, AbstractType<?> cmp, com.google.common.base.Function<java.lang.Long,DecoratedKey> keyReader) -
Uses of File in org.apache.cassandra.io
Constructors in org.apache.cassandra.io with parameters of type File Constructor Description FSError(java.lang.String message, java.lang.Throwable cause, File path)FSError(java.lang.Throwable cause, File path)FSReadError(java.lang.String message, java.lang.Throwable cause, File path)FSReadError(java.lang.Throwable cause, File path)FSWriteError(java.lang.String message, java.lang.Throwable cause, File path)FSWriteError(java.lang.Throwable cause, File path) -
Uses of File in org.apache.cassandra.io.compress
Constructors in org.apache.cassandra.io.compress with parameters of type File Constructor Description CompressedSequentialWriter(File file, java.lang.String offsetsPath, File digestFile, SequentialWriterOption option, CompressionParams parameters, MetadataCollector sstableMetadataCollector)Create CompressedSequentialWriter without digest file. -
Uses of File in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as File Modifier and Type Field Description FileDescriptor. directorycanonicalized path to the directory where SSTable residesFileCorruptSSTableException. pathMethods in org.apache.cassandra.io.sstable that return File Modifier and Type Method Description FileDescriptor. fileFor(Component component)Methods in org.apache.cassandra.io.sstable that return types with arguments of type File Modifier and Type Method Description java.util.List<File>Descriptor. getTemporaryFiles()Return any temporary files found in the directoryMethods in org.apache.cassandra.io.sstable with parameters of type File Modifier and Type Method Description static DescriptorDescriptor. fromFilename(File file)Parse a sstable filename into a Descriptor.static Pair<Descriptor,Component>Descriptor. fromFilenameWithComponent(File file)Parse a sstable filename, extracting both theDescriptorandComponentpart.CQLSSTableWriter.BuilderCQLSSTableWriter.Builder. inDirectory(File directory)The directory where to write the sstables (mandatory option).static booleanDescriptor. isValidFile(File file)static Pair<Descriptor,Component>SSTable. tryComponentFromFilename(File file)Parse a sstable filename into both aDescriptorandComponentobject.static DescriptorSSTable. tryDescriptorFromFilename(File file)Parse a sstable filename into aDescriptorobject.Constructors in org.apache.cassandra.io.sstable with parameters of type File Constructor Description CorruptSSTableException(java.lang.Throwable cause, File path)Descriptor(java.lang.String version, File directory, java.lang.String ksname, java.lang.String cfname, SSTableId id, SSTableFormat.Type formatType)Descriptor(Version version, File directory, java.lang.String ksname, java.lang.String cfname, SSTableId id, SSTableFormat.Type formatType)Descriptor(File directory, java.lang.String ksname, java.lang.String cfname, SSTableId id)A descriptor that assumes CURRENT_VERSION.Descriptor(File directory, java.lang.String ksname, java.lang.String cfname, SSTableId id, SSTableFormat.Type formatType)Constructor for sstable writers only.SSTableLoader(File directory, SSTableLoader.Client client, OutputHandler outputHandler)SSTableLoader(File directory, SSTableLoader.Client client, OutputHandler outputHandler, int connectionsPerHost, java.lang.String targetKeyspace) -
Uses of File in org.apache.cassandra.io.util
Methods in org.apache.cassandra.io.util that return File Modifier and Type Method Description static FileFileUtils. createDeletableTempFile(java.lang.String prefix, java.lang.String suffix)static FileFileUtils. createTempFile(java.lang.String prefix, java.lang.String suffix)static FileFileUtils. createTempFile(java.lang.String prefix, java.lang.String suffix, File directory)Pretty much likeFile.createTempFile(String, String, java.io.File), but with the guarantee that the "random" part of the generated file name betweenprefixandsuffixis a positive, increasinglongvalue.static FileFileUtils. getTempDir()File[]File. list()File[]File. list(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. list(java.util.function.Predicate<File> filter)File[]File. listUnchecked()File[]File. listUnchecked(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. listUnchecked(java.util.function.Predicate<File> filter)FileFile. parent()FileFile. toAbsolute()FileFile. toCanonical()File[]File. tryList()File[]File. tryList(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. tryList(java.util.function.Predicate<File> filter)Methods in org.apache.cassandra.io.util with parameters of type File Modifier and Type Method Description static voidFileUtils. append(File file, java.lang.String... lines)static voidFileUtils. appendAndSync(File file, java.lang.String... lines)intFile. compareTo(File that)static voidFileUtils. copyWithConfirm(File from, File to)static voidFileUtils. createDirectory(File directory)Deprecated.static voidFileUtils. createHardLink(File from, File to)static voidFileUtils. createHardLinkWithConfirm(File from, File to)static FileFileUtils. createTempFile(java.lang.String prefix, java.lang.String suffix, File directory)Pretty much likeFile.createTempFile(String, String, java.io.File), but with the guarantee that the "random" part of the generated file name betweenprefixandsuffixis a positive, increasinglongvalue.static voidFileUtils. delete(File... files)Deprecated.static voidFileUtils. deleteRecursive(File dir)Deprecated.static voidFileUtils. deleteRecursiveOnExit(File dir)Deprecated.static voidFileUtils. deleteRecursiveWithThrottle(File dir, com.google.common.util.concurrent.RateLimiter rateLimiter)Deprecated.static voidFileUtils. deleteWithConfirm(File file)Deprecated.static java.lang.ThrowableFileUtils. deleteWithConfirm(File file, java.lang.Throwable accumulate)Deprecated.static java.lang.ThrowableFileUtils. deleteWithConfirm(File file, java.lang.Throwable accumulate, com.google.common.util.concurrent.RateLimiter rateLimiter)Deprecated.static longFileUtils. folderSize(File folder)Get the size of a directory in bytesstatic java.lang.StringFileUtils. getCanonicalPath(File file)booleanFile. isAncestorOf(File child)static booleanFileUtils. isContained(File folder, File file)Return true if file is contained in folderstatic booleanFileUtils. isSubDirectory(File parent, File child)Deprecated.voidFile. move(File to)Atomically (if supported) rename/move this file totostatic RandomAccessReaderChecksummedRandomAccessReader. open(File file, File crcFile)static RandomAccessReaderRandomAccessReader. open(File file)Open a RandomAccessReader (not compressed, not mmapped, no read throttling) that will own its channel.static java.nio.channels.FileChannelChannelProxy. openChannel(File file)static java.util.List<java.lang.String>FileUtils. readLines(File file)static voidFileUtils. renameWithConfirm(File from, File to)Deprecated.static voidFileUtils. replace(File file, java.lang.String... lines)booleanFile. tryMove(File to)Try to rename the file atomically, if the system supports it.static voidFileUtils. write(File file, java.util.List<java.lang.String> lines, java.nio.file.StandardOpenOption... options)Write lines to a file adding a newline to the end of each supplied line using the provided open options.voidChecksumWriter. writeFullChecksum(File digestFile)Method parameters in org.apache.cassandra.io.util with type arguments of type File Modifier and Type Method Description voidFile. forEach(java.util.function.Consumer<File> forEach)voidFile. forEachRecursive(java.util.function.Consumer<File> forEach)File[]File. list(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. list(java.util.function.Predicate<File> filter)java.lang.String[]File. listNames(java.util.function.BiPredicate<File,java.lang.String> filter)java.lang.String[]File. listNamesUnchecked(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. listUnchecked(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. listUnchecked(java.util.function.Predicate<File> filter)File[]File. tryList(java.util.function.BiPredicate<File,java.lang.String> filter)File[]File. tryList(java.util.function.Predicate<File> filter)java.lang.String[]File. tryListNames(java.util.function.BiPredicate<File,java.lang.String> filter)<T extends java.lang.Throwable>
java.lang.String[]File. tryListNames(java.util.function.BiPredicate<File,java.lang.String> filter, net.openhft.chronicle.core.util.ThrowingFunction<java.io.IOException,java.lang.String[],T> orElse)Constructors in org.apache.cassandra.io.util with parameters of type File Constructor Description ChannelProxy(File file)ChecksummedSequentialWriter(File file, File crcPath, File digestFile, SequentialWriterOption option)File(File parent, java.lang.String child)Construct a File representing the childchildofparentFileInputStreamPlus(File file)FileOutputStreamPlus(File file)FileOutputStreamPlus(File file, File.WriteMode mode)FileReader(File file)FileWriter(File file)FileWriter(File file, File.WriteMode mode)SequentialWriter(File file)Create heap-based, non-compressed SequenialWriter with default buffer size(64k).SequentialWriter(File file, SequentialWriterOption option)Create SequentialWriter for given file with specific writer option.SequentialWriter(File file, SequentialWriterOption option, boolean strictFlushing)Create SequentialWriter for given file with specific writer option. -
Uses of File in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type File Modifier and Type Method Description static DataResurrectionCheck.HeartbeatDataResurrectionCheck.Heartbeat. deserializeFromJsonFile(File file)voidDataResurrectionCheck.Heartbeat. serializeToJsonFile(File outputFile) -
Uses of File in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted that return File Modifier and Type Method Description FilePaxosBallotTracker. getDirectory()FilePaxosUncommittedTracker. getDirectory()Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type File Modifier and Type Method Description static PaxosStateTrackerPaxosStateTracker. create(File[] directories)static UncommittedDataFileUncommittedDataFile. create(TableId tableId, File file, File crcFile, long generation)static PaxosBallotTrackerPaxosBallotTracker. load(File directory)static PaxosUncommittedTrackerPaxosUncommittedTracker. load(File dataDirectory)static voidPaxosBallotTracker. truncate(File directory)static voidPaxosUncommittedTracker. truncate(File dataDirectory)Constructors in org.apache.cassandra.service.paxos.uncommitted with parameters of type File Constructor Description PaxosUncommittedTracker(File dataDirectory)PaxosUncommittedTracker(File dataDirectory, com.google.common.collect.ImmutableMap<TableId,UncommittedTableData> tableStates) -
Uses of File in org.apache.cassandra.service.snapshot
Methods in org.apache.cassandra.service.snapshot that return types with arguments of type File Modifier and Type Method Description java.util.Collection<File>TableSnapshot. getDirectories()java.util.Optional<File>TableSnapshot. getManifestFile()java.util.Optional<File>TableSnapshot. getSchemaFile()Methods in org.apache.cassandra.service.snapshot with parameters of type File Modifier and Type Method Description static SnapshotManifestSnapshotManifest. deserializeFromJsonFile(File file)voidSnapshotManifest. serializeToJsonFile(File outputFile)Constructor parameters in org.apache.cassandra.service.snapshot with type arguments of type File Constructor Description TableSnapshot(java.lang.String keyspaceName, java.lang.String tableName, java.util.UUID tableId, java.lang.String tag, java.time.Instant createdAt, java.time.Instant expiresAt, java.util.Set<File> snapshotDirs) -
Uses of File in org.apache.cassandra.tools
Fields in org.apache.cassandra.tools declared as File Modifier and Type Field Description FileLoaderOptions. directory -
Uses of File in org.apache.cassandra.triggers
Methods in org.apache.cassandra.triggers with parameters of type File Modifier and Type Method Description voidCustomClassLoader. addClassPath(File dir)Constructors in org.apache.cassandra.triggers with parameters of type File Constructor Description CustomClassLoader(java.lang.ClassLoader parent, File classPathDir) -
Uses of File in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils that return File Modifier and Type Method Description static FileFBUtilities. cassandraTriggerDir()static FileFBUtilities. getToolsOutputDirectory()Methods in org.apache.cassandra.utils with parameters of type File Modifier and Type Method Description static <T> TFBUtilities. deserializeFromJsonFile(java.lang.Class<T> tClass, File file)static voidThrowables. perform(File against, Throwables.FileOpType opType, Throwables.DiscreteAction<? extends java.io.IOException>... actions)static voidFBUtilities. serializeToJsonFile(java.lang.Object object, File outputFile)static voidSyncUtil. trySyncDir(File dir) -
Uses of File in org.apache.cassandra.utils.binlog
Methods in org.apache.cassandra.utils.binlog with parameters of type File Modifier and Type Method Description static java.lang.ThrowableBinLog. cleanDirectory(File directory, java.lang.Throwable accumulate)
-