org.datavec.api.transform.sequence.window

Class ReduceSequenceByWindowTransform

java.lang.Object

org.datavec.api.transform.sequence.window.ReduceSequenceByWindowTransform

All Implemented Interfaces:

java.io.Serializable, ColumnOp, Transform

public class ReduceSequenceByWindowTransform
extends java.lang.Object
implements Transform

Idea: do two things. First, apply a window function to the sequence data. Second: Reduce that window of data into a single value by using a Reduce function

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReduceSequenceByWindowTransform(IReducer reducer, WindowFunction windowFunction)

Method Summary

Modifier and Type	Method and Description
java.lang.String	columnName() Returns a singular column name this op is meant to run on
java.lang.String[]	columnNames() Returns column names this op is meant to run on
Schema	getInputSchema() Getter for input schema
java.util.List<Writable>	map(java.util.List<Writable> writables) Transform a writable in to another writable
java.lang.Object	map(java.lang.Object input) Transform an object in to another object
java.util.List<java.util.List<Writable>>	mapSequence(java.util.List<java.util.List<Writable>> sequence) Transform a sequence
java.lang.Object	mapSequence(java.lang.Object sequence) Transform a sequence
java.lang.String	outputColumnName() The output column name after the operation has been applied
java.lang.String[]	outputColumnNames() The output column names This will often be the same as the input
void	setInputSchema(Schema inputSchema) Set the input schema.
java.lang.String	toString()
Schema	transform(Schema inputSchema) Get the output schema for this transformation, given an input schema

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceSequenceByWindowTransform

public ReduceSequenceByWindowTransform(IReducer reducer,
                                       WindowFunction windowFunction)

Method Detail

transform

public Schema transform(Schema inputSchema)

Description copied from interface: ColumnOp

Get the output schema for this transformation, given an input schema

Specified by:

transform in interface ColumnOp

setInputSchema

public void setInputSchema(Schema inputSchema)

Description copied from interface: ColumnOp

Set the input schema.

Specified by:

setInputSchema in interface ColumnOp

getInputSchema

public Schema getInputSchema()

Description copied from interface: ColumnOp

Getter for input schema

Specified by:

getInputSchema in interface ColumnOp

Returns:

map

public java.util.List<Writable> map(java.util.List<Writable> writables)

Description copied from interface: Transform

Transform a writable in to another writable

Specified by:

map in interface Transform

Parameters:

writables - the record to transform

Returns:

the transformed writable

mapSequence

public java.util.List<java.util.List<Writable>> mapSequence(java.util.List<java.util.List<Writable>> sequence)

Description copied from interface: Transform

Transform a sequence

Specified by:

mapSequence in interface Transform

map

public java.lang.Object map(java.lang.Object input)

Transform an object in to another object

Specified by:

map in interface Transform

Parameters:

input - the record to transform

Returns:

the transformed writable

mapSequence

public java.lang.Object mapSequence(java.lang.Object sequence)

Transform a sequence

Specified by:

mapSequence in interface Transform

Parameters:

sequence -

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

outputColumnName

public java.lang.String outputColumnName()

The output column name after the operation has been applied

Specified by:

outputColumnName in interface ColumnOp

Returns:

the output column name

outputColumnNames

public java.lang.String[] outputColumnNames()

The output column names This will often be the same as the input

Specified by:

outputColumnNames in interface ColumnOp

Returns:

the output column names

columnNames

public java.lang.String[] columnNames()

Returns column names this op is meant to run on

Specified by:

columnNames in interface ColumnOp

Returns:

columnName

public java.lang.String columnName()

Returns a singular column name this op is meant to run on

Specified by:

columnName in interface ColumnOp

Returns: