开发者社区> 问答> 正文

Flink中的RocksDB在Java程序中的本地简单应用是什么?

Flink中的RocksDB在Java程序中的本地简单应用是什么?

展开
收起
游客vwuxaq6iqaowc 2021-12-09 14:24:17 420 0
1 条回答
写回答
取消 提交回答
  • 本地简单应用 使用maven构建项目,在pom.xml中加入依赖

    org.rocksdb rocksdbjni
    1 2 3 4 简单的kv插入和查询,就是先open出一个rocksdb实例,构造方法中传入配置和路径,然后通过这个实例来进行操作

    /** * @author ctl * @date 2021/2/7 */ public class RocksTest {

    RocksDB rocksDB;
    
    String path = "/Users/ctl/rocksTest";
    
    @Test
    public void testOpen() throws RocksDBException {
        RocksDB.loadLibrary();
        Options options = new Options();
        options.setCreateIfMissing(true);
        rocksDB = RocksDB.open(options, path);
        rocksDB.put("key".getBytes(), "val".getBytes());
        byte[] bytes = rocksDB.get("key".getBytes());
        System.out.println(new String(bytes));
    }
    

    }

    2021-12-09 14:24:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
The Reactive Cloud Native Arch 立即下载
JAVA开发手册1.5.0 立即下载