public class TimeMathOpTransform extends BaseColumnTransform
Note: only the following MathOps are supported: Add, Subtract, ScalarMin, ScalarMax
For ScalarMin/Max, the TimeUnit must be milliseconds - i.e., value must be in epoch millisecond format
columnName, columnNumber
inputSchema
Constructor and Description |
---|
TimeMathOpTransform(java.lang.String columnName,
MathOp mathOp,
long timeQuantity,
java.util.concurrent.TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
ColumnMetaData |
getNewColumnMetaData(java.lang.String newName,
ColumnMetaData oldColumnType) |
java.lang.Object |
map(java.lang.Object input)
Transform an object
in to another object
|
Writable |
map(Writable columnWritable) |
java.lang.String |
toString() |
columnName, columnNames, equals, hashCode, map, mapSequence, outputColumnName, outputColumnNames, setInputSchema, transform
getInputSchema, mapSequence
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getInputSchema
public TimeMathOpTransform(java.lang.String columnName, MathOp mathOp, long timeQuantity, java.util.concurrent.TimeUnit timeUnit)
public ColumnMetaData getNewColumnMetaData(java.lang.String newName, ColumnMetaData oldColumnType)
getNewColumnMetaData
in class BaseColumnTransform
public Writable map(Writable columnWritable)
map
in class BaseColumnTransform
public java.lang.String toString()
toString
in class BaseColumnTransform
public java.lang.Object map(java.lang.Object input)
input
- the record to transform