Package io.milvus.v2.service.cdc.request
Class DumpMessagesReq
- java.lang.Object
-
- io.milvus.v2.service.cdc.request.DumpMessagesReq
-
public class DumpMessagesReq extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classDumpMessagesReq.DumpMessagesReqBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static DumpMessagesReq.DumpMessagesReqBuilderbuilder()LonggetEndTimetick()BooleangetIncludeStartMessage()StringgetPchannel()GetReplicateInfoResp.MessageIDgetStartMessageID()Start position in WAL.LonggetStartTimetick()StringtoString()
-
-
-
Method Detail
-
builder
public static DumpMessagesReq.DumpMessagesReqBuilder builder()
-
getPchannel
public String getPchannel()
-
getStartMessageID
public GetReplicateInfoResp.MessageID getStartMessageID()
Start position in WAL. Its walName supports: RocksMQ, Pulsar, Kafka, WoodPecker.
-
getStartTimetick
public Long getStartTimetick()
-
getEndTimetick
public Long getEndTimetick()
-
getIncludeStartMessage
public Boolean getIncludeStartMessage()
-
-