| 程序包 | 说明 |
|---|---|
| org.apache.flink.table.factories | |
| org.apache.flink.table.sources |
| 限定符和类型 | 方法和说明 |
|---|---|
default StreamTableSource<T> |
StreamTableSourceFactory.createStreamTableSource(Map<String,String> properties)
已过时。
Context contains more information, and already contains table schema too.
Please use TableSourceFactory.createTableSource(Context) instead. |
| 限定符和类型 | 类和说明 |
|---|---|
class |
CsvTableSource
已过时。
The legacy CSV connector has been replaced by
FileSource. It is kept only to
support tests for the legacy connector stack. |
class |
InputFormatTableSource<T>
已过时。
This interface has been replaced by
DynamicTableSource. The new interface
produces internal data structures. See FLIP-95 for more information. |
| 限定符和类型 | 方法和说明 |
|---|---|
StreamTableSource<org.apache.flink.types.Row> |
CsvAppendTableSourceFactory.createStreamTableSource(Map<String,String> properties)
已过时。
|
StreamTableSource<org.apache.flink.types.Row> |
CsvBatchTableSourceFactory.createStreamTableSource(Map<String,String> properties)
已过时。
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.