public class RocksDBStateFactory extends Object implements Closeable
Constructor and Description |
---|
RocksDBStateFactory(String path,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
RocksDBSetState |
setState(String name,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer,
long lruCacheSize) |
RocksDBValueState |
valueState(String name,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer,
long lruCacheSize) |
public RocksDBStateFactory(String path, org.apache.flink.configuration.Configuration conf) throws IOException
IOException
public RocksDBValueState valueState(String name, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer, long lruCacheSize) throws IOException
IOException
public RocksDBSetState setState(String name, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer, long lruCacheSize) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.