Public Attributes
std::string	output_dir
	Directory for output Parquet files (required)

std::string	file_prefix = "stream"
	Filename prefix for output files.

size_t	ring_buffer_capacity = 65536
	Soft cap on ring buffer occupancy (must be power of 2)

size_t	row_group_size = 10'000
	Records per Parquet row group.

size_t	max_file_rows = 1'000'000
	Maximum rows per output Parquet file before rolling.

std::chrono::milliseconds	flush_interval {100}
	Background thread wake-up interval.

bool	auto_start = true
	Start the background thread immediately on create()

Detailed Description

Configuration options for StreamingSink::create().

Definition at line 412 of file streaming_sink.hpp.

Member Data Documentation

bool signet::forge::StreamingSink::Options::auto_start = true

Start the background thread immediately on create()

Definition at line 419 of file streaming_sink.hpp.

std::string signet::forge::StreamingSink::Options::file_prefix = "stream"

Filename prefix for output files.

Definition at line 414 of file streaming_sink.hpp.

std::chrono::milliseconds signet::forge::StreamingSink::Options::flush_interval {100}

Background thread wake-up interval.

Definition at line 418 of file streaming_sink.hpp.

size_t signet::forge::StreamingSink::Options::max_file_rows = 1'000'000

Maximum rows per output Parquet file before rolling.

Definition at line 417 of file streaming_sink.hpp.

std::string signet::forge::StreamingSink::Options::output_dir

Directory for output Parquet files (required)

Definition at line 413 of file streaming_sink.hpp.

size_t signet::forge::StreamingSink::Options::ring_buffer_capacity = 65536

Soft cap on ring buffer occupancy (must be power of 2)

Definition at line 415 of file streaming_sink.hpp.

size_t signet::forge::StreamingSink::Options::row_group_size = 10'000

Records per Parquet row group.

Definition at line 416 of file streaming_sink.hpp.

The documentation for this struct was generated from the following file: