Package com.illumon.iris.importers

Class MergeIntradayData

java.lang.Object

com.illumon.iris.importers.BaseMergeData

com.illumon.iris.importers.MergeIntradayData

public class MergeIntradayData
extends BaseMergeData

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

Field Summary

Fields inherited from class com.illumon.iris.importers.BaseMergeData

database, logger, params

Constructor Summary

Constructors

Constructor	Description
MergeIntradayData(Database db, MergeParameters params, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
protected Table	getInputData(String logPrefix, TableDefinition tableDefinition)
static void	main(String namespace, String tableName, String partitionValue, String... args)	Main - thin wrapper around merge().

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

awaitJobs, awaitSyncOperators, filterWritablePartitions, makeExecutor, merge

Methods inherited from class java.lang.Object

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

Constructor Details

MergeIntradayData

public MergeIntradayData(Database db,
 @NotNull
 MergeParameters params,
 @NotNull
 com.fishlib.io.logger.Logger log)

Method Details

getInputData

@Nullable
protected Table getInputData(@NotNull
 String logPrefix,
 @NotNull
 TableDefinition tableDefinition)

main

public static void main(String namespace,
 String tableName,
 String partitionValue,
 String... args)
                 throws IOException

Main - thin wrapper around merge().

Parameters:

args - Command-line arguments

Throws:

IOException