com.cinchapi.concourse.etl

Class Strainer

Object

Strainer

public class Strainer
extends Object

A Strainer is used to process a generic data set (e.g. a Map from String to Object) using an action.

Strainers work in accordance with Concourse's data model, which is a non-nestable, implicit multimap. Therefore, a Strainer flattens top level sequence values and process their items individually.

Constructor Summary

Constructors

Constructor and Description
Strainer(BiConsumer<String,Object> action) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
void	process(Map<String,Object> data) Process each key/value pair in data.
void	process(String key, Object value) Process the key/value pair.

Methods inherited from class Object

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

Constructor Detail

Strainer

public Strainer(BiConsumer<String,Object> action)

Construct a new instance.

Parameters:

action -

Method Detail

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

process

public final void process(Map<String,Object> data)

Process each key/value pair in data.

If a value is a sequence, it is "flattened" and the assessment is applied to each of its members. This is done because Concourse's data model is an non-nestable implicit multimap.

Parameters:

key -

value -

process

public final void process(String key,
                          Object value)

Process the key/value pair.

If a value is a sequence, it is "flattened" and the assessment is applied to each of its members. This is done because Concourse's data model is an non-nestable implicit multimap.

Parameters:

key -

value -