MergeFromTable

java.lang.Object

com.illumon.iris.importers.MergeData

com.illumon.iris.importers.MergeFromTable

public class MergeFromTable
extends MergeData

Merge data from a provided source table.

Constructor Summary

Constructors

Constructor Description

MergeFromTable()

Method Summary

Modifier and Type	Method	Description
`protected Table`	`getInputData(com.fishlib.io.logger.Logger log, String logPrefix, Database db, TableDefinition tableDefinition, String namespace, String tableName, String partitioningColumnValue)`	Get the input data that should be merged.

Methods inherited from class com.illumon.iris.importers.MergeData

filterWritablePartitions, makeExecutor, merge, merge, merge, merge, merge, merge, supportedParquetCodecsStream

Methods inherited from class java.lang.Object

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

Constructor Details
- MergeFromTable
  
  public MergeFromTable()
Method Details
- getInputData
  
  @Nullable protected Table getInputData(@NotNull com.fishlib.io.logger.Logger log, @NotNull String logPrefix, @NotNull Database db, @NotNull TableDefinition tableDefinition, @NotNull String namespace, @NotNull String tableName, @NotNull String partitioningColumnValue)
  
  Description copied from class: MergeData
  
  Get the input data that should be merged.
  
  Specified by:
  
  getInputData in class MergeData
  
  Parameters:
  
  log - Logger for any useful output
  
  logPrefix - A prefix for any log output
  
  db - The Database instance to use when sourcing input data
  
  tableDefinition - The definition of the destination table
  
  namespace - The namespace of the destination table
  
  tableName - The name of the destination table
  
  partitioningColumnValue - The value of the destination partitioning column
  
  Returns:
  
  Input data in Table form, or null if no such data exists