Package com.illumon.iris.importers.util

Class MergeData.Builder

java.lang.Object

com.illumon.iris.importers.util.MergeData.Builder

All Implemented Interfaces:

MergeDataBuilder

Enclosing class:

MergeData

public static class MergeData.Builder
extends Object
implements MergeDataBuilder

The Builder class allows setting properties for a merge and provides a build() method which returns a MergeData object that will use the configured properties to merge data.

Constructor Summary

Constructors

Constructor	Description
Builder(Database database, String namespace, String table)

Method Summary

Modifier and Type	Method	Description
MergeData	build()	Creates a MergeData object using the properties that have been set in the MergeDataBuilder.
MergeData.Builder	setAllowEmptyInput(Boolean allowEmptyInput)	Sets if empty inputs are allowed.
MergeData.Builder	setCodecName(String codecName)	Sets the codec.
MergeData.Builder	setForce(Boolean force)	Sets whether to force merge when destinations already have data.
MergeData.Builder	setLowHeapUsage(Boolean lowHeapUsage)	Sets how much heap to use.
MergeData.Builder	setMaximumConcurrentColumns(int maximumConcurrentColumns)	Sets the maximum number of concurrent input columns.
MergeData.Builder	setPartitionColumnFormula(String partColumnFormula)	Sets the partition column formula.
MergeData.Builder	setPartitionColumnValue(String partColumnValue)	Sets the partition column value.
MergeData.Builder	setSortColumnFormula(String sortColumnFormula)	Sets the sort column formula.
MergeDataBuilder	setSourceTable(Table sourceTable)	Sets the Table to use as source of data for the merge operation.
MergeData.Builder	setStorageFormat(String storageFormat)	Sets the storage format.
MergeData.Builder	setSyncMode(String syncMode)	Sets the data synchronization mode.
MergeData.Builder	setThreadPoolSize(int threadPoolSize)	Sets the thread pool size.

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder(Database database,
 String namespace,
 String table)

Method Details

setPartitionColumnFormula

public MergeData.Builder setPartitionColumnFormula(String partColumnFormula)

Description copied from interface: MergeDataBuilder

Sets the partition column formula.

Specified by:

setPartitionColumnFormula in interface MergeDataBuilder

Parameters:

partColumnFormula - partition column formula.

Returns:

this builder.

setPartitionColumnValue

public MergeData.Builder setPartitionColumnValue(String partColumnValue)

Description copied from interface: MergeDataBuilder

Sets the partition column value. This method adds quotes around a literal partition value to make a formula.

Specified by:

setPartitionColumnValue in interface MergeDataBuilder

Parameters:

partColumnValue - partition column value.

Returns:

this builder.

setThreadPoolSize

public MergeData.Builder setThreadPoolSize(int threadPoolSize)

Description copied from interface: MergeDataBuilder

Sets the thread pool size.

Specified by:

setThreadPoolSize in interface MergeDataBuilder

Parameters:

threadPoolSize - thread pool size.

Returns:

this builder.

setMaximumConcurrentColumns

public MergeData.Builder setMaximumConcurrentColumns(int maximumConcurrentColumns)

Sets the maximum number of concurrent input columns.

Specified by:

setMaximumConcurrentColumns in interface MergeDataBuilder

Parameters:

maximumConcurrentColumns - the maximum number of concurrent input columns.

Returns:

this builder.

setLowHeapUsage

public MergeData.Builder setLowHeapUsage(Boolean lowHeapUsage)

Sets how much heap to use.

Specified by:

setLowHeapUsage in interface MergeDataBuilder

Parameters:

lowHeapUsage - true to use low amounts of heap.

Returns:

this builder.

setForce

public MergeData.Builder setForce(Boolean force)

Description copied from interface: MergeDataBuilder

Sets whether to force merge when destinations already have data.

Specified by:

setForce in interface MergeDataBuilder

Parameters:

force - Whether to force merge when destinations already have data.

Returns:

this builder.

setAllowEmptyInput

public MergeData.Builder setAllowEmptyInput(Boolean allowEmptyInput)

Description copied from interface: MergeDataBuilder

Sets if empty inputs are allowed.

Specified by:

setAllowEmptyInput in interface MergeDataBuilder

Parameters:

allowEmptyInput - true to allow empty inputs.

Returns:

this builder.

setSortColumnFormula

public MergeData.Builder setSortColumnFormula(String sortColumnFormula)

Description copied from interface: MergeDataBuilder

Sets the sort column formula.

Specified by:

setSortColumnFormula in interface MergeDataBuilder

Parameters:

sortColumnFormula - column formula.

Returns:

this builder.

setStorageFormat

public MergeData.Builder setStorageFormat(String storageFormat)

Description copied from interface: MergeDataBuilder

Sets the storage format.

Specified by:

setStorageFormat in interface MergeDataBuilder

Parameters:

storageFormat - storage format.

Returns:

this builder.

See Also:

• Database.StorageFormat

setCodecName

public MergeData.Builder setCodecName(String codecName)

Description copied from interface: MergeDataBuilder

Sets the codec.

Specified by:

setCodecName in interface MergeDataBuilder

Parameters:

codecName - codec name.

Returns:

this builder.

setSyncMode

public MergeData.Builder setSyncMode(String syncMode)

Description copied from interface: MergeDataBuilder

Sets the data synchronization mode.

Specified by:

setSyncMode in interface MergeDataBuilder

Parameters:

syncMode - data synchronization mode.

Returns:

this builder.

setSourceTable

public MergeDataBuilder setSourceTable(@Nullable
 Table sourceTable)

Description copied from interface: MergeDataBuilder

Sets the Table to use as source of data for the merge operation.

Specified by:

setSourceTable in interface MergeDataBuilder

Parameters:

sourceTable - Table to use as source of data for the merge operation.

Returns:

this builder.

build

public MergeData build()

Description copied from interface: MergeDataBuilder

Creates a MergeData object using the properties that have been set in the MergeDataBuilder.

Specified by:

build in interface MergeDataBuilder

Returns:

new MergeData object.