Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.connectors.hive.read | |
org.apache.flink.table.filesystem |
Modifier and Type | Class and Description |
---|---|
static class |
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>>
PartitionFetcher.Context for
ContinuousPartitionFetcher . |
Modifier and Type | Method and Description |
---|---|
List<Tuple2<org.apache.hadoop.hive.metastore.api.Partition,T>> |
HiveContinuousPartitionFetcher.fetchPartitions(ContinuousPartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition,T> context,
T previousOffset) |
Modifier and Type | Method and Description |
---|---|
List<Tuple2<P,T>> |
ContinuousPartitionFetcher.fetchPartitions(ContinuousPartitionFetcher.Context<P,T> context,
T previousOffset)
Fetch partitions by previous partition offset (Including).
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.