Hierarchy For Package org.apache.flink.connector.file.table

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.connector.file.table.BinPacking
  • 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.connector.file.table.FileSystemTableSink.TableRollingPolicy
  • org.apache.flink.connector.file.table.DefaultPartTimeExtractor (implements org.apache.flink.connector.file.table.PartitionTimeExtractor)
  • org.apache.flink.connector.file.table.DeserializationSchemaAdapter (implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>)
  • org.apache.flink.connector.file.table.DynamicPartitionWriter<T> (implements org.apache.flink.connector.file.table.PartitionWriter<T>)
  • org.apache.flink.connector.file.table.EmptyMetaStoreFactory (implements org.apache.flink.connector.file.table.TableMetaStoreFactory)
  • org.apache.flink.connector.file.table.EnrichedRowData (implements org.apache.flink.table.data.RowData)
  • org.apache.flink.connector.file.table.FileSystemCommitter
  • org.apache.flink.connector.file.table.FileSystemConnectorOptions
  • org.apache.flink.connector.file.table.FileSystemOutputFormat<T> (implements org.apache.flink.api.common.io.FinalizeOnMaster, org.apache.flink.api.common.io.OutputFormat<IT>, java.io.Serializable, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts)
  • org.apache.flink.connector.file.table.FileSystemOutputFormat.Builder<T>
  • org.apache.flink.connector.file.table.FileSystemTableFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
  • org.apache.flink.connector.file.table.FileSystemTableSink (implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning)
  • org.apache.flink.connector.file.table.FileSystemTableSink.ProjectionBulkFactory (implements org.apache.flink.api.common.serialization.BulkWriter.Factory<T>)
  • org.apache.flink.connector.file.table.FileSystemTableSink.TableBucketAssigner (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID>)
  • org.apache.flink.connector.file.table.FileSystemTableSource (implements org.apache.flink.table.connector.source.ScanTableSource, org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown, org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown, org.apache.flink.table.connector.source.abilities.SupportsPartitionPushDown, org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown, org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata, org.apache.flink.table.connector.source.abilities.SupportsStatisticReport)
  • org.apache.flink.connector.file.table.GroupedPartitionWriter<T> (implements org.apache.flink.connector.file.table.PartitionWriter<T>)
  • org.apache.flink.connector.file.table.LimitableBulkFormat<T,SplitT> (implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>)
  • org.apache.flink.connector.file.table.MetastoreCommitPolicy (implements org.apache.flink.connector.file.table.PartitionCommitPolicy)
  • org.apache.flink.connector.file.table.PartitionCommitPolicyFactory (implements java.io.Serializable)
  • org.apache.flink.connector.file.table.PartitionLoader (implements java.io.Closeable)
  • org.apache.flink.connector.file.table.PartitionTempFileManager
  • org.apache.flink.connector.file.table.PartitionWriter.Context<T>
  • org.apache.flink.connector.file.table.PartitionWriter.DefaultPartitionWriterListener (implements org.apache.flink.connector.file.table.PartitionWriter.PartitionWriterListener)
  • org.apache.flink.connector.file.src.util.RecyclableIterator<E> (implements org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<T>)
    • org.apache.flink.connector.file.table.ColumnarRowIterator
  • org.apache.flink.connector.file.table.RowDataPartitionComputer (implements org.apache.flink.connector.file.table.PartitionComputer<T>)
  • org.apache.flink.connector.file.table.RowPartitionComputer (implements org.apache.flink.connector.file.table.PartitionComputer<T>)
  • org.apache.flink.connector.file.table.SerializationSchemaAdapter (implements org.apache.flink.api.common.serialization.Encoder<IN>)
  • org.apache.flink.connector.file.table.SingleDirectoryWriter<T> (implements org.apache.flink.connector.file.table.PartitionWriter<T>)
  • org.apache.flink.connector.file.table.SuccessFileCommitPolicy (implements org.apache.flink.connector.file.table.PartitionCommitPolicy)

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.connector.file.table.PartitionReader<P,OUT> (also extends java.io.Serializable)
    • org.apache.flink.connector.file.table.TableMetaStoreFactory.TableMetaStore
• org.apache.flink.connector.file.table.PartitionCommitPolicy
• org.apache.flink.connector.file.table.PartitionCommitPolicy.Context
• org.apache.flink.connector.file.table.PartitionWriter<T>
• org.apache.flink.connector.file.table.PartitionWriter.PartitionWriterListener
• java.io.Serializable
  • org.apache.flink.connector.file.table.FileSystemFactory
  • org.apache.flink.connector.file.table.OutputFormatFactory<T>
  • org.apache.flink.connector.file.table.PartitionComputer<T>
  • org.apache.flink.connector.file.table.PartitionFetcher<P>
    • org.apache.flink.connector.file.table.ContinuousPartitionFetcher<P,T>
  • org.apache.flink.connector.file.table.PartitionFetcher.Context<P>
    • org.apache.flink.connector.file.table.ContinuousPartitionFetcher.Context<P,T>
  • org.apache.flink.connector.file.table.PartitionFetcher.Context.ComparablePartitionValue<P,T>
  • org.apache.flink.connector.file.table.PartitionFieldExtractor<T>
  • org.apache.flink.connector.file.table.PartitionReader<P,OUT> (also extends java.io.Closeable)
  • org.apache.flink.connector.file.table.PartitionTimeExtractor
  • org.apache.flink.connector.file.table.PartitionWriterFactory<T>
  • org.apache.flink.connector.file.table.TableMetaStoreFactory

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.connector.file.table.FileSystemConnectorOptions.FileStatisticsType (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.connector.file.table.FileSystemConnectorOptions.PartitionCommitTriggerType (implements org.apache.flink.configuration.DescribedEnum)