io.druid.indexer.hadoop

Class SegmentInputRow

java.lang.Object

io.druid.indexer.hadoop.SegmentInputRow

All Implemented Interfaces:

InputRow, Row, Comparable<Row>

public class SegmentInputRow
extends Object
implements InputRow

SegmentInputRow serves as a marker that these InputRow instances have already been combined and they contain the columns as they show up in the segment after ingestion, not what you would see in raw data. It must only be used to represent such InputRows.

Constructor Summary

Constructors

Constructor and Description
SegmentInputRow(InputRow delegate)

Method Summary

Modifier and Type	Method and Description
int	compareTo(Row row)
InputRow	getDelegate()
List<String>	getDimension(String dimension) Returns the list of dimension values for the given column name.
List<String>	getDimensions() Returns the dimensions that exist in this row.
float	getFloatMetric(String metric) Returns the float value of the given metric column.
long	getLongMetric(String metric) Returns the long value of the given metric column.
Object	getRaw(String dimension) Returns the raw dimension value for the given column name.
org.joda.time.DateTime	getTimestamp() Returns the timestamp from the epoch as an org.joda.time.DateTime.
long	getTimestampFromEpoch() Returns the timestamp from the epoch in milliseconds.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentInputRow

public SegmentInputRow(InputRow delegate)

Method Detail

getDimensions

public List<String> getDimensions()

Description copied from interface: InputRow

Returns the dimensions that exist in this row.

Specified by:

getDimensions in interface InputRow

Returns:

the dimensions that exist in this row.

getTimestampFromEpoch

public long getTimestampFromEpoch()

Description copied from interface: Row

Returns the timestamp from the epoch in milliseconds. If the event happened _right now_, this would return the same thing as System.currentTimeMillis();

Specified by:

getTimestampFromEpoch in interface Row

Returns:

the timestamp from the epoch in milliseconds.

getTimestamp

public org.joda.time.DateTime getTimestamp()

Description copied from interface: Row

Returns the timestamp from the epoch as an org.joda.time.DateTime. If the event happened _right now_, this would return the same thing as new DateTime();

Specified by:

getTimestamp in interface Row

Returns:

the timestamp from the epoch as an org.joda.time.DateTime object.

getDimension

public List<String> getDimension(String dimension)

Description copied from interface: Row

Returns the list of dimension values for the given column name.

Specified by:

getDimension in interface Row

Parameters:

dimension - the column name of the dimension requested

Returns:

the list of values for the provided column name

getRaw

public Object getRaw(String dimension)

Description copied from interface: Row

Returns the raw dimension value for the given column name. This is different from #getDimension which all values to strings before returning them.

Specified by:

getRaw in interface Row

Parameters:

dimension - the column name of the dimension requested

Returns:

the value of the provided column name

getFloatMetric

public float getFloatMetric(String metric)

Description copied from interface: Row

Returns the float value of the given metric column.

Specified by:

getFloatMetric in interface Row

Parameters:

metric - the column name of the metric requested

Returns:

the float value for the provided column name.

getLongMetric

public long getLongMetric(String metric)

Description copied from interface: Row

Returns the long value of the given metric column.

Specified by:

getLongMetric in interface Row

Parameters:

metric - the column name of the metric requested

Returns:

the long value for the provided column name.

compareTo

public int compareTo(Row row)

Specified by:

compareTo in interface Comparable<Row>

getDelegate

public InputRow getDelegate()

toString

public String toString()

Overrides:

toString in class Object