com.illumon.iris.importers.RemergeData

public class RemergeData
extends MergeData

Merge data from system permanent locations of another table (as written by MergeData).

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.
`static void`	`main(String... args)`	Main - thin wrapper around merge().

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

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

Constructor Details
- RemergeData
  
  public RemergeData(@NotNull String sourceNamespace, @NotNull String sourceTableName)
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
- main
  
  public static void main(String... args) throws IOException
  
  Main - thin wrapper around merge().
  
  Parameters:
  
  args - Command-line arguments
  
  Throws:
  
  IOException

Class RemergeData