org.datavec.api.transform.reduce.geo

Class CoordinatesReduction

java.lang.Object

org.datavec.api.transform.reduce.geo.CoordinatesReduction

All Implemented Interfaces:

java.io.Serializable, ColumnOp, ColumnReduction

public class CoordinatesReduction
extends java.lang.Object
implements ColumnReduction

Applies a ReduceOp to a column of coordinates, for each component independently.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_COLUMN_NAME
static java.lang.String	DEFAULT_DELIMITER
protected java.lang.String	delimiter

Constructor Summary

Constructors

Constructor and Description
CoordinatesReduction(java.lang.String columnNamePostReduce, ReduceOp op)
CoordinatesReduction(java.lang.String columnNamePostReduce, ReduceOp op, java.lang.String delimiter)

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
ColumnMetaData	getColumnOutputMetaData(java.lang.String newColumnName, ColumnMetaData columnInputMeta) Post-reduce: what is the metadata (type, etc) for this column? For example: a "count unique" operation on a String (StringMetaData) column would return an Integer (IntegerMetaData) column
java.lang.String	getColumnOutputName(java.lang.String columnInputName) Post-reduce: what is the name of the column? For example, "myColumn" -> "mean(myColumn)"
Schema	getInputSchema() Getter for input schema
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
Writable	reduceColumn(java.util.List<Writable> columnData) Reduce a single column.
void	setInputSchema(Schema inputSchema) Set the input schema.
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, toString, wait, wait, wait

Field Detail

DEFAULT_COLUMN_NAME

public static final java.lang.String DEFAULT_COLUMN_NAME

See Also:

Constant Field Values

DEFAULT_DELIMITER

public static final java.lang.String DEFAULT_DELIMITER

See Also:

Constant Field Values

delimiter

protected java.lang.String delimiter

Constructor Detail

CoordinatesReduction

public CoordinatesReduction(java.lang.String columnNamePostReduce,
                            ReduceOp op)

CoordinatesReduction

public CoordinatesReduction(java.lang.String columnNamePostReduce,
                            ReduceOp op,
                            java.lang.String delimiter)

Method Detail

reduceColumn

public Writable reduceColumn(java.util.List<Writable> columnData)

Description copied from interface: ColumnReduction

Reduce a single column. Note: The List<Writable> here is a single column in a reduction window, and NOT the single row (as is usually the case for List<Writable> instances

Specified by:

reduceColumn in interface ColumnReduction

Parameters:

columnData - The Writable objects for a column

Returns:

Writable containing the reduced data

getColumnOutputName

public java.lang.String getColumnOutputName(java.lang.String columnInputName)

Description copied from interface: ColumnReduction

Post-reduce: what is the name of the column? For example, "myColumn" -> "mean(myColumn)"

Specified by:

getColumnOutputName in interface ColumnReduction

Parameters:

columnInputName - Name of the column before reduction

Returns:

Name of the column after the reduction

getColumnOutputMetaData

public ColumnMetaData getColumnOutputMetaData(java.lang.String newColumnName,
                                              ColumnMetaData columnInputMeta)

Description copied from interface: ColumnReduction

Post-reduce: what is the metadata (type, etc) for this column? For example: a "count unique" operation on a String (StringMetaData) column would return an Integer (IntegerMetaData) column

Specified by:

getColumnOutputMetaData in interface ColumnReduction

columnInputMeta - Metadata for the column, before reduce

Returns:

Metadata for the column, after the reduction

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:

outputColumnName

public java.lang.String outputColumnName()

Description copied from interface: ColumnOp

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()

Description copied from interface: ColumnOp

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()

Description copied from interface: ColumnOp

Returns column names this op is meant to run on

Specified by:

columnNames in interface ColumnOp

Returns:

columnName

public java.lang.String columnName()

Description copied from interface: ColumnOp

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

Specified by:

columnName in interface ColumnOp

Returns: