org.apache.flink.examples.java.misc

Class PiEstimation.Sampler

java.lang.Object

org.apache.flink.examples.java.misc.PiEstimation.Sampler

All Implemented Interfaces:

Serializable, Function, MapFunction<Long,Long>

Enclosing class:

PiEstimation

public static class PiEstimation.Sampler
extends Object
implements MapFunction<Long,Long>

Sampler randomly emits points that fall within a square of edge x * y. It calculates the distance to the center of a virtually centered circle of radius x = y = 1 If the distance is less than 1, then and only then does it returns a 1.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Sampler()

Method Summary

Modifier and Type	Method and Description
Long	map(Long value) The mapping method.

Methods inherited from class java.lang.Object

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

Constructor Detail

Sampler

public Sampler()

Method Detail

map

public Long map(Long value)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<Long,Long>

Parameters:

value - The input value.

Returns:

The transformed value