@PublicEvolving public interface SourceProvider extends ScanTableSource.ScanRuntimeProvider
Source
instance as a runtime implementation for ScanTableSource
.Modifier and Type | Method and Description |
---|---|
Source<RowData,?,?> |
createSource()
Creates a
Source instance. |
static SourceProvider |
of(Source<RowData,?,?> source)
Helper method for creating a static provider.
|
isBounded
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.