public class ReconcileFtpsRequest extends AsyncTaskRequest
Constructor and Description |
---|
ReconcileFtpsRequest(int uuid,
String topic,
int partition,
String ftpsFilePath,
long fromTimestamp,
FtpsStateForRestore ftpsStateForRestore,
Map<UUID,SegmentState> segmentsStateMap)
Constructs new ReconcileFtpsRequest.
|
ReconcileFtpsRequest(int uuid,
String topic,
int partition,
String ftpsFilePath,
long fromTimestamp,
Map<UUID,SegmentState> segmentsStateMap) |
Modifier and Type | Method and Description |
---|---|
long |
getFromTimestamp() |
FtpsStateForRestore |
getFtpsStateForRestore() |
Map<UUID,SegmentState> |
getSegmentsMap() |
getFtpsFilePath, toString
getCreateTimestamp, getPartition, getTopic, getTopicPartition, getUuid, name
public ReconcileFtpsRequest(int uuid, String topic, int partition, String ftpsFilePath, long fromTimestamp, FtpsStateForRestore ftpsStateForRestore, Map<UUID,SegmentState> segmentsStateMap)
uuid
- unique integer ID for this requesttopic
- topic being operated uponpartition
- partition number being operated uponftpsFilePath
- file path to FTPS filesegmentsStateMap
- map of segment numbers to current statuspublic ReconcileFtpsRequest(int uuid, String topic, int partition, String ftpsFilePath, long fromTimestamp, Map<UUID,SegmentState> segmentsStateMap)
public Map<UUID,SegmentState> getSegmentsMap()
public long getFromTimestamp()
public FtpsStateForRestore getFtpsStateForRestore()