Skip to content

[WAYANG-55] Refactor TableSource to support column projection.#721

Open
tanyarai5446 wants to merge 2 commits intoapache:mainfrom
tanyarai5446:fix/tablesource-column-projection
Open

[WAYANG-55] Refactor TableSource to support column projection.#721
tanyarai5446 wants to merge 2 commits intoapache:mainfrom
tanyarai5446:fix/tablesource-column-projection

Conversation

@tanyarai5446
Copy link

Currently, JdbcTableSource and other SQL-based operators cannot perform column projection because the parent TableSource class does not persist the columnNames array passed in the constructor.

Changes:

  • Refactored TableSource to store columnNames as a protected field.
  • Added getColumnNames() getter to TableSource.

Updated JdbcTableSource to utilize these names in createSqlClause for more efficient SQL generation (moving from SELECT * to SELECT col1, col2...).

Testing:

  • Verified with mvn clean install -am -pl :wayang-jdbc-template (Build Success).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant