public class TierPartitionStateFactory extends Object
Constructor and Description |
---|
TierPartitionStateFactory(boolean tierFeatureEnabled,
boolean tierChecksumFeatureEnabled,
boolean tierCleanerFeatureEnabled,
boolean tierCleanupFeatureEnabled) |
Modifier and Type | Method and Description |
---|---|
TierPartitionState |
initState(File stateDir,
org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config,
kafka.server.LogDirFailureChannel logDirFailureChannel,
kafka.utils.Scheduler scheduler,
Boolean tierChecksumState,
org.apache.kafka.common.utils.Time time) |
TierPartitionState |
initState(File stateDir,
org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config,
kafka.server.LogDirFailureChannel logDirFailureChannel,
kafka.utils.Scheduler scheduler,
org.apache.kafka.common.utils.Time time) |
boolean |
mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config) |
public TierPartitionStateFactory(boolean tierFeatureEnabled, boolean tierChecksumFeatureEnabled, boolean tierCleanerFeatureEnabled, boolean tierCleanupFeatureEnabled)
public TierPartitionState initState(File stateDir, org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel, kafka.utils.Scheduler scheduler, org.apache.kafka.common.utils.Time time) throws IOException
IOException
public TierPartitionState initState(File stateDir, org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel, kafka.utils.Scheduler scheduler, Boolean tierChecksumState, org.apache.kafka.common.utils.Time time) throws IOException
IOException
public boolean mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config)