Package com.northconcepts.datapipeline.foundations.pipeline.output

Class FileSinkPipelineOutput

java.lang.Object
com.northconcepts.datapipeline.foundations.core.Bean
com.northconcepts.datapipeline.foundations.core.FoundationObject
com.northconcepts.datapipeline.foundations.pipeline.PipelineObject
com.northconcepts.datapipeline.foundations.pipeline.PipelineOutput
com.northconcepts.datapipeline.foundations.pipeline.output.FileSinkPipelineOutput
All Implemented Interfaces:
DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataWriterFactory, JavaCodeGenerator, Serializable
Direct Known Subclasses:
AvroPipelineOutput, CsvPipelineOutput, ExcelPipelineOutput, FixedWidthPipelineOutput, JsonRecordPipelineOutput, LatexPipelineOutput, MicrosoftWordPipelineOutput, OrcPipelineOutput, ParquetPipelineOutput, PdfPipelineOutput, XmlRecordPipelineOutput
public abstract class FileSinkPipelineOutput extends PipelineOutput
Base class for pipeline outputs that write their data to a FileSink.
See Also:

  • Constructor Details

    • FileSinkPipelineOutput

      public FileSinkPipelineOutput()

  • Method Details

    • getFileSink

      public abstract FileSink getFileSink()

    • setFileSink

      public abstract FileSinkPipelineOutput setFileSink(FileSink fileSink)

    • generateSaveCode

      public void generateSaveCode(JavaCodeBuilder javaCodeBuilder)
      Writes the generated code that saves the output after Job.run(reader, writer); does nothing by default.

    • getName

      public String getName()
      Description copied from class: PipelineOutput
      Returns a display name for this output, such as the destination's name followed by its format.
      Specified by:
      getName in class PipelineOutput