org.apache.flink.connectors.hive

Class HiveTableFactory

java.lang.Object

org.apache.flink.connectors.hive.HiveTableFactory

All Implemented Interfaces:

org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSinkFactory, org.apache.flink.table.factories.TableSourceFactory

public class HiveTableFactory
extends Object
implements org.apache.flink.table.factories.TableSourceFactory, org.apache.flink.table.factories.TableSinkFactory

A table factory implementation for Hive catalog.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSourceFactory

org.apache.flink.table.factories.TableSourceFactory.Context

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

org.apache.flink.table.factories.TableSinkFactory.Context

Constructor Summary

Constructors

Constructor and Description
HiveTableFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink	createTableSink(org.apache.flink.table.factories.TableSinkFactory.Context context)
org.apache.flink.table.sources.TableSource	createTableSource(org.apache.flink.table.factories.TableSourceFactory.Context context)
Map<String,String>	requiredContext()
List<String>	supportedProperties()

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.factories.TableSourceFactory

createTableSource, createTableSource

Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

createTableSink, createTableSink

Constructor Detail

HiveTableFactory

public HiveTableFactory()

Method Detail

requiredContext

public Map<String,String> requiredContext()

Specified by:

requiredContext in interface org.apache.flink.table.factories.TableFactory

supportedProperties

public List<String> supportedProperties()

Specified by:

supportedProperties in interface org.apache.flink.table.factories.TableFactory

createTableSource

public org.apache.flink.table.sources.TableSource createTableSource(org.apache.flink.table.factories.TableSourceFactory.Context context)

Specified by:

createTableSource in interface org.apache.flink.table.factories.TableSourceFactory

createTableSink

public org.apache.flink.table.sinks.TableSink createTableSink(org.apache.flink.table.factories.TableSinkFactory.Context context)

Specified by:

createTableSink in interface org.apache.flink.table.factories.TableSinkFactory