Package 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	Description
static class	RocksDBManualCompactionConfig.Builder	Builder for RocksDBManualCompactionConfig.

Field Summary

Fields

Modifier and Type	Field	Description
int	maxAutoCompactions
org.apache.flink.configuration.MemorySize	maxFileSizeToCompact
int	maxFilesToCompact
int	maxManualCompactions
org.apache.flink.configuration.MemorySize	maxOutputFileSize
int	minFilesToCompact
long	minInterval

Constructor Summary

Constructors

Constructor	Description
RocksDBManualCompactionConfig(long periodMs, int maxManualCompactions, org.apache.flink.configuration.MemorySize maxFileSizeToCompact, int minFilesToCompact, int maxFilesToCompact, org.apache.flink.configuration.MemorySize maxOutputFileSize, int maxAutoCompactions)

Method Summary

Modifier and Type	Method	Description
static RocksDBManualCompactionConfig.Builder	builder()
static RocksDBManualCompactionConfig	from(org.apache.flink.configuration.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 org.apache.flink.configuration.MemorySize maxFileSizeToCompact

minFilesToCompact

public final int minFilesToCompact

maxFilesToCompact

public final int maxFilesToCompact

maxOutputFileSize

public final org.apache.flink.configuration.MemorySize maxOutputFileSize

maxAutoCompactions

public final int maxAutoCompactions

Constructor Detail

RocksDBManualCompactionConfig

public RocksDBManualCompactionConfig(long periodMs,
                                     int maxManualCompactions,
                                     org.apache.flink.configuration.MemorySize maxFileSizeToCompact,
                                     int minFilesToCompact,
                                     int maxFilesToCompact,
                                     org.apache.flink.configuration.MemorySize maxOutputFileSize,
                                     int maxAutoCompactions)

Method Detail

builder

public static RocksDBManualCompactionConfig.Builder builder()

from

public static RocksDBManualCompactionConfig from(org.apache.flink.configuration.ReadableConfig config)

getDefault

public static RocksDBManualCompactionConfig getDefault()

toString

public String toString()

Overrides:

toString in class Object