org.apache.flink.contrib.streaming.state.sstmerge

Class RocksDBManualCompactionConfig

java.lang.Object

org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionConfig

All Implemented Interfaces:

Serializable

public class RocksDBManualCompactionConfig
extends Object
implements Serializable

Configuration for RocksDBManualCompactionManager.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RocksDBManualCompactionConfig.Builder Builder for RocksDBManualCompactionConfig.

Field Summary

Fields

Modifier and Type	Field and Description
int	maxAutoCompactions
MemorySize	maxFileSizeToCompact
int	maxFilesToCompact
int	maxManualCompactions
MemorySize	maxOutputFileSize
int	minFilesToCompact
long	minInterval

Constructor Summary

Constructors

Constructor and Description
RocksDBManualCompactionConfig(long periodMs, int maxManualCompactions, MemorySize maxFileSizeToCompact, int minFilesToCompact, int maxFilesToCompact, MemorySize maxOutputFileSize, int maxAutoCompactions)

Method Summary

Modifier and Type	Method and Description
static RocksDBManualCompactionConfig.Builder	builder()
static RocksDBManualCompactionConfig	from(ReadableConfig config)
static RocksDBManualCompactionConfig	getDefault()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

minInterval

public final long minInterval

maxManualCompactions

public final int maxManualCompactions

maxFileSizeToCompact

public final MemorySize maxFileSizeToCompact

minFilesToCompact

public final int minFilesToCompact

maxFilesToCompact

public final int maxFilesToCompact

maxOutputFileSize

public final MemorySize maxOutputFileSize

maxAutoCompactions

public final int maxAutoCompactions

Constructor Detail

RocksDBManualCompactionConfig

public RocksDBManualCompactionConfig(long periodMs,
                                     int maxManualCompactions,
                                     MemorySize maxFileSizeToCompact,
                                     int minFilesToCompact,
                                     int maxFilesToCompact,
                                     MemorySize maxOutputFileSize,
                                     int maxAutoCompactions)

Method Detail

builder

public static RocksDBManualCompactionConfig.Builder builder()

from

public static RocksDBManualCompactionConfig from(ReadableConfig config)

getDefault

public static RocksDBManualCompactionConfig getDefault()

toString

public String toString()

Overrides:

toString in class Object