Highest cumulative ACK watermark, or -1n before acknowledgement.
Highest stable frame sequence published by this sender.
Adds a QuestDB DOUBLE[] value with between 1 and 32 dimensions.
Discards the row in progress, including its table selection, so the next row starts from table() again. Rows already completed stay staged.
Commits rows previously sent by transactional auto-flush. This is an ergonomic alias for flush(); pending local rows are included in the same group-closing frame.
Adds a QuestDB DATE column value in milliseconds since the epoch.
-9_223_372_036_854_775_808n is QuestDB's DATE NULL sentinel: it is
stored as NULL and cannot be stored as an ordinary value.
Publishes completed rows to the local ingress/replay boundary. This does not wait for a server ACK unless awaitServerAck or awaitDurableAck is set.
Publishes pending rows without waiting for their server ACK and returns the highest frame sequence produced by this call, or -1n when empty. Pass the result to waitForAcknowledged() when an explicit delivery barrier is needed.
Adds a QuestDB INT column value. -2_147_483_648 is QuestDB's INT NULL
sentinel: it is stored as NULL and cannot be stored as an ordinary value.
Adds a protocol LONG[] column value with between 1 and 32 dimensions.
Current QuestDB servers reject LONG-array ingestion with long arrays are not supported, only double arrays. This method remains available for
Java-client and protocol parity.
Adds a QuestDB LONG column value. -9_223_372_036_854_775_808n is
QuestDB's LONG NULL sentinel: it is stored as NULL and cannot be stored as
an ordinary value.
InternalFlushes completed rows and resets borrower-local staging without closing the physical session. Used by the pooled QWP client when a lease returns.
Independently waits until the cumulative ACK watermark covers a frame.
OptionaltimeoutMs: numberCompiles an immutable table schema into an atomic object-row writer. The returned writer remains usable after this sender is reset.
Browser-safe high-level QWP ingress API.
Applications normally obtain this class through create/connectQwpNodeSender or create/connectQwpBrowserSender, rather than constructing sessions and QwpTableBuffer instances themselves.