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.DefaultPartTimeExtractor (implements org.apache.flink.table.filesystem.PartitionTimeExtractor)
- org.apache.flink.table.filesystem.DeserializationSchemaAdapter (implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>)
- 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.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
- org.apache.flink.table.filesystem.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.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.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.filesystem.GroupedPartitionWriter<T> (implements org.apache.flink.table.filesystem.PartitionWriter<T>)
- org.apache.flink.table.filesystem.LimitableBulkFormat<T,SplitT> (implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>)
- 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.connector.file.src.util.RecyclableIterator<E> (implements org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<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.SerializationSchemaAdapter (implements org.apache.flink.api.common.serialization.Encoder<IN>)
- 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)
Interface Hierarchy
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.