org.pentaho.di.trans.steps.databaselookup.readallcache

Class ReadAllCache

java.lang.Object

org.pentaho.di.trans.steps.databaselookup.readallcache.ReadAllCache

All Implemented Interfaces:

DatabaseLookupData.Cache

public class ReadAllCache
extends Object
implements DatabaseLookupData.Cache

This is a read-only array-based cache to be used in DatabaseLookup when "Load All Data In Cache" checkbox is selected. Internally, it uses some optimizations to reduce memory consumption.

Author:

Andrey Khayrutdinov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReadAllCache.Builder Builder class for ReadAllCache.

Method Summary

Modifier and Type	Method and Description
Object[]	getRowFromCache(RowMetaInterface lookupMeta, Object[] lookupRow) Returns the very first data row that matches all conditions or null if none has been found.
void	storeRowInCache(DatabaseLookupMeta meta, RowMetaInterface lookupMeta, Object[] lookupRow, Object[] add) Saved add as data row and lookupRow as a key for searching it.

Methods inherited from class java.lang.Object

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

Method Detail

getRowFromCache

public Object[] getRowFromCache(RowMetaInterface lookupMeta,
                                Object[] lookupRow)
                         throws KettleException

Description copied from interface: DatabaseLookupData.Cache

Returns the very first data row that matches all conditions or null if none has been found. Note, cache should keep the order in which elements were put into it.

Specified by:

getRowFromCache in interface DatabaseLookupData.Cache

Parameters:

lookupMeta - meta object for dealing with lookupRow

lookupRow - tuple containing values for comparison

Returns:

first matching data row or null

Throws:

KettleException

storeRowInCache

public void storeRowInCache(DatabaseLookupMeta meta,
                            RowMetaInterface lookupMeta,
                            Object[] lookupRow,
                            Object[] add)

Description copied from interface: DatabaseLookupData.Cache

Saved add as data row and lookupRow as a key for searching it.

Specified by:

storeRowInCache in interface DatabaseLookupData.Cache

Parameters:

meta - step's meta

lookupMeta - lookupRow's meta

lookupRow - tuple of keys

add - tuple of data