Package com.snowflake.connectors.common.table

Class InMemoryReadOnlyKeyValueTable

java.lang.Object

com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable

All Implemented Interfaces:

com.snowflake.connectors.common.table.KeyValueTable

public class InMemoryReadOnlyKeyValueTable
extends Object
implements com.snowflake.connectors.common.table.KeyValueTable

In memory, read-only implementation of KeyValueTable.

Constructor Summary

Constructors

Constructor	Description
InMemoryReadOnlyKeyValueTable(Map<String,Variant> repository)

Method Summary

Modifier and Type	Method	Description
void	delete(String key)
Variant	fetch(String key)
Map<String,Variant>	fetchAll()
List<Variant>	getAllWhere(Column filter)
void	setGetAllWherePredicate(Predicate<Map.Entry<String,Variant>> getAllWherePredicate)
void	update(String key, Variant value)
void	updateAll(List<com.snowflake.connectors.common.table.KeyValue> keyValues)
void	updateMany(List<String> ids, String fieldName, Variant fieldValue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InMemoryReadOnlyKeyValueTable

public InMemoryReadOnlyKeyValueTable(Map<String,Variant> repository)

Method Detail

fetch

public Variant fetch(String key)

Specified by:

fetch in interface com.snowflake.connectors.common.table.KeyValueTable

fetchAll

public Map<String,Variant> fetchAll()

Specified by:

fetchAll in interface com.snowflake.connectors.common.table.KeyValueTable

update

public void update(String key,
                   Variant value)

Specified by:

update in interface com.snowflake.connectors.common.table.KeyValueTable

getAllWhere

public List<Variant> getAllWhere(Column filter)

Specified by:

getAllWhere in interface com.snowflake.connectors.common.table.KeyValueTable

setGetAllWherePredicate

public void setGetAllWherePredicate(Predicate<Map.Entry<String,Variant>> getAllWherePredicate)

updateMany

public void updateMany(List<String> ids,
                       String fieldName,
                       Variant fieldValue)

Specified by:

updateMany in interface com.snowflake.connectors.common.table.KeyValueTable

updateAll

public void updateAll(List<com.snowflake.connectors.common.table.KeyValue> keyValues)

Specified by:

updateAll in interface com.snowflake.connectors.common.table.KeyValueTable

delete

public void delete(String key)

Specified by:

delete in interface com.snowflake.connectors.common.table.KeyValueTable