Class BinlogOffsetBuilder
- java.lang.Object
-
- org.apache.flink.cdc.connectors.mysql.source.offset.BinlogOffsetBuilder
-
public class BinlogOffsetBuilder extends Object
Builder forBinlogOffset.
-
-
Constructor Summary
Constructors Constructor Description BinlogOffsetBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BinlogOffsetbuild()BinlogOffsetBuildersetBinlogFilePosition(String filename, long position)BinlogOffsetBuildersetGtidSet(String gtidSet)BinlogOffsetBuildersetOffsetKind(BinlogOffsetKind offsetKind)BinlogOffsetBuildersetOffsetMap(Map<String,String> offsetMap)BinlogOffsetBuildersetServerId(long serverId)BinlogOffsetBuildersetSkipEvents(long skipEvents)BinlogOffsetBuildersetSkipRows(long skipRows)BinlogOffsetBuildersetTimestampSec(long timestampSec)
-
-
-
Method Detail
-
setBinlogFilePosition
public BinlogOffsetBuilder setBinlogFilePosition(String filename, long position)
-
setSkipEvents
public BinlogOffsetBuilder setSkipEvents(long skipEvents)
-
setSkipRows
public BinlogOffsetBuilder setSkipRows(long skipRows)
-
setTimestampSec
public BinlogOffsetBuilder setTimestampSec(long timestampSec)
-
setGtidSet
public BinlogOffsetBuilder setGtidSet(String gtidSet)
-
setServerId
public BinlogOffsetBuilder setServerId(long serverId)
-
setOffsetKind
public BinlogOffsetBuilder setOffsetKind(BinlogOffsetKind offsetKind)
-
setOffsetMap
public BinlogOffsetBuilder setOffsetMap(Map<String,String> offsetMap)
-
build
public BinlogOffset build()
-
-