org.apache.flink.connectors.hive.read

Class HiveContinuousPartitionFetcher<T extends Comparable<T>>

java.lang.Object

org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher<T>

All Implemented Interfaces:

Serializable, org.apache.flink.table.filesystem.ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T>, org.apache.flink.table.filesystem.PartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition>

@Internal
public class HiveContinuousPartitionFetcher<T extends Comparable<T>>
extends Object
implements org.apache.flink.table.filesystem.ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T>

A ContinuousPartitionFetcher for hive table.

See Also:

Serialized Form

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
HiveContinuousPartitionFetcher()

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.hive.metastore.api.Partition>	fetch(org.apache.flink.table.filesystem.PartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition> context)
List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,T>>	fetchPartitions(org.apache.flink.table.filesystem.ContinuousPartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition,T> context, T previousOffset)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveContinuousPartitionFetcher

public HiveContinuousPartitionFetcher()

Method Detail

fetchPartitions

public List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,T>> fetchPartitions(org.apache.flink.table.filesystem.ContinuousPartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition,T> context,
                                                                                                                      T previousOffset)
                                                                                                               throws Exception

Specified by:

fetchPartitions in interface org.apache.flink.table.filesystem.ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T extends Comparable<T>>

Throws:

Exception

fetch

public List<org.apache.hadoop.hive.metastore.api.Partition> fetch(org.apache.flink.table.filesystem.PartitionFetcher.Context<org.apache.hadoop.hive.metastore.api.Partition> context)
                                                           throws Exception

Specified by:

fetch in interface org.apache.flink.table.filesystem.PartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition>

Throws:

Exception