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 Details

    • setPartitionColumnFormula

      MergeDataBuilder setPartitionColumnFormula(String partColumnFormula)
      Sets the partition column formula.
      Parameters:
      partColumnFormula - partition column formula.
      Returns:
      this builder.

    • setPartitionColumnValue

      MergeDataBuilder setPartitionColumnValue(String partColumnValue)
      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

      MergeDataBuilder setThreadPoolSize(int threadPoolSize)
      Sets the thread pool size.
      Parameters:
      threadPoolSize - thread pool size.
      Returns:
      this builder.

    • setLowHeapUsage

      MergeDataBuilder setLowHeapUsage(Boolean lowHeapUsage)
      Sets how much heap to use.
      Parameters:
      lowHeapUsage - true to use low amounts of heap.
      Returns:
      this builder.

    • setMaximumConcurrentColumns

      MergeDataBuilder setMaximumConcurrentColumns(int maximumConcurrentColumns)
      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 than maximumConcurrentColumns distinct columns are being written.
      Parameters:
      maximumConcurrentColumns - the maximum number of columns that may be concurrently written
      Returns:
      this builder.

    • setForce

      MergeDataBuilder setForce(Boolean force)
      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

      MergeDataBuilder setAllowEmptyInput(Boolean allowEmptyInput)
      Sets if empty inputs are allowed.
      Parameters:
      allowEmptyInput - true to allow empty inputs.
      Returns:
      this builder.

    • setSortColumnFormula

      MergeDataBuilder setSortColumnFormula(String sortColumnFormula)
      Sets the sort column formula.
      Parameters:
      sortColumnFormula - column formula.
      Returns:
      this builder.

    • setStorageFormat

      MergeDataBuilder setStorageFormat(String storageFormat)
      Sets the storage format.
      Parameters:
      storageFormat - storage format.
      Returns:
      this builder.
      See Also:

    • setCodecName

      MergeDataBuilder setCodecName(String codecName)
      Sets the codec.
      Parameters:
      codecName - codec name.
      Returns:
      this builder.

    • setSyncMode

      MergeDataBuilder setSyncMode(String syncMode)
      Sets the data synchronization mode.
      Parameters:
      syncMode - data synchronization mode.
      Returns:
      this builder.

    • setSourceTable

      MergeDataBuilder setSourceTable(Table sourceTable)
      Sets the Table to use as source of data for the merge operation.
      Parameters:
      sourceTable - Table to use as source of data for the merge operation.
      Returns:
      this builder.

    • build

      MergeData build()
      Creates a MergeData object using the properties that have been set in the MergeDataBuilder.
      Returns:
      new MergeData object.