edu.iu.dsc.tws.tset.sinks

Class StoreIterSink<T,T1>

java.lang.Object

edu.iu.dsc.tws.api.tset.fn.BaseTFunction<T,T>

edu.iu.dsc.tws.api.tset.fn.BaseSinkFunc<java.util.Iterator<T>>

edu.iu.dsc.tws.tset.sinks.StoreIterSink<T,T1>

Type Parameters:

T - Base type of the input

T1 - type that is passed to the partition through the StoreIterSink.extractValue method

All Implemented Interfaces:

SinkFunc<java.util.Iterator<T>>, TFunction<java.util.Iterator<T>,java.util.Iterator<T>>, java.io.Serializable

Direct Known Subclasses:

BaseDiskPersistIterSink, CacheGatherSink, CacheIterSink

public abstract class StoreIterSink<T,T1>
extends BaseSinkFunc<java.util.Iterator<T>>

Base classed used by cache/persist sinks that receive an Iterator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StoreIterSink()

Method Summary

Modifier and Type	Method and Description
boolean	add(java.util.Iterator<T> value) Every time an edge produces a value, this method is called.
protected abstract T1	extractValue(T input) Extracts value from an input value of the iterator
abstract CollectionPartition<T1>	get() Returns the CollectionPartition that would accept the values.

Methods inherited from class edu.iu.dsc.tws.api.tset.fn.BaseTFunction

getInput, getTSetContext, prepare

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction

close, end, prepare

Constructor Detail

StoreIterSink

public StoreIterSink()

Method Detail

extractValue

protected abstract T1 extractValue(T input)

Extracts value from an input value of the iterator

get

public abstract CollectionPartition<T1> get()

Returns the CollectionPartition that would accept the values. This could be an in-mem collection or a disk-backed collection

Returns:

collection partition

add

public boolean add(java.util.Iterator<T> value)

Description copied from interface: SinkFunc

Every time an edge produces a value, this method is called.

Parameters:

value - the value to add

Returns:

true if success