public class RestorePartitionOperatorFactory extends Object
RestorePartitionOperator
s. Can be mocked for testing.Constructor and Description |
---|
RestorePartitionOperatorFactory() |
Modifier and Type | Method and Description |
---|---|
RestorePartitionOperator |
get(org.apache.kafka.common.TopicPartition topicPartition,
String stateFileName,
long fromTimestamp)
Returns a new
RestorePartitionOperator with the given params. |
public RestorePartitionOperator get(org.apache.kafka.common.TopicPartition topicPartition, String stateFileName, long fromTimestamp) throws Exception
RestorePartitionOperator
with the given params.topicPartition
- topic and partition being restoredstateFileName
- FTPS file namefromTimestamp
- time from which to restoreException
- if construction of RestorePartitionOperator fails