Skip to content

feat: Support setting IPC options in FlightSQL call options#674

Merged
zeroshade merged 2 commits intoapache:mainfrom
peasee:peasee/260226-flightsql-ipc-opts
Feb 27, 2026
Merged

feat: Support setting IPC options in FlightSQL call options#674
zeroshade merged 2 commits intoapache:mainfrom
peasee:peasee/260226-flightsql-ipc-opts

Conversation

@peasee
Copy link
Contributor

@peasee peasee commented Feb 26, 2026

Rationale for this change

I would like to specify the IPC stream compression settings for the FlightSQL ExecuteIngest command. Currently, there is no way to apply IPC options to the writer stream from the ExecuteIngest method.

What changes are included in this PR?

  • Introduces a ExecuteIngestWithIPC which allows passing IPC options
  • Retains the existing behaviour of ExecuteIngest
  • Consolidates the shared execute ingest behaviour into a private executeIngest

Are these changes tested?

  • Tested with new unit tests to validate the record batch frames are sent with LZ4 compression when the ipc.WithLZ4() option is passed in the call options

Are there any user-facing changes?

  • Yes - introduces a new public method ExecuteIngestWithIPC

@peasee peasee marked this pull request as ready for review February 27, 2026 17:41
@peasee peasee requested a review from zeroshade as a code owner February 27, 2026 17:41
@zeroshade zeroshade merged commit 7d9f381 into apache:main Feb 27, 2026
23 checks passed
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.

2 participants