Package | Description |
---|---|
org.apache.flink.table.sources |
Modifier and Type | Method and Description |
---|---|
CsvTableSource |
CsvTableSource.Builder.build()
Apply the current values and constructs a newly-created
CsvTableSource . |
CsvTableSource |
CsvTableSourceConverter.fromExternalCatalogTable(ExternalCatalogTable externalCatalogTable) |
CsvTableSource |
CsvTableSource.projectFields(int[] fields)
Returns a copy of
TableSource with ability to project fields |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.