public class SequenceSplitTimeSeparation extends java.lang.Object implements SequenceSplit
Constructor and Description |
---|
SequenceSplitTimeSeparation(java.lang.String timeColumn,
long timeQuantity,
java.util.concurrent.TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
Schema |
getInputSchema() |
void |
setInputSchema(Schema inputSchema) |
java.util.List<java.util.List<java.util.List<Writable>>> |
split(java.util.List<java.util.List<Writable>> sequence) |
java.lang.String |
toString() |
public SequenceSplitTimeSeparation(java.lang.String timeColumn, long timeQuantity, java.util.concurrent.TimeUnit timeUnit)
timeColumn
- Time column to consider when splittingtimeQuantity
- Value/amount (of the specified TimeUnit)timeUnit
- The unit of timepublic java.util.List<java.util.List<java.util.List<Writable>>> split(java.util.List<java.util.List<Writable>> sequence)
split
in interface SequenceSplit
public void setInputSchema(Schema inputSchema)
setInputSchema
in interface SequenceSplit
public Schema getInputSchema()
getInputSchema
in interface SequenceSplit
public java.lang.String toString()
toString
in class java.lang.Object