Page History

import java.io.IOException;
import java.util.Map;
import schema_id.bohmap.BOHMap;
import schema_id.bohmap.OHMap;

public class Main {
  static Map<DeviceID, Map<String, SchemaEntry>> map;

  private static final int deviceNum = 100_000;
  private static final int sensorName = 100;
  private static final int sensorLen = 10;

  public static void main(String[] args) throws InterruptedException, IOException {
    putMap();

    getMap();

	// for checking memory
    Thread.sleep(100000000);
  }

  private static void putMap() {
    long curTime = System.nanoTime();

    for (int i = 0; i < deviceNum; i++) {
      //Map<String, SchemaEntry> cur = new HashMap<>(128, 1f);
      Map<String, SchemaEntry> cur = new OHMap<String, SchemaEntry>(new BOHMap(10), Serializer::stringSer, Serializer::stringDes, Serializer::schemaSer, Serializer::schemaDes);
      map.put(new DeviceID(i), cur);
      for (int j = 0; j < sensorName; j++) {
        cur.put(buildString(i, j), new SchemaEntry(1,1,1,1));
      }
    }

    System.out.println(map.size());
    int count = 0;
    for(Map<String, SchemaEntry> inner : map.values()){
      count += inner.size();
    }
    System.out.println(count);

    long finishTime = System.nanoTime();

    System.out.println("write finished time: " + (finishTime - curTime) / 1000 / 1000 + " ms.");
  }

  private static void getMap() {
    long curTime = System.nanoTime();

    long count = 0;
    for (int i = 0; i < deviceNum; i++) {
      Map<String, SchemaEntry> cur = map.get(new DeviceID(i));
      for (int j = 0; j < sensorName; j++) {
        SchemaEntry schemaEntry = cur.get(buildString(i, j));
        count += schemaEntry.lastTime;
      }
    }

    long finishTime = System.nanoTime();

    System.out.println(count);
    System.out.println("read finished time: " + (finishTime - curTime) / 1000 / 1000 + " ms.");
  }

  
  private static String buildString(int d, int s){
    StringBuilder sb = new StringBuilder();
    sb.append(d);
    sb.append("_");
    sb.append(s);

    while (sb.length() < sensorLen){
      sb.append('c');
    }

    return sb.toString();
  }
}