org.apache.flink.connectors.hive

Class HiveSourceFileEnumerator.Provider

java.lang.Object

org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider

All Implemented Interfaces:

Serializable, FileEnumerator.Provider

Enclosing class:

HiveSourceFileEnumerator

public static class HiveSourceFileEnumerator.Provider
extends Object
implements FileEnumerator.Provider

A factory to create HiveSourceFileEnumerator.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
FileEnumerator	create()

Methods inherited from class java.lang.Object

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

Constructor Detail

Provider

public Provider(List<byte[]> partitionBytes,
                JobConfWrapper jobConfWrapper)

Method Detail

create

public FileEnumerator create()

Specified by:

create in interface FileEnumerator.Provider