wuchunfu commented on code in PR #9608:
URL: https://github.com/apache/seatunnel/pull/9608#discussion_r2222183061
##########
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java:
##########
@@ -65,6 +66,106 @@ public class TextReadStrategy extends AbstractReadStrategy {
private int[] indexes;
private String encoding = FileBaseSourceOptions.ENCODING.defaultValue();
+ /** Custom stream divider for splitting text streams by specified
delimiters */
+ public static class StreamLineSplitter {
+ private final String delimiter;
+ private final char[] delimiterChars;
+ private final StringBuilder lineBuffer;
+ private int delimiterIndex;
+ private int skipCount;
+ private final long skipHeaderNumber;
+ private final LineProcessor lineProcessor;
+ private final boolean useReadLine; // 是否可以使用readline优化
Review Comment:
Please use English
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
