public class ResetPartitionOperator extends Object
Constructor and Description |
---|
ResetPartitionOperator(org.apache.kafka.common.TopicPartition topicPartition,
String stateFileName) |
Modifier and Type | Method and Description |
---|---|
Map<UUID,String> |
execute()
Clear tiered data info from FTPS
1.
|
FtpsSegmentView |
operatorContext() |
public Map<UUID,String> execute() throws Exception
Exception
public FtpsSegmentView operatorContext()