程序包org.apache.flink.connectors.hive的分层结构

程序包分层结构:

• 所有程序包

类分层结构

• java.lang.Object
  • org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.table.filesystem.FileSystemFactory)
  • org.apache.flink.connectors.hive.HiveOptions
  • org.apache.flink.connectors.hive.HiveOutputFormatFactory (implements org.apache.flink.table.filesystem.OutputFormatFactory<T>)
  • org.apache.flink.connectors.hive.HiveTableFactory (implements org.apache.flink.table.factories.TableSinkFactory<T>, org.apache.flink.table.factories.TableSourceFactory<T>)
  • org.apache.flink.connectors.hive.HiveTableMetaStoreFactory (implements org.apache.flink.table.filesystem.TableMetaStoreFactory)
  • org.apache.flink.connectors.hive.HiveTablePartition (implements java.io.Serializable)
  • org.apache.flink.connectors.hive.HiveTableSource (implements org.apache.flink.table.sources.LimitableTableSource<T>, org.apache.flink.table.sources.PartitionableTableSource, org.apache.flink.table.sources.ProjectableTableSource<T>, org.apache.flink.table.sources.StreamTableSource<T>)
  • org.apache.flink.connectors.hive.JobConfWrapper (implements java.io.Serializable)
  • org.apache.flink.table.sinks.OutputFormatTableSink<T> (implements org.apache.flink.table.sinks.StreamTableSink<T>)
    • org.apache.flink.connectors.hive.HiveTableSink (implements org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink)
  • org.apache.flink.table.filesystem.RowPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
    • org.apache.flink.connectors.hive.HivePartitionComputer
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.flink.connectors.hive.FlinkHiveException