Signet Forge 0.1.0
C++20 Parquet library with AI-native extensions
DEMO
Loading...
Searching...
No Matches
signet::forge::StreamingSink Member List

This is the complete list of members for signet::forge::StreamingSink, including all inherited members.

bytes_written() constsignet::forge::StreamingSinkinline
create(Options opts)signet::forge::StreamingSinkinlinestatic
files_written() constsignet::forge::StreamingSinkinline
flush()signet::forge::StreamingSinkinline
operator=(StreamingSink &&)=defaultsignet::forge::StreamingSink
operator=(const StreamingSink &)=deletesignet::forge::StreamingSink
output_files() constsignet::forge::StreamingSinkinline
records_dropped() constsignet::forge::StreamingSinkinline
records_submitted() constsignet::forge::StreamingSinkinline
records_written() constsignet::forge::StreamingSinkinline
start()signet::forge::StreamingSinkinline
stop()signet::forge::StreamingSinkinline
stop_nowait()signet::forge::StreamingSinkinline
StreamingSink(StreamingSink &&)=defaultsignet::forge::StreamingSink
StreamingSink(const StreamingSink &)=deletesignet::forge::StreamingSink
submit(StreamRecord rec)signet::forge::StreamingSinkinline
submit(int64_t timestamp_ns, uint32_t type_id, const uint8_t *data, size_t size)signet::forge::StreamingSinkinline
submit(int64_t timestamp_ns, uint32_t type_id, std::string_view sv)signet::forge::StreamingSinkinline
~StreamingSink()signet::forge::StreamingSinkinline