Struct IntWriter

pub struct IntWriter {
    writer: TableWriter<IntRecord>,
    users: IdIndex<String>,
    review_ids: HashSet<i64>,
    n_recs: u32,
}

Object writer to transform and write GoodReads interactions

Fields

writer: TableWriter<IntRecord>

users: IdIndex<String>

review_ids: HashSet<i64>

n_recs: u32

Implementations

impl IntWriter

pub fn open() -> Result<IntWriter>

Open a new output

Trait Implementations

impl DataSink for IntWriter

fn output_files(&self) -> Vec<PathBuf>

Get the output files for the sink.

fn input_files(&self) -> Vec<PathBuf>

Get auxillary input files for the sink.

impl ObjectWriter<RawInteraction> for IntWriter

fn write_object(&mut self, row: RawInteraction) -> Result<()>

Write a single interaction to the output

fn finish(self) -> Result<usize>

Finish and close the target.

fn write_all_objects<I>(&mut self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator full of objects.

fn write_and_finish<I>(self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator of objects and finish the writer.

fn with_transform<F, T2>(self, transform: F) -> MapWriter<F, T2, T, Self>

where F: Fn(T2) -> Result<T>,

Wrap this object writer in a transformed writer.