Package com.northconcepts.datapipeline.foundations.pipeline
package com.northconcepts.datapipeline.foundations.pipeline
Declarative pipeline modeling and execution.
-
ClassesClassDescriptionBase class for declarative pipelines that read records from a
PipelineInput, process them and write them to aPipelineOutput.A pipeline that maps each input record to a new record using aDataMapping; records failing the mapping go to the discard writer, if one is set, instead of stopping the pipeline.A pipeline with no processing whose input defaults to aNullReader(no records) and output to aNullWriter.A declarative pipeline that applies an ordered list ofPipelineActions to its input records, with undo and redo of the most recent actions.Base class for the sources a pipeline reads its records from, such as CSV, Excel, fixed-width, JSON or XML files, JDBC queries and datasets.Base class for pipelines and their parts (inputs, outputs and actions), which can be serialized and can generate Java code.Base class for the destinations a pipeline writes its records to, such as CSV, Excel, fixed-width, JSON or XML files and JDBC tables.Base class for inputs that wrap anotherPipelineInputand decorate each reader it creates.Base class for outputs that wrap anotherPipelineOutputand decorate each writer it creates.