Package org.iq80.leveldb

Examples of org.iq80.leveldb.Options

79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
   public int clearThreshold() {
      return clearThreshold;
   }

   public Options dataDbOptions() {
      Options options = new Options().createIfMissing(true);

      options.compressionType(compressionType);

      if (blockSize != null) {
         options.blockSize(blockSize);
      }

      if (cacheSize != null) {
         options.cacheSize(cacheSize);
      }

      return options;
   }
View Full Code Here
95
96
97
98
99
100
101
      return options;
   }

   public Options expiredDbOptions() {
      return new Options().createIfMissing(true);
   }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
   private String getQualifiedExpiredLocation() {
      return configuration.expiredLocation() + sanitizedCacheName();
   }

   private Options dataDbOptions() {
      Options options = new Options().createIfMissing(true);

      options.compressionType(CompressionType.valueOf(configuration.compressionType().name()));

      if (configuration.blockSize() != null) {
         options.blockSize(configuration.blockSize());
      }

      if (configuration.cacheSize() != null) {
         options.cacheSize(configuration.cacheSize());
      }

      return options;
   }
View Full Code Here
127
128
129
130
131
132
133
      return options;
   }

   private Options expiredDbOptions() {
      return new Options().createIfMissing(true);
   }
View Full Code Here
143
144
145
146
147
148
149
      return dbFactory.open(dir, options);
   }

   protected void destroyDatabase(String location) throws IOException {
      File dir = new File(location);
      dbFactory.destroy(dir, new Options());
   }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    }
   
    @AfterClass
  public static void destroyDB() {
    try {
      Options options = new Options();
      factory.destroy(new File("temp"), options);
    } catch (IOException e) {
      fail("Destroying temp-db failed");
    }
  }
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
167
168
  }

  @Override
  @SuppressWarnings("unchecked")
  protected void serviceInit(Configuration conf) throws Exception {
    Options options = new Options();
    options.createIfMissing(true);
    options.cacheSize(conf.getLong(
        YarnConfiguration.TIMELINE_SERVICE_LEVELDB_READ_CACHE_SIZE,
        YarnConfiguration.DEFAULT_TIMELINE_SERVICE_LEVELDB_READ_CACHE_SIZE));
    JniDBFactory factory = new JniDBFactory();
    String path = conf.get(YarnConfiguration.TIMELINE_SERVICE_LEVELDB_PATH);
    File p = new File(path);
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
137
138
    private DB openDatabase(String aDirectoryPath) {

        try {
            DBFactory factory = new Iq80DBFactory();

            Options options = new Options();

            options.createIfMissing(true);

            DB db = factory.open(new File(aDirectoryPath), options);

            return db;
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
365
366
        try {
            this.setDatabasePath(aDirectoryPath);

            DBFactory factory = new Iq80DBFactory();

            Options options = new Options();

            options.createIfMissing(true);

            this.setDatabase(factory.open(new File(aDirectoryPath), options));

            if (!this.cacheJournalSequence()) {
                this.repair();
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
        }
        File nodeStateDir = _concatAndCreate(metadataRoot, path);
        _verifyDir(metadataRoot, true);

        Iq80DBFactory factory = Iq80DBFactory.factory;
        Options options = new Options();
        options = options
                .createIfMissing(true)
                .logger(_ldbLogger)
                // better safe than sorry, for store data?
                .verifyChecksums(true)
                .cacheSize(NODE_STATE_CACHE_SIZE)
View Full Code Here
TOP

Related Classes of org.iq80.leveldb.Options

  • co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBOrderedTableCore
  • co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBOrderedTableService
  • com.alexkasko.springjdbc.compress.SnappyCompressor
  • com.cloudhopper.datastore.leveldb.LevelDbDataStore
  • com.fasterxml.storemate.backend.leveldb.LevelDBBuilder
  • com.google.common.util.concurrent.ThreadFactoryBuilder
  • com.nabalive.server.web.DataUtil
  • com.nabalive.server.web.TokenUtil
  • com.saasovation.common.port.adapter.persistence.eventsourcing.leveldb.LevelDBJournal
  • com.saasovation.common.port.adapter.persistence.eventsourcing.leveldb.LevelDBJournalRepairTool
    • 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.