org.apache.flink.streaming.api.functions.windowing.delta.extractor

Class FieldsFromTuple

java.lang.Object

org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromTuple

All Implemented Interfaces:

Serializable, Extractor<Tuple,double[]>

@Internal
public class FieldsFromTuple
extends Object
implements Extractor<Tuple,double[]>

Extracts one or more fields of the type Double from a tuple and puts them into a new double[]

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FieldsFromTuple(int... indexes) Extracts one or more fields of the the type Double from a tuple and puts them into a new double[] (in the specified order).

Method Summary

Modifier and Type	Method and Description
double[]	extract(Tuple in) Extracts/Converts the given input to an object of the output type

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldsFromTuple

public FieldsFromTuple(int... indexes)

Extracts one or more fields of the the type Double from a tuple and puts them into a new double[] (in the specified order).

Parameters:

indexes - The indexes of the fields to be extracted.

Method Detail

extract

public double[] extract(Tuple in)

Description copied from interface: Extractor

Extracts/Converts the given input to an object of the output type

Specified by:

extract in interface Extractor<Tuple,double[]>

Parameters:

in - the input data

Returns:

the extracted/converted data