RE: [FLINK-3848] Add ProjectableTableSource

2016-11-11 Thread Anton Solovev
can create a new code generation or let nulls come from CsvInputFormt Any ideas? -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Wednesday, November 2, 2016 5:11 PM To: dev@flink.apache.org Subject: Re: [FLINK-3848] Add ProjectableTableSource Hi Anton, a

Re: [FLINK-3848] Add ProjectableTableSource

2016-11-02 Thread Fabian Hueske
Hi Anton, a regular TableSource does not accept a predicate and return the whole table. A ProjectableTableSource is able to evaluate a predicate while scanning. TableSources that evaluate predicates while (or rather before) scanning can significantly reduce IO compared to a full scan. Sources tha

[FLINK-3848] Add ProjectableTableSource

2016-11-02 Thread Anton Solovev
Hi folks, Can you explain me what ProjectableTableSource is ? What is it being invented for? Best, Anton

[jira] [Created] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-04-28 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3848: Summary: Add ProjectableTableSource interface and translation rule Key: FLINK-3848 URL: https://issues.apache.org/jira/browse/FLINK-3848 Project: Flink Issue