Package org.apache.cassandra.io.sstable
Class SSTableHeaderFix.Builder
- java.lang.Object
-
- org.apache.cassandra.io.sstable.SSTableHeaderFix.Builder
-
- Enclosing class:
- SSTableHeaderFix
public static class SSTableHeaderFix.Builder extends java.lang.Object
Builder to configure and construct an instance ofSSTableHeaderFix
. Default settings:- log via the slf4j logger of
SSTableHeaderFix
- no dry-run (i.e. validate and fix, if no serious errors are detected)
- no schema callback
withDescriptor(Descriptor)
norwithPath(Path)
are used, all "live" sstables in all data directories will be scanned.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SSTableHeaderFix
build()
SSTableHeaderFix.Builder
dryRun()
Only validate and prepare fix, but do not write updated (fixed) sstable serialization-headers.SSTableHeaderFix.Builder
error(java.util.function.Consumer<java.lang.String> error)
SSTableHeaderFix.Builder
info(java.util.function.Consumer<java.lang.String> output)
SSTableHeaderFix.Builder
logToList(java.util.List<java.lang.String> output)
SSTableHeaderFix.Builder
schemaCallback(java.util.function.Supplier<java.util.function.Function<Descriptor,TableMetadata>> schemaCallback)
Schema callback to retrieve the schema of a table.SSTableHeaderFix.Builder
warn(java.util.function.Consumer<java.lang.String> warn)
SSTableHeaderFix.Builder
withDescriptor(Descriptor descriptor)
SSTableHeaderFix.Builder
withPath(java.nio.file.Path path)
Manually provide an individual sstable or directory containing sstables.
-
-
-
Method Detail
-
dryRun
public SSTableHeaderFix.Builder dryRun()
Only validate and prepare fix, but do not write updated (fixed) sstable serialization-headers.
-
info
public SSTableHeaderFix.Builder info(java.util.function.Consumer<java.lang.String> output)
-
warn
public SSTableHeaderFix.Builder warn(java.util.function.Consumer<java.lang.String> warn)
-
error
public SSTableHeaderFix.Builder error(java.util.function.Consumer<java.lang.String> error)
-
withPath
public SSTableHeaderFix.Builder withPath(java.nio.file.Path path)
Manually provide an individual sstable or directory containing sstables. Implementation note: procesing "live" sstables in their data directories as well as sstables in snapshots and backups in the data directories works. But processing sstables that reside somewhere else (i.e. verifying sstables before import) requires the use ofwithDescriptor(Descriptor)
.
-
withDescriptor
public SSTableHeaderFix.Builder withDescriptor(Descriptor descriptor)
-
schemaCallback
public SSTableHeaderFix.Builder schemaCallback(java.util.function.Supplier<java.util.function.Function<Descriptor,TableMetadata>> schemaCallback)
Schema callback to retrieve the schema of a table. Production code always delegates to the live schema (Schema.instance
). Unit tests use this method to feed a custom schema.
-
build
public SSTableHeaderFix build()
-
logToList
public SSTableHeaderFix.Builder logToList(java.util.List<java.lang.String> output)
-
-