org.apache.flink.connectors.hive

Class HiveSourceDynamicFileEnumerator.Provider

java.lang.Object

org.apache.flink.connectors.hive.HiveSourceDynamicFileEnumerator.Provider

All Implemented Interfaces:

Serializable, DynamicFileEnumerator.Provider, FileEnumerator.Provider

Enclosing class:

HiveSourceDynamicFileEnumerator

public static class HiveSourceDynamicFileEnumerator.Provider
extends Object
implements DynamicFileEnumerator.Provider

A factory to create HiveSourceDynamicFileEnumerator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Provider(String table, List<String> dynamicFilterPartitionKeys, List<byte[]> partitionBytes, String hiveVersion, JobConfWrapper jobConfWrapper)

Method Summary

Modifier and Type	Method and Description
DynamicFileEnumerator	create()

Methods inherited from class java.lang.Object

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

Constructor Detail

Provider

public Provider(String table,
                List<String> dynamicFilterPartitionKeys,
                List<byte[]> partitionBytes,
                String hiveVersion,
                JobConfWrapper jobConfWrapper)

Method Detail

create

public DynamicFileEnumerator create()

Specified by:

create in interface DynamicFileEnumerator.Provider

Specified by:

create in interface FileEnumerator.Provider