[INLONG-10761][Agent] Delete reader related code

justinwwhuang · Aug 7, 2024 · 954303b · 954303b
1 parent af74355
commit 954303b
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...gent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java b/...gent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java
@@ -19,10 +19,12 @@
 
 import org.apache.inlong.agent.conf.JobProfile;
 import org.apache.inlong.agent.plugin.Reader;
+import org.apache.inlong.agent.plugin.sources.reader.BinlogReader;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -37,7 +39,13 @@ public BinlogSource() {
 
     @Override
     public List<Reader> split(JobProfile conf) {
-        return null;
+        super.init(conf);
+        BinlogReader binlogReader = new BinlogReader();
+        binlogReader.setReadSource(conf.getInstanceId());
+        List<Reader> readerList = new ArrayList<>();
+        readerList.add(binlogReader);
+        sourceMetric.sourceSuccessCount.incrementAndGet();
+        return readerList;
     }
 
 }