Struct RootSink 

pub struct RootSink { /* private fields */ }

Event sink that writes a ROOT TTree on a background thread.

Implementations

impl RootSink

pub fn create(path: impl Into<PathBuf>) -> Self

Creates a sink with default options.

pub fn builder(path: impl Into<PathBuf>) -> RootSinkBuilder

Creates a configurable sink builder.

pub fn resolved_path(&self) -> Option<&Path>

Returns the concrete path after writing has begun.

Trait Implementations

impl Drop for RootSink

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EventSink for RootSink

fn begin(&mut self, schema: Arc<Schema>, plan: WritePlan) -> LadduDataResult<()>

Begins a write operation.

fn write_batch(&mut self, batch: &EventBatch) -> LadduDataResult<()>

Writes one batch.

fn finish(&mut self) -> LadduDataResult<()>

Finishes and flushes the write operation.

fn retains_batches(&self) -> bool

Returns whether written batches remain resident in memory.