public interface Partition extends Serializable
BasePartitionTap
sub-classes.
A partition is a directory on a filesystem, where the directory contains data related to the files underneath
the partition directory.
For example, a partition could be "2012/09/01"
, which would contain log files for that day.Modifier and Type | Method and Description |
---|---|
Fields |
getPartitionFields()
The
Fields used to populate the partition. |
int |
getPathDepth()
Returns the directory search depth of the partition.
|
String |
toPartition(TupleEntry tupleEntry)
Converts the given tupleEntry into a partition string.
|
void |
toTuple(String partition,
TupleEntry tupleEntry)
Converts the given partition String to a
TupleEntry using the given TupleEntry instance for re-use. |
int getPathDepth()
"2012/09/01"
would have a depth of 3.Fields getPartitionFields()
Fields
used to populate the partition.void toTuple(String partition, TupleEntry tupleEntry)
TupleEntry
using the given TupleEntry instance for re-use.partition
- a StringtupleEntry
- a TupleEntryString toPartition(TupleEntry tupleEntry)
tupleEntry
- a TupleEntryCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.