Skip to content

feat(qwp): transaction support#34

Merged
bluestreak01 merged 7 commits into
mainfrom
vi_fix_send
May 27, 2026
Merged

feat(qwp): transaction support#34
bluestreak01 merged 7 commits into
mainfrom
vi_fix_send

Conversation

@bluestreak01
Copy link
Copy Markdown
Member

No description provided.

bluestreak01 and others added 7 commits May 25, 2026 03:06
flushAndGetSequence() now reads the deferCommit field so that
explicit flush() calls respect the flag set by the caller.
The auto-flush path continues to derive the flag from the
transactional field.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
close() previously always sent a commit message for deferred
batches, which committed data the caller intended to abandon.
Align close() with flush() by checking the deferCommit flag
before sending the commit message.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
@mtopolnik
Copy link
Copy Markdown
Contributor

[PR Coverage check]

😞 fail : 18 / 100 (18.00%)

file detail

path covered line new line coverage
🔵 io/questdb/client/cutlass/http/client/WebSocketSendBuffer.java 0 2 00.00%
🔵 io/questdb/client/cutlass/qwp/client/NativeBufferWriter.java 0 2 00.00%
🔵 io/questdb/client/cutlass/qwp/client/SegmentedNativeBufferWriter.java 0 4 00.00%
🔵 io/questdb/client/Sender.java 2 14 14.29%
🔵 io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java 12 73 16.44%
🔵 io/questdb/client/cutlass/qwp/client/QwpWebSocketEncoder.java 3 4 75.00%
🔵 io/questdb/client/cutlass/qwp/client/QwpColumnWriter.java 1 1 100.00%

@bluestreak01 bluestreak01 merged commit 637c0e4 into main May 27, 2026
11 of 12 checks passed
@bluestreak01 bluestreak01 deleted the vi_fix_send branch May 27, 2026 02:54
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