Hierarchy For Package org.apache.flink.table.filesystem

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<IN,BucketID> (implements org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID>)
    • org.apache.flink.table.filesystem.FileSystemTableSink.TableRollingPolicy
  • org.apache.flink.table.filesystem.DefaultPartTimeExtractor (implements org.apache.flink.table.filesystem.PartitionTimeExtractor)
  • org.apache.flink.table.filesystem.DynamicPartitionWriter<T> (implements org.apache.flink.table.filesystem.PartitionWriter<T>)
  • org.apache.flink.table.filesystem.EmptyMetaStoreFactory (implements org.apache.flink.table.filesystem.TableMetaStoreFactory)
  • org.apache.flink.table.filesystem.FileSystemOptions
  • org.apache.flink.table.filesystem.FileSystemOutputFormat<T> (implements org.apache.flink.api.common.io.FinalizeOnMaster, org.apache.flink.api.common.io.OutputFormat<IT>, java.io.Serializable)
  • org.apache.flink.table.filesystem.FileSystemOutputFormat.Builder<T>
  • org.apache.flink.table.filesystem.FileSystemTableFactory (implements org.apache.flink.table.factories.TableSinkFactory<T>, org.apache.flink.table.factories.TableSourceFactory<T>)
  • org.apache.flink.table.filesystem.FileSystemTableSink (implements org.apache.flink.table.sinks.AppendStreamTableSink<T>, org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink)
  • org.apache.flink.table.filesystem.FileSystemTableSink.ProjectionBulkFactory (implements org.apache.flink.api.common.serialization.BulkWriter.Factory<T>)
  • org.apache.flink.table.filesystem.FileSystemTableSink.TableBucketAssigner (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID>)
  • org.apache.flink.table.filesystem.FileSystemTableSource (implements org.apache.flink.table.sources.FilterableTableSource<T>, 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.table.filesystem.GroupedPartitionWriter<T> (implements org.apache.flink.table.filesystem.PartitionWriter<T>)
  • org.apache.flink.table.filesystem.MetastoreCommitPolicy (implements org.apache.flink.table.filesystem.PartitionCommitPolicy)
  • org.apache.flink.table.filesystem.PartitionLoader (implements java.io.Closeable)
  • org.apache.flink.table.filesystem.PartitionTempFileManager
  • org.apache.flink.table.filesystem.PartitionWriter.Context<T>
  • org.apache.flink.table.filesystem.RowDataPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
  • org.apache.flink.table.filesystem.RowPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
  • org.apache.flink.table.filesystem.SingleDirectoryWriter<T> (implements org.apache.flink.table.filesystem.PartitionWriter<T>)
  • org.apache.flink.table.filesystem.SuccessFileCommitPolicy (implements org.apache.flink.table.filesystem.PartitionCommitPolicy)
  • org.apache.flink.table.functions.UserDefinedFunction (implements org.apache.flink.table.functions.FunctionDefinition, java.io.Serializable)
    • org.apache.flink.table.functions.TableFunction<T>
      • org.apache.flink.table.filesystem.FileSystemLookupFunction<T>

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.table.filesystem.TableMetaStoreFactory.TableMetaStore
• org.apache.flink.table.filesystem.PartitionCommitPolicy
• org.apache.flink.table.filesystem.PartitionCommitPolicy.Context
• org.apache.flink.table.filesystem.PartitionWriter<T>
• java.io.Serializable
  • org.apache.flink.table.filesystem.FileSystemFactory
  • org.apache.flink.table.filesystem.OutputFormatFactory<T>
  • org.apache.flink.table.filesystem.PartitionComputer<T>
  • org.apache.flink.table.filesystem.PartitionTimeExtractor
  • org.apache.flink.table.filesystem.PartitionWriterFactory<T>
  • org.apache.flink.table.filesystem.TableMetaStoreFactory