public static interface PartitionFetcher.Context<P> extends Serializable
Modifier and Type | Interface and Description |
---|---|
static interface |
PartitionFetcher.Context.ComparablePartitionValue<P,T extends Comparable<T>>
A comparable partition value that can compare order by using its comparator.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
close the resources of the Context, this method should call when the context do not need
any more.
|
List<PartitionFetcher.Context.ComparablePartitionValue> |
getComparablePartitionValueList()
Get list that contains partition with comparable object.
|
Optional<P> |
getPartition(List<String> partValues)
Get partition by file partition values.
|
void |
open()
open the resources of the Context, this method should first call before call other
methods.
|
void open() throws Exception
Exception
Optional<P> getPartition(List<String> partValues) throws Exception
Exception
List<PartitionFetcher.Context.ComparablePartitionValue> getComparablePartitionValueList() throws Exception
For 'create-time' and 'partition-time',the comparable object type is Long which represents time in milliseconds, for 'partition-name', the comparable object type is String which represents the partition names string.
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.