Struct spring_batch_rs::LoggerWriter

pub struct LoggerWriter {}

Implementations

impl LoggerWriter

pub fn new() -> Self

Examples found in repository

examples/csv_reader_with_headers.rs (line 39)

fn main() -> std::io::Result<()> {
    let csv = "year,make,model,description
    1948,Porsche,356,Luxury sports car
    1967,Ford,Mustang fastback 1967,American car";

    let reader = CsvItemReaderBuilder::new()
        .has_headers(true)
        .delimiter(b',')
        .from_reader(csv.as_bytes());

    let writer = LoggerWriter::new();

    let step: Step<Record, Record> = StepBuilder::new()
        .reader(&reader)
        .writer(&writer)
        .chunk(4)
        .build();

    step.execute();

    Ok(())
}

examples/json_reader.rs (line 21)

fn main() -> std::io::Result<()> {
    let path = Path::new("examples/data/persons.json");

    let file = File::options()
        .append(true)
        .read(true)
        .create(false)
        .open(path)
        .expect("Unable to open file");

    let reader = JsonItemReaderBuilder::new().from_reader(file);

    let writer = LoggerWriter::new();

    let step: Step<Person, Person> = StepBuilder::new()
        .reader(&reader)
        .writer(&writer)
        .chunk(4)
        .build();

    step.execute();

    Ok(())
}

Trait Implementations

impl Default for LoggerWriter

fn default() -> LoggerWriter

Returns the “default value” for a type.

impl<T> ItemWriter<T> for LoggerWriter

where T: Display,

fn write(&self, item: &T) -> Result<(), BatchError>

fn flush(&self) -> Result<(), BatchError>

fn open(&self) -> Result<(), BatchError>

fn update(&self, _is_first_item: bool) -> Result<(), BatchError>

fn close(&self) -> Result<(), BatchError>