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 SequenceSplitpublic void setInputSchema(Schema inputSchema)
setInputSchema in interface SequenceSplitpublic Schema getInputSchema()
getInputSchema in interface SequenceSplitpublic java.lang.String toString()
toString in class java.lang.Object