Package com.illumon.iris.importers.util
Interface MergeDataBuilder
- All Known Implementing Classes:
MergeData.Builder
@ScriptApi public interface MergeDataBuilder
A clean interface defining all the methods a MergeData builder must define. The MergeData class should provide
factory methods to provide the implementation.
-
Method Summary
Modifier and Type Method Description MergeData
build()
Creates a MergeData object using the properties that have been set in theMergeDataBuilder
.MergeDataBuilder
setAllowEmptyInput(Boolean allowEmptyInput)
Sets if empty inputs are allowed.MergeDataBuilder
setCodecName(String codecName)
Sets the codec.MergeDataBuilder
setForce(Boolean force)
Sets whether to force merge when destinations already have data.MergeDataBuilder
setLowHeapUsage(Boolean lowHeapUsage)
Sets how much heap to use.MergeDataBuilder
setMaximumConcurrentColumns(int maximumConcurrentColumns)
Set the maximum number of columns that may be concurrently processed when in maximum throughput mode.MergeDataBuilder
setPartitionColumnFormula(String partColumnFormula)
Sets the partition column formula.MergeDataBuilder
setPartitionColumnValue(String partColumnValue)
Sets the partition column value.MergeDataBuilder
setSortColumnFormula(String sortColumnFormula)
Sets the sort column formula.MergeDataBuilder
setStorageFormat(String storageFormat)
Sets the storage format.MergeDataBuilder
setSyncMode(String syncMode)
Sets the data synchronization mode.MergeDataBuilder
setThreadPoolSize(int threadPoolSize)
Sets the thread pool size.
-
Method Details
-
setPartitionColumnFormula
Sets the partition column formula.- Parameters:
partColumnFormula
- partition column formula.- Returns:
- this builder.
-
setPartitionColumnValue
Sets the partition column value. This method adds quotes around a literal partition value to make a formula.- Parameters:
partColumnValue
- partition column value.- Returns:
- this builder.
-
setThreadPoolSize
Sets the thread pool size.- Parameters:
threadPoolSize
- thread pool size.- Returns:
- this builder.
-
setLowHeapUsage
Sets how much heap to use.- Parameters:
lowHeapUsage
- true to use low amounts of heap.- Returns:
- this builder.
-
setMaximumConcurrentColumns
Set the maximum number of columns that may be concurrently processed when in maximum throughput mode. In this mode, no matter how many threads are available write jobs will not be enqueued until less thanmaximumConcurrentColumns
distinct columns are being written.- Parameters:
maximumConcurrentColumns
- the maximum number of columns that may be concurrently written- Returns:
- this builder.
-
setForce
Sets whether to force merge when destinations already have data.- Parameters:
force
- Whether to force merge when destinations already have data.- Returns:
- this builder.
-
setAllowEmptyInput
Sets if empty inputs are allowed.- Parameters:
allowEmptyInput
- true to allow empty inputs.- Returns:
- this builder.
-
setSortColumnFormula
Sets the sort column formula.- Parameters:
sortColumnFormula
- column formula.- Returns:
- this builder.
-
setStorageFormat
Sets the storage format.- Parameters:
storageFormat
- storage format.- Returns:
- this builder.
- See Also:
Database.StorageFormat
-
setCodecName
Sets the codec.- Parameters:
codecName
- codec name.- Returns:
- this builder.
-
setSyncMode
Sets the data synchronization mode.- Parameters:
syncMode
- data synchronization mode.- Returns:
- this builder.
-
build
MergeData build()Creates a MergeData object using the properties that have been set in theMergeDataBuilder
.- Returns:
- new
MergeData
object.
-