diff --git a/table/integration/src/main/java/com/riiablo/table/schema/MonStatsParserImpl.java b/table/integration/src/main/java/com/riiablo/table/schema/MonStatsParserImpl.java index 2f29e612..d3d57ec6 100644 --- a/table/integration/src/main/java/com/riiablo/table/schema/MonStatsParserImpl.java +++ b/table/integration/src/main/java/com/riiablo/table/schema/MonStatsParserImpl.java @@ -1,22 +1,29 @@ package com.riiablo.table.schema; import java.io.IOException; -import javax.annotation.Generated; import com.riiablo.table.Parser; import com.riiablo.table.TsvParser; -public abstract class MonStatsParserImpl implements Parser { +public class MonStatsParserImpl implements Parser { + int[] fieldIds = new int[5]; + @Override public boolean hasNext(TsvParser parser) throws IOException { return parser.cacheLine() != -1; } + @Override + public void parseFields(TsvParser parser) { + fieldIds[0] = parser.fieldId("A1MaxD1"); + fieldIds[1] = parser.fieldId("A1MaxD2"); + } + // TODO: performance improvement of sorting calls by fieldId // create Function[numFields]: (record) -> record. = parser.parse(fieldId) - @Generated(value = "") + @Override public void parseRecord(final MonStats record, final TsvParser parser) { - record.A1MaxD[0] = parser.parseInt(0); - record.A1MaxD[1] = parser.parseInt(5); + record.A1MaxD[0] = parser.parseInt(fieldIds[0]); + record.A1MaxD[1] = parser.parseInt(fieldIds[1]); } }