public class LogHybridSourceFactory extends Object implements org.apache.flink.connector.base.source.hybrid.HybridSource.SourceFactory<org.apache.flink.table.data.RowData,org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?>,StaticFileStoreSplitEnumerator>
HybridSource.SourceFactory
from StaticFileStoreSplitEnumerator
.Constructor and Description |
---|
LogHybridSourceFactory(LogSourceProvider provider) |
Modifier and Type | Method and Description |
---|---|
static FlinkSource |
buildHybridFirstSource(Table table,
int[][] projectedFields,
Predicate predicate) |
org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?> |
create(org.apache.flink.connector.base.source.hybrid.HybridSource.SourceSwitchContext<StaticFileStoreSplitEnumerator> context) |
public LogHybridSourceFactory(LogSourceProvider provider)
public org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?> create(org.apache.flink.connector.base.source.hybrid.HybridSource.SourceSwitchContext<StaticFileStoreSplitEnumerator> context)
create
in interface org.apache.flink.connector.base.source.hybrid.HybridSource.SourceFactory<org.apache.flink.table.data.RowData,org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?>,StaticFileStoreSplitEnumerator>
public static FlinkSource buildHybridFirstSource(Table table, @Nullable int[][] projectedFields, @Nullable Predicate predicate)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.