wuchong commented on a change in pull request #9197:
[FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the
TableSource return a modified schema in blink planner
URL: https://github.com/apache/flink/pull/9197#discussion_r306147450
##########
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
##########
@@ -34,16 +34,21 @@ import org.apache.flink.table.sources.{TableSource,
TableSourceUtil}
class TableSourceTable[T](
val tableSource: TableSource[T],
val isStreamingMode: Boolean,
- val statistic: FlinkStatistic)
+ val statistic: FlinkStatistic,
+ val selectedFields: Option[Array[Int]])
Review comment:
Can be simplified to `val selectedFields: Option[Array[Int]] = None`. Then
we don't need to introduce a new constructor.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
