Package | Description |
---|---|
org.apache.flink.connector.file.table | |
org.apache.flink.connectors.hive | |
org.apache.flink.connectors.hive.read |
Modifier and Type | Interface and Description |
---|---|
static interface |
ContinuousPartitionFetcher.Context<P,T extends Comparable<T>>
Context for fetch partitions, partition information is stored in hive meta store.
|
Modifier and Type | Method and Description |
---|---|
List<P> |
PartitionFetcher.fetch(PartitionFetcher.Context<P> context)
Fetch the suitable partitions, call this method should guarantee the fetcher has opened.
|
Modifier and Type | Class and Description |
---|---|
static class |
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>>
PartitionFetcher.Context for
ContinuousPartitionFetcher . |
Modifier and Type | Method and Description |
---|---|
PartitionFetcher.Context<P> |
FileSystemLookupFunction.getFetcherContext() |
Constructor and Description |
---|
FileSystemLookupFunction(PartitionFetcher<P> partitionFetcher,
PartitionFetcher.Context<P> fetcherContext,
PartitionReader<P,RowData> partitionReader,
RowType rowType,
int[] lookupKeys,
Duration reloadInterval) |
Modifier and Type | Interface and Description |
---|---|
interface |
HiveContinuousPartitionContext<P,T extends Comparable<T>>
Context for Hive continuous partition fetcher.
|
interface |
HivePartitionContext<P>
Context for Hive partition fetcher.
|
Modifier and Type | Class and Description |
---|---|
class |
HivePartitionFetcherContextBase<P>
Base class for table partition fetcher context.
|
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.hive.metastore.api.Partition> |
HiveContinuousPartitionFetcher.fetch(PartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition> context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.