public class FileTierPartitionStateFactory extends java.lang.Object implements TierPartitionStateFactory
Constructor and Description |
---|
FileTierPartitionStateFactory() |
Modifier and Type | Method and Description |
---|---|
TierPartitionState |
initState(java.io.File stateDir,
org.apache.kafka.common.TopicPartition topicPartition,
boolean tieringEnabled) |
public TierPartitionState initState(java.io.File stateDir, org.apache.kafka.common.TopicPartition topicPartition, boolean tieringEnabled) throws java.io.IOException
initState
in interface TierPartitionStateFactory
java.io.IOException