Package com.snowflake.connectors.common.table

Class InMemoryAppendOnlyKeyValueTable

java.lang.Object

com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable

All Implemented Interfaces:

com.snowflake.connectors.common.table.AppendOnlyTable

public class InMemoryAppendOnlyKeyValueTable
extends Object
implements com.snowflake.connectors.common.table.AppendOnlyTable

In memory implementation of AppendOnlyTable.

Constructor Summary

Constructors

Constructor	Description
InMemoryAppendOnlyKeyValueTable()

Method Summary

Modifier and Type	Method	Description
Variant	fetch(String key)
List<Variant>	getAllWhere(Column filter)
void	insert(String key, Variant value)
void	setGetAllWherePredicate(Predicate<Map.Entry<String,Collection<FakeKeyValue>>> getAllWherePredicate)	Sets the predicate used by the getAllWhere method.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryAppendOnlyKeyValueTable

public InMemoryAppendOnlyKeyValueTable()

Method Detail

fetch

public Variant fetch(String key)

Specified by:

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

insert

public void insert(String key,
                   Variant value)

Specified by:

insert in interface com.snowflake.connectors.common.table.AppendOnlyTable

getAllWhere

public List<Variant> getAllWhere(Column filter)

Specified by:

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

setGetAllWherePredicate

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

Sets the predicate used by the getAllWhere method.

Parameters:

getAllWherePredicate - new predicate