Package org.apache.cassandra.io.sstable

Class SSTableHeaderFix

java.lang.Object

org.apache.cassandra.io.sstable.SSTableHeaderFix

public abstract class SSTableHeaderFix
extends java.lang.Object

Validates and fixes type issues in the serialization-header of sstables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SSTableHeaderFix.Builder	Builder to configure and construct an instance of SSTableHeaderFix.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	dryRun
protected java.util.function.Consumer<java.lang.String>	error
protected java.util.function.Consumer<java.lang.String>	info
protected java.util.function.Function<Descriptor,TableMetadata>	schemaCallback
protected java.util.function.Consumer<java.lang.String>	warn

Method Summary

Modifier and Type	Method	Description
static SSTableHeaderFix.Builder	builder()
void	execute()
static void	fixNonFrozenUDTIfUpgradeFrom30()
boolean	hasChanges()	Whether execute() found mismatches.
boolean	hasError()	Whether execute() encountered an error.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

info

protected final java.util.function.Consumer<java.lang.String> info

warn

protected final java.util.function.Consumer<java.lang.String> warn

error

protected final java.util.function.Consumer<java.lang.String> error

dryRun

protected final boolean dryRun

schemaCallback

protected final java.util.function.Function<Descriptor,TableMetadata> schemaCallback

Method Detail

fixNonFrozenUDTIfUpgradeFrom30

public static void fixNonFrozenUDTIfUpgradeFrom30()

builder

public static SSTableHeaderFix.Builder builder()

execute

public final void execute()

hasError

public boolean hasError()

Whether execute() encountered an error.

hasChanges

public boolean hasChanges()

Whether execute() found mismatches.