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.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.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.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.src.util.RecyclableIterator<E> (implements org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<T>)
- 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
Enum Hierarchy
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.