strangedb/src/main/java/org/warp/jcwdb/DBLightListParser.java

46 lines
1.2 KiB
Java

package org.warp.jcwdb;
import java.util.ArrayList;
import it.unimi.dsi.fastutil.longs.LongArrayList;
public class DBLightListParser extends DBTypeParserImpl<LightList> {
private final JCWDatabase db;
public DBLightListParser(JCWDatabase db) {
this.db = db;
}
public DBReader<LightList> getReader() {
return (i, size) -> {
LongArrayList internalList = new LongArrayList();
LongArrayList hashes = new LongArrayList();
long max = size / (Long.BYTES * 2);
for (int item = 0; item < max; item++){
long itm = i.readLong();
long hash = i.readLong();
internalList.add(itm);
hashes.add(hash);
}
return new LightList(db, internalList, hashes);
};
}
public DBDataOutput<LightList> getWriter(final LightList value) {
final int elementsCount = value.size();
return DBDataOutput.create((o) -> {
LongArrayList list = value.internalList;
LongArrayList hashes = value.hashes;
for (int i = 0; i < elementsCount; i++) {
o.writeLong(list.getLong(i));
o.writeLong(hashes.getLong(i));
}
}, DBStandardTypes.LIGHT_LIST, elementsCount * Long.BYTES * 2, calculateHash(value));
}
@Override
public long calculateHash(LightList value) {
return value.hashCodeLong();
}
}