org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder

Enclosing class:

FileWriteSchemaTransformConfiguration.CsvConfiguration

public abstract static class FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract FileWriteSchemaTransformConfiguration.CsvConfiguration	build()
abstract FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder	setCsvFormat(java.lang.String value) The format of the written CSV file.
abstract FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder	setPreamble(java.lang.String value) Not to be confused with the CSV header, it is content written to the top of every sharded file prior to the header.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

setPreamble

public abstract FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder setPreamble(java.lang.String value)

Not to be confused with the CSV header, it is content written to the top of every sharded file prior to the header. In the example below, all the text proceeding the header 'column1,column2,column3' is the preamble.

Fake company, Inc. Lab experiment: abcdefg123456 Experiment date: 2022-12-05 Operator: John Doe

column1,column2,column3 1,2,3 4,5,6

setCsvFormat

public abstract FileWriteSchemaTransformConfiguration.CsvConfiguration.Builder setCsvFormat(java.lang.String value)

The format of the written CSV file. See org.apache.commons.csv.CSVFormat for allowed values, stringified in lowercase. Defaults to CSVFormat.DEFAULT

build

public abstract FileWriteSchemaTransformConfiguration.CsvConfiguration build()