This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 4b1d865cd4d Rename MySQLBinlogPosition (#32540)
4b1d865cd4d is described below
commit 4b1d865cd4d32f784ee3461defc3b7e36926b763
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Aug 16 00:15:21 2024 +0800
Rename MySQLBinlogPosition (#32540)
---
.../binlog/{BinlogContext.java => MySQLBinlogContext.java} | 4 ++--
.../binlog/{BinlogPosition.java => MySQLBinlogPosition.java} | 4 ++--
.../ingest/client/netty/MySQLBinlogEventPacketDecoder.java | 6 +++---
.../pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java | 12 ++++++------
.../mysql/ingest/position/MySQLIngestPositionManager.java | 12 ++++++------
.../{BinlogContextTest.java => MySQLBinlogContextTest.java} | 6 +++---
...{BinlogPositionTest.java => MySQLBinlogPositionTest.java} | 4 ++--
.../client/netty/MySQLBinlogEventPacketDecoderTest.java | 6 +++---
.../mysql/ingest/dumper/MySQLIncrementalDumperTest.java | 4 ++--
.../ingest/position/MySQLIngestPositionManagerTest.java | 4 ++--
10 files changed, 31 insertions(+), 31 deletions(-)
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContext.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContext.java
similarity index 96%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContext.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContext.java
index cbf3b1a977a..a61242ecdfc 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContext.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContext.java
@@ -25,12 +25,12 @@ import
org.apache.shardingsphere.db.protocol.mysql.packet.binlog.row.MySQLBinlog
import java.util.Map;
/**
- * Binlog context.
+ * MySQL binlog context.
*/
@RequiredArgsConstructor
@Getter
@Setter
-public final class BinlogContext {
+public final class MySQLBinlogContext {
private final int checksumLength;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPosition.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPosition.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPosition.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPosition.java
index e70d4427dc6..c0f96d7998b 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPosition.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPosition.java
@@ -22,11 +22,11 @@ import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.core.ingest.position.IngestPosition;
/**
- * Binlog position.
+ * MySQL binlog position.
*/
@RequiredArgsConstructor
@Getter
-public final class BinlogPosition implements IngestPosition {
+public final class MySQLBinlogPosition implements IngestPosition {
private final String filename;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoder.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoder.java
index c910e559e6d..f964fe9bcb5 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoder.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoder.java
@@ -23,7 +23,7 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.core.exception.PipelineInternalException;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogContext;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogContext;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.AbstractBinlogEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.AbstractRowsEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.DeleteRowsEvent;
@@ -54,7 +54,7 @@ public final class MySQLBinlogEventPacketDecoder extends
ByteToMessageDecoder {
private static final String TX_BEGIN_SQL = "BEGIN";
- private final BinlogContext binlogContext;
+ private final MySQLBinlogContext binlogContext;
private final boolean decodeWithTX;
@@ -62,7 +62,7 @@ public final class MySQLBinlogEventPacketDecoder extends
ByteToMessageDecoder {
public MySQLBinlogEventPacketDecoder(final int checksumLength, final
Map<Long, MySQLBinlogTableMapEventPacket> tableMap, final boolean decodeWithTX)
{
this.decodeWithTX = decodeWithTX;
- binlogContext = new BinlogContext(checksumLength, tableMap);
+ binlogContext = new MySQLBinlogContext(checksumLength, tableMap);
}
@Override
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
index 41b62f392e5..72688c200f1 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
@@ -33,7 +33,7 @@ import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTabl
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData;
import org.apache.shardingsphere.data.pipeline.core.util.PipelineJdbcUtils;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogPosition;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogPosition;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.AbstractBinlogEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.AbstractRowsEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.DeleteRowsEvent;
@@ -68,7 +68,7 @@ public final class MySQLIncrementalDumper extends
AbstractPipelineLifecycleRunna
private final IncrementalDumperContext dumperContext;
- private final BinlogPosition binlogPosition;
+ private final MySQLBinlogPosition binlogPosition;
private final PipelineTableMetaDataLoader metaDataLoader;
@@ -80,7 +80,7 @@ public final class MySQLIncrementalDumper extends
AbstractPipelineLifecycleRunna
public MySQLIncrementalDumper(final IncrementalDumperContext
dumperContext, final IngestPosition binlogPosition, final PipelineChannel
channel, final PipelineTableMetaDataLoader metaDataLoader) {
this.dumperContext = dumperContext;
- this.binlogPosition = (BinlogPosition) binlogPosition;
+ this.binlogPosition = (MySQLBinlogPosition) binlogPosition;
this.channel = channel;
this.metaDataLoader = metaDataLoader;
StandardPipelineDataSourceConfiguration pipelineDataSourceConfig =
(StandardPipelineDataSourceConfiguration)
dumperContext.getCommonContext().getDataSourceConfig();
@@ -139,7 +139,7 @@ public final class MySQLIncrementalDumper extends
AbstractPipelineLifecycleRunna
}
private PlaceholderRecord createPlaceholderRecord(final
AbstractBinlogEvent event) {
- PlaceholderRecord result = new PlaceholderRecord(new
BinlogPosition(event.getFileName(), event.getPosition()));
+ PlaceholderRecord result = new PlaceholderRecord(new
MySQLBinlogPosition(event.getFileName(), event.getPosition()));
result.setCommitTime(event.getTimestamp() * 1000L);
return result;
}
@@ -205,8 +205,8 @@ public final class MySQLIncrementalDumper extends
AbstractPipelineLifecycleRunna
private DataRecord createDataRecord(final PipelineSQLOperationType type,
final AbstractRowsEvent rowsEvent, final int columnCount) {
String tableName =
dumperContext.getCommonContext().getTableNameMapper().getLogicTableName(rowsEvent.getTableName()).toString();
- IngestPosition position = new BinlogPosition(rowsEvent.getFileName(),
rowsEvent.getPosition());
- DataRecord result = new DataRecord(type, tableName, position,
columnCount);
+ IngestPosition binlogPosition = new
MySQLBinlogPosition(rowsEvent.getFileName(), rowsEvent.getPosition());
+ DataRecord result = new DataRecord(type, tableName, binlogPosition,
columnCount);
result.setActualTableName(rowsEvent.getTableName());
result.setCommitTime(rowsEvent.getTimestamp() * 1000L);
return result;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManager.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManager.java
index a4e8da55cd5..26057047d8f 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManager.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManager.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.data.pipeline.mysql.ingest.position;
import com.google.common.base.Preconditions;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogPosition;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogPosition;
import
org.apache.shardingsphere.data.pipeline.core.ingest.position.DialectIngestPositionManager;
import javax.sql.DataSource;
@@ -33,25 +33,25 @@ import java.sql.SQLException;
public final class MySQLIngestPositionManager implements
DialectIngestPositionManager {
@Override
- public BinlogPosition init(final String data) {
+ public MySQLBinlogPosition init(final String data) {
String[] array = data.split("#");
Preconditions.checkArgument(2 == array.length, "Unknown binlog
position: %s", data);
- return new BinlogPosition(array[0], Long.parseLong(array[1]));
+ return new MySQLBinlogPosition(array[0], Long.parseLong(array[1]));
}
@Override
- public BinlogPosition init(final DataSource dataSource, final String
slotNameSuffix) throws SQLException {
+ public MySQLBinlogPosition init(final DataSource dataSource, final String
slotNameSuffix) throws SQLException {
try (Connection connection = dataSource.getConnection()) {
return getBinlogPosition(connection);
}
}
- private BinlogPosition getBinlogPosition(final Connection connection)
throws SQLException {
+ private MySQLBinlogPosition getBinlogPosition(final Connection connection)
throws SQLException {
try (
PreparedStatement preparedStatement =
connection.prepareStatement("SHOW MASTER STATUS");
ResultSet resultSet = preparedStatement.executeQuery()) {
resultSet.next();
- return new BinlogPosition(resultSet.getString(1),
resultSet.getLong(2));
+ return new MySQLBinlogPosition(resultSet.getString(1),
resultSet.getLong(2));
}
}
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContextTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContextTest.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContextTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContextTest.java
index b4b6bd749ff..fbe719b05c8 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogContextTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogContextTest.java
@@ -34,7 +34,7 @@ import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
-class BinlogContextTest {
+class MySQLBinlogContextTest {
private static final String TEST_SCHEMA = "test_schema";
@@ -45,11 +45,11 @@ class BinlogContextTest {
@Mock
private MySQLBinlogTableMapEventPacket tableMapEventPacket;
- private BinlogContext binlogContext;
+ private MySQLBinlogContext binlogContext;
@BeforeEach
void setUp() {
- binlogContext = new BinlogContext(4, new HashMap<>());
+ binlogContext = new MySQLBinlogContext(4, new HashMap<>());
when(tableMapEventPacket.getSchemaName()).thenReturn(TEST_SCHEMA);
when(tableMapEventPacket.getTableName()).thenReturn(TEST_TABLE);
}
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPositionTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPositionTest.java
similarity index 88%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPositionTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPositionTest.java
index da2df4e23e7..fee6529ae9a 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/BinlogPositionTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/MySQLBinlogPositionTest.java
@@ -22,10 +22,10 @@ import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
-class BinlogPositionTest {
+class MySQLBinlogPositionTest {
@Test
void assertToString() {
- assertThat(new BinlogPosition("mysql-bin.000001", 4L).toString(),
is("mysql-bin.000001#4"));
+ assertThat(new MySQLBinlogPosition("mysql-bin.000001", 4L).toString(),
is("mysql-bin.000001#4"));
}
}
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoderTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoderTest.java
index 3aa102d5633..cef42f74b43 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoderTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLBinlogEventPacketDecoderTest.java
@@ -23,7 +23,7 @@ import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.internal.StringUtil;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogContext;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogContext;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.DeleteRowsEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.QueryEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.UpdateRowsEvent;
@@ -66,7 +66,7 @@ class MySQLBinlogEventPacketDecoderTest {
@Mock
private MySQLBinlogTableMapEventPacket tableMapEventPacket;
- private BinlogContext binlogContext;
+ private MySQLBinlogContext binlogContext;
private MySQLBinlogEventPacketDecoder binlogEventPacketDecoder;
@@ -75,7 +75,7 @@ class MySQLBinlogEventPacketDecoderTest {
@BeforeEach
void setUp() throws NoSuchFieldException, IllegalAccessException {
binlogEventPacketDecoder = new MySQLBinlogEventPacketDecoder(4, new
ConcurrentHashMap<>(), true);
- binlogContext = (BinlogContext)
Plugins.getMemberAccessor().get(MySQLBinlogEventPacketDecoder.class.getDeclaredField("binlogContext"),
binlogEventPacketDecoder);
+ binlogContext = (MySQLBinlogContext)
Plugins.getMemberAccessor().get(MySQLBinlogEventPacketDecoder.class.getDeclaredField("binlogContext"),
binlogEventPacketDecoder);
when(channelHandlerContext.channel().attr(CommonConstants.CHARSET_ATTRIBUTE_KEY).get()).thenReturn(StandardCharsets.UTF_8);
columnDefs = Lists.newArrayList(new
MySQLBinlogColumnDef(MySQLBinaryColumnType.LONGLONG), new
MySQLBinlogColumnDef(MySQLBinaryColumnType.LONG),
new MySQLBinlogColumnDef(MySQLBinaryColumnType.VARCHAR), new
MySQLBinlogColumnDef(MySQLBinaryColumnType.NEWDECIMAL));
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumperTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumperTest.java
index f1a9a88b2c9..9b58bed7735 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumperTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumperTest.java
@@ -31,7 +31,7 @@ import
org.apache.shardingsphere.data.pipeline.core.ingest.record.Record;
import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogPosition;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogPosition;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.AbstractBinlogEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.DeleteRowsEvent;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.PlaceholderEvent;
@@ -91,7 +91,7 @@ class MySQLIncrementalDumperTest {
MemoryPipelineChannel channel = new MemoryPipelineChannel(10000,
records -> {
});
- incrementalDumper = new MySQLIncrementalDumper(dumperContext, new
BinlogPosition("binlog-000001", 4L), channel, metaDataLoader);
+ incrementalDumper = new MySQLIncrementalDumper(dumperContext, new
MySQLBinlogPosition("binlog-000001", 4L), channel, metaDataLoader);
pipelineTableMetaData = new PipelineTableMetaData("t_order",
mockOrderColumnsMetaDataMap(), Collections.emptyList());
when(metaDataLoader.getTableMetaData(any(),
any())).thenReturn(pipelineTableMetaData);
}
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManagerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManagerTest.java
index 90e8f0c3e41..c680a25f7d0 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManagerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/position/MySQLIngestPositionManagerTest.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.data.pipeline.mysql.ingest.position;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.BinlogPosition;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.MySQLBinlogPosition;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -58,7 +58,7 @@ class MySQLIngestPositionManagerTest {
@Test
void assertGetCurrentPosition() throws SQLException {
MySQLIngestPositionManager positionInitializer = new
MySQLIngestPositionManager();
- BinlogPosition actual = positionInitializer.init(dataSource, "");
+ MySQLBinlogPosition actual = positionInitializer.init(dataSource, "");
assertThat(actual.getFilename(), is(LOG_FILE_NAME));
assertThat(actual.getPosition(), is(LOG_POSITION));
}
