Package com.illumon.iris.importers

Class 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

awaitJobs, awaitSyncOperators, filterWritablePartitions, makeExecutor, merge, merge, merge, merge, merge, merge

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