Package org.apache.beam.sdk.io.iceberg
Class AddFilesSchemaTransformProvider.Configuration.Builder
java.lang.Object
org.apache.beam.sdk.io.iceberg.AddFilesSchemaTransformProvider.Configuration.Builder
- Enclosing class:
AddFilesSchemaTransformProvider.Configuration
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()setCatalogProperties(Map<String, String> catalogProperties) setConfigProperties(Map<String, String> confProperties) setErrorHandling(ErrorHandling errorHandling) setLocationPrefix(String prefix) setManifestFileSize(Integer size) setPartitionFields(List<String> fields) setTableProperties(Map<String, String> props) setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds)
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
setTable
-
setCatalogProperties
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setCatalogProperties(Map<String, String> catalogProperties) -
setConfigProperties
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setConfigProperties(Map<String, String> confProperties) -
setTriggeringFrequencySeconds
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds) -
setManifestFileSize
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setManifestFileSize(Integer size) -
setLocationPrefix
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setLocationPrefix(String prefix) -
setPartitionFields
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setPartitionFields(List<String> fields) -
setTableProperties
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setTableProperties(Map<String, String> props) -
setErrorHandling
public abstract AddFilesSchemaTransformProvider.Configuration.Builder setErrorHandling(ErrorHandling errorHandling) -
build
-