logger.info(String.format(
"discard the first line: %s", lineString));
}
while ((lineString = br.readLine()) != null){
ILine line = lineSender.createNewLine();
int i = 0;
int begin = 0;
int length = lineString.length();
if (!colListSwitch){
for (i = 0; i < length; ++i) {
if (lineString.charAt(i) == fieldSplit) {
line.addField(replaceNullString(lineString.substring(begin, i)));
begin = i + 1;
}
}
line.addField(replaceNullString(lineString.substring(begin, i)));
}else{
int index = 0;
for (i = 0; i < length; ++i) {
if (lineString.charAt(i) == fieldSplit) {
if (colList[index] >= 0){
line.addField(replaceNullString(lineString.substring(begin, i)),
colList[index]);
}
begin = i + 1;
index++;
}
}
if (colList[index] >= 0) {
line.addField(replaceNullString(lineString.substring(begin, i)),
colList[index]);
}
// add constant columns
for (Integer k : constColMap.keySet()) {
line.addField(constColMap.get(k), k);
}
}
logger.debug(line.toString(','));
boolean flag = lineSender.send(line);
if(getMonitor()!=null) {
if (flag){
getMonitor().increaseSuccessLines();