@Override
	public void clear() {
		try {
			backend.db.delete(columnFamily, writeOptions, serializeCurrentKeyWithGroupAndNamespace());
		} catch (RocksDBException e) {
			throw new FlinkRuntimeException("Error while removing entry from RocksDB", e);
		}
	}
@ Override public void clear ( ) { try { backend . db . delete ( columnFamily , writeOptions , serializeCurrentKeyWithGroupAndNamespace ( ) ) ; } catch ( RocksDBException e ) { throw new FlinkRuntimeException ( "Error while removing entry from RocksDB" , e ) ; } }
------------------------------------------------------------------------