org.apache.flink.connectors.hive.read

Class HivePartitionFetcherContextBase<P>

java.lang.Object

org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase<P>

Type Parameters:

P - The type of partition.

All Implemented Interfaces:

Serializable, org.apache.flink.table.filesystem.PartitionFetcher.Context<P>

Direct Known Subclasses:

HiveTableSource.HiveContinuousPartitionFetcherContext

public abstract class HivePartitionFetcherContextBase<P>
extends Object
implements org.apache.flink.table.filesystem.PartitionFetcher.Context<P>

Base class for table partition fetcher context.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.filesystem.PartitionFetcher.Context

org.apache.flink.table.filesystem.PartitionFetcher.Context.ComparablePartitionValue<P,T extends Comparable<T>>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.configuration.Configuration	configuration
protected JobConfWrapper	confWrapper
protected ConsumeOrder	consumeOrder
protected String	defaultPartitionName
protected String[]	fieldNames
protected org.apache.flink.table.types.DataType[]	fieldTypes
protected org.apache.hadoop.fs.FileSystem	fs
protected HiveShim	hiveShim
protected org.apache.hadoop.hive.metastore.IMetaStoreClient	metaStoreClient
protected List<String>	partitionKeys
protected org.apache.hadoop.fs.Path	tableLocation
protected org.apache.flink.table.catalog.ObjectPath	tablePath
protected Properties	tableProps
protected org.apache.hadoop.hive.metastore.api.StorageDescriptor	tableSd

Constructor Summary

Constructors

Constructor and Description
HivePartitionFetcherContextBase(org.apache.flink.table.catalog.ObjectPath tablePath, HiveShim hiveShim, JobConfWrapper confWrapper, List<String> partitionKeys, org.apache.flink.table.types.DataType[] fieldTypes, String[] fieldNames, org.apache.flink.configuration.Configuration configuration, String defaultPartitionName)

Method Summary

Modifier and Type	Method and Description
void	close()
List<org.apache.flink.table.filesystem.PartitionFetcher.Context.ComparablePartitionValue>	getComparablePartitionValueList()
void	open()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.filesystem.PartitionFetcher.Context

getPartition

Field Detail

tablePath

protected final org.apache.flink.table.catalog.ObjectPath tablePath

hiveShim

protected final HiveShim hiveShim

confWrapper

protected final JobConfWrapper confWrapper

partitionKeys

protected final List<String> partitionKeys

fieldTypes

protected final org.apache.flink.table.types.DataType[] fieldTypes

fieldNames

protected final String[] fieldNames

configuration

protected final org.apache.flink.configuration.Configuration configuration

defaultPartitionName

protected final String defaultPartitionName

consumeOrder

protected final ConsumeOrder consumeOrder

metaStoreClient

protected transient org.apache.hadoop.hive.metastore.IMetaStoreClient metaStoreClient

tableSd

protected transient org.apache.hadoop.hive.metastore.api.StorageDescriptor tableSd

tableProps

protected transient Properties tableProps

tableLocation

protected transient org.apache.hadoop.fs.Path tableLocation

fs

protected transient org.apache.hadoop.fs.FileSystem fs

Constructor Detail

HivePartitionFetcherContextBase

public HivePartitionFetcherContextBase(org.apache.flink.table.catalog.ObjectPath tablePath,
                                       HiveShim hiveShim,
                                       JobConfWrapper confWrapper,
                                       List<String> partitionKeys,
                                       org.apache.flink.table.types.DataType[] fieldTypes,
                                       String[] fieldNames,
                                       org.apache.flink.configuration.Configuration configuration,
                                       String defaultPartitionName)

Method Detail

open

public void open()
          throws Exception

Specified by:

open in interface org.apache.flink.table.filesystem.PartitionFetcher.Context<P>

Throws:

Exception

getComparablePartitionValueList

public List<org.apache.flink.table.filesystem.PartitionFetcher.Context.ComparablePartitionValue> getComparablePartitionValueList()
                                                                                                                          throws Exception

Specified by:

getComparablePartitionValueList in interface org.apache.flink.table.filesystem.PartitionFetcher.Context<P>

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.table.filesystem.PartitionFetcher.Context<P>

Throws:

Exception