Package com.snowflake.connectors.common.table

Class InMemoryDefaultKeyValueTable

java.lang.Object

com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable

All Implemented Interfaces:

com.snowflake.connectors.common.table.KeyValueTable

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

In memory implementation of KeyValueTable.

Constructor Summary

Constructors

Constructor	Description
InMemoryDefaultKeyValueTable()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears this table.
void	delete(String key)
Variant	fetch(String key)
Map<String,Variant>	fetchAll()
List<Variant>	getAllWhere(Column filter)
Map<String,FakeKeyValue>	getRepository()	Returns the map backing this table.
void	setGetAllWherePredicate(Predicate<Map.Entry<String,FakeKeyValue>> getAllWherePredicate)	Sets the predicate used by getAllWhere(Column) method.
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

InMemoryDefaultKeyValueTable

public InMemoryDefaultKeyValueTable()

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,FakeKeyValue>> getAllWherePredicate)

Sets the predicate used by getAllWhere(Column) method.

Parameters:

getAllWherePredicate - new predicate

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

getRepository

public Map<String,FakeKeyValue> getRepository()

Returns the map backing this table.

Returns:

map backing this table

clear

public void clear()

Clears this table.