MapperDef

com.phasmid.majabigwaduce.core.MapperDef
final case class MapperDef[K1, V1, K2, W](f: (K1, V1) => Try[(K2, W)], forgiving: Boolean) extends Serializable

Describes how to build a mapper behavior. Unlike a Behavior, a definition holds only the mapper function and its mode, and is Serializable -- so a non-local WorkerPool can ship it to another node and build the behavior there (see doc/Clustering.md).

Value parameters

f

the mapper function.

forgiving

whether to use Mapper_Forgiving rather than Mapper.

Attributes

Graph
Supertypes
trait Product
trait Equals
trait Serializable
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def behavior: Behavior[MapperCommand[K1, V1, K2, W]]

Inherited methods

def productElementNames: Iterator[String]

An iterator over the names of all the elements of this product.

An iterator over the names of all the elements of this product.

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

An iterator over all the elements of this product.

An iterator over all the elements of this product.

Attributes

Returns

in the default implementation, an Iterator[Any]

Inherited from:
Product