Package com.illumon.iris.importers

Class RemergeData

java.lang.Object

com.illumon.iris.importers.BaseMergeData

com.illumon.iris.importers.RemergeData

@ScriptApi
public class RemergeData
extends BaseMergeData

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

Field Summary

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

database, logger, params

Constructor Summary

Constructors

Constructor	Description
RemergeData(Database db, MergeParameters params, com.fishlib.io.logger.Logger logger, String sourceNamespace, String sourceTableName)

Method Summary

Modifier and Type	Method	Description
protected Table	getInputData(String logPrefix, TableDefinition tableDefinition)
static void	main(String sourceNamespace, String sourceTableName, String destNamespace, String destTableName, 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

RemergeData

public RemergeData(Database db,
 @NotNull
 MergeParameters params,
 @NotNull
 com.fishlib.io.logger.Logger logger,
 @NotNull
 String sourceNamespace,
 @NotNull
 String sourceTableName)

Method Details

getInputData

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

main

public static void main(String sourceNamespace,
 String sourceTableName,
 String destNamespace,
 String destTableName,
 String partitionValue,
 String... args)
                 throws IOException

Main - thin wrapper around merge(). see https://deephaven.io/enterprise/docs/importing-data/advanced/merging/#remergedata

Parameters:

args - Command-line arguments

Throws:

IOException