@Internal public class TestFileSystemTableSource extends FileSystemTableSource
ScanTableSource.ScanContext, ScanTableSource.ScanRuntimeProvider
DynamicTableSource.Context, DynamicTableSource.DataStructureConverter
SupportsFilterPushDown.Result
Constructor and Description |
---|
TestFileSystemTableSource(ObjectIdentifier tableIdentifier,
DataType physicalRowDataType,
List<String> partitionKeys,
ReadableConfig tableOptions,
DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat,
DecodingFormat<DeserializationSchema<RowData>> deserializationFormat) |
Modifier and Type | Method and Description |
---|---|
protected SourceProvider |
createSourceProvider(BulkFormat<RowData,FileSourceSplit> bulkFormat) |
applyFilters, applyLimit, applyPartitions, applyProjection, applyReadableMetadata, asSummaryString, copy, getChangelogMode, getScanRuntimeProvider, listPartitions, listReadableMetadata, paths, reportStatistics, supportsNestedProjection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applyProjection
supportsMetadataProjection
public TestFileSystemTableSource(ObjectIdentifier tableIdentifier, DataType physicalRowDataType, List<String> partitionKeys, ReadableConfig tableOptions, @Nullable DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, @Nullable DecodingFormat<DeserializationSchema<RowData>> deserializationFormat)
protected SourceProvider createSourceProvider(BulkFormat<RowData,FileSourceSplit> bulkFormat)
createSourceProvider
in class FileSystemTableSource
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.