org.finra.datagenerator.distributor.spark

Class CatchAndStoreProcessing

java.lang.Object

org.finra.datagenerator.distributor.spark.CatchAndStoreProcessing

All Implemented Interfaces:

Serializable, ProcessingStrategy

public class CatchAndStoreProcessing
extends Object
implements ProcessingStrategy, Serializable

Simple wrapper for storing Frontier results into a List

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CatchAndStoreProcessing(List<Map<String,String>> storage) Simple wrapper for storing Frontier results into a List

Method Summary

Methods

Modifier and Type	Method and Description
void	processOutput(Map<String,String> resultsMap) Adds the passes results map to the given List.

Methods inherited from class java.lang.Object

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

Constructor Detail

CatchAndStoreProcessing

public CatchAndStoreProcessing(List<Map<String,String>> storage)

Simple wrapper for storing Frontier results into a List

Parameters:

storage - the List to store into

Method Detail

processOutput

public void processOutput(Map<String,String> resultsMap)

Adds the passes results map to the given List. Poll the List to access the results.

Specified by:

processOutput in interface ProcessingStrategy

Parameters:

resultsMap - map of String and String to add to the list