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, columnNumberinputSchema| 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, transformgetInputSchema, mapSequenceclone, finalize, getClass, notify, notifyAll, wait, wait, waitgetInputSchemapublic 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 BaseColumnTransformpublic Writable map(Writable columnWritable)
map in class BaseColumnTransformpublic java.lang.String toString()
toString in class BaseColumnTransformpublic java.lang.Object map(java.lang.Object input)
input - the record to transform