MergeIntradayData

java.lang.Object

com.illumon.iris.importers.MergeData

com.illumon.iris.importers.MergeIntradayData

public class MergeIntradayData
extends MergeData

Merge data from system intraday locations (as written by various importers).

Constructor Summary

Constructors

Constructor Description

MergeIntradayData()

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().

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
- MergeIntradayData
  
  public MergeIntradayData()
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