Package org.entityfs.support.log

Examples of org.entityfs.support.log.StdOutLogAdapter


  @Override
  protected SimpleDatabase<Integer, Long, KeyAndValue<Integer, Long>> createDatabase()
  {
    File f = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    DatabaseBackend<Integer, Long, KeyAndValue<Integer, Long>> b = new ConstantRecordSizeBPlusTreeBackend<Integer, Long>(new LruCacheNodeRepository<Integer, Long>(new FileBackedNodeRepository<Integer, Long>(new ReadWritableFileAdapter(f), false, 0, new NumberOfRecordsNodeSizeStrategy(2), true, IntegerNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah), 10), false, lah);
    SimpleDatabase<Integer, Long, KeyAndValue<Integer, Long>> res = new SimpleDatabase<Integer, Long, KeyAndValue<Integer, Long>>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), f);
    return res;
  }
View Full Code Here


  @Override
  protected SimpleDatabase<Character, Character, KeyAndValue<Character, Character>> createCharacterDatabase()
  {
    File f = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    DatabaseBackend<Character, Character, KeyAndValue<Character, Character>> b = new ConstantRecordSizeBPlusTreeBackend<Character, Character>(new LruCacheNodeRepository<Character, Character>(new FileBackedNodeRepository<Character, Character>(new ReadWritableFileAdapter(f), false, 0, new NumberOfRecordsNodeSizeStrategy(2), true, CharacterNullSerializer.INSTANCE, CharacterSerializer.INSTANCE, 4, 8192, null, lah), 10), false, lah);
    SimpleDatabase<Character, Character, KeyAndValue<Character, Character>> res = new SimpleDatabase<Character, Character, KeyAndValue<Character, Character>>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), f);
    return res;
  }
View Full Code Here

  @Override
  protected SimpleDatabase<Integer, Long, Long> createDatabase()
  {
    File f = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    DatabaseBackend<Integer, Long, Long> b = new ConstantRecordSizeHeapBackend<Integer, Long>(new ReadWritableFileAdapter(f), false, IntegerSerializer.INSTANCE, LongSerializer.INSTANCE, 0L, 8192, lah);
    SimpleDatabase<Integer, Long, Long> res = new SimpleDatabase<Integer, Long, Long>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), f);
    return res;
  }
View Full Code Here

  @Override
  protected SimpleDatabase<Character, Character, Long> createCharacterDatabase()
  {
    File f = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    DatabaseBackend<Character, Character, Long> b = new ConstantRecordSizeHeapBackend<Character, Character>(new ReadWritableFileAdapter(f), false, CharacterSerializer.INSTANCE, CharacterSerializer.INSTANCE, 0L, 8192, lah);
    SimpleDatabase<Character, Character, Long> res = new SimpleDatabase<Character, Character, Long>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), f);
    return res;
  }
View Full Code Here

  @Override
  protected SimpleDatabase<String, String, Long> createDatabase()
  {
    File f = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    DatabaseBackend<String, String, Long> b = new HeapBackend<String, String>(new ReadWritableFileAdapter(f), false, StringSerializer.INSTANCE, StringSerializer.INSTANCE, lah);
    SimpleDatabase<String, String, Long> res = new SimpleDatabase<String, String, Long>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), f);
    return res;
  }
View Full Code Here

  @Override
  protected SimpleDatabase<String, String, Long> createDatabase()
  {
    File f = FileSupport.createTempFile();
    File indf = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    BPlusTree<Long, Long> btr = new BPlusTree<Long, Long>(new LruCacheNodeRepository<Long, Long>(new FileBackedNodeRepository<Long, Long>(new ReadWritableFileAdapter(indf), false, 0, new NumberOfRecordsNodeSizeStrategy(3), true, LongNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah), 10), lah);
    DatabaseBackend<String, String, Long> b = new BPlusTreeIndexBackend<String, String, Long, Long>(new HeapBackend<String, String>(new ReadWritableFileAdapter(f), false, StringSerializer.INSTANCE, StringSerializer.INSTANCE, lah), false, btr, new StringToLongHasher(), lah);
    SimpleDatabase<String, String, Long> res = new SimpleDatabase<String, String, Long>(b, lah);
    m_dbFiles.put(System.identityHashCode(res), new File[] { f, indf });
    return res;
View Full Code Here

  {
    File tmpFile = FileSupport.createTempFile();
    try
    {
      ReadWritableFile f = new ReadWritableFileAdapter(tmpFile);
      LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
      FileBackedNodeRepository<Long, Long> nr = new FileBackedNodeRepository<Long, Long>(f, false, 0, new NumberOfRecordsNodeSizeStrategy(2), false, LongNullSerializer.INSTANCE, LongSerializer.INSTANCE, 8, 8192, null, lah);
      BPlusTree<Long, Long> mgr = new BPlusTree<Long, Long>(nr, lah);
      try
      {
        // 0[(5),3(6), ]
View Full Code Here

  {
    File tmpFile = FileSupport.createTempFile();
    try
    {
      ReadWritableFile f = new ReadWritableFileAdapter(tmpFile);
      LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
      FileBackedNodeRepository<Long, Integer> nr = new FileBackedNodeRepository<Long, Integer>(f, false, 0, new NumberOfRecordsNodeSizeStrategy(2), false, LongNullSerializer.INSTANCE, IntegerSerializer.INSTANCE, 8, 8192, null, lah);
      BPlusTree<Long, Integer> mgr = new BPlusTree<Long, Integer>(nr, lah);
      try
      {
        NodePositions np = new NodePositions(getNonLeafNodeSize(LongSerializer.DATA_SIZE, 8, 2), getLeafNodeSize(LongSerializer.DATA_SIZE, IntegerSerializer.DATA_SIZE, 8, 2, false), nr.getPositionOfRootNode());
View Full Code Here

  {
    File tmpFile = FileSupport.createTempFile();
    try
    {
      ReadWritableFile f = new ReadWritableFileAdapter(tmpFile);
      LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
      NodeSizeStrategy nss = new NumberOfRecordsNodeSizeStrategy(2);
      FileBackedNodeRepository<Long, Long> nr = new FileBackedNodeRepository<Long, Long>(f, false, 0, nss, false, LongNullSerializer.INSTANCE, LongSerializer.INSTANCE, 8, 8192, null, lah);
      BPlusTree<Long, Long> mgr = new BPlusTree<Long, Long>(nr, lah);
      try
      {
View Full Code Here

{
  private final Map<Database<?, ?>, EFile[]> m_dbFiles = new HashMap<Database<?, ?>, EFile[]>();

  private LoggingTransactionalDatabase<Integer, Long, Long> createDbUsingFiles(EFile f, EFile treef, EFile logf)
  {
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    lah.setLevel(Level.SEVERE);
    DatabaseBackend<Integer, Long, Long> backend = new ConstantRecordSizeHeapBackend<Integer, Long>(f, false, IntegerNullSerializer.INSTANCE, LongSerializer.INSTANCE, 0, 8192, lah);
    NodeRepository<Integer> nr = new LruCacheNodeRepository<Integer, Long>(new FileBackedNodeRepository<Integer, Long>(treef, false, 0, new NumberOfRecordsNodeSizeStrategy(3), true, IntegerNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah), 10);
    BPlusTree<Integer, Long> tree = new BPlusTree<Integer, Long>(nr, lah);
    backend = new BPlusTreeIndexBackend<Integer, Long, Integer, Long>(backend, false, tree, IntegerToIntegerHasher.INSTANCE, lah);
View Full Code Here

TOP

Related Classes of org.entityfs.support.log.StdOutLogAdapter

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.