Package com.illumon.iris.importers.merge

Interface MergeDestinationFactory

public interface MergeDestinationFactory

A factory interface for creating MergeDestination instances appropriate for the desired Database.StorageFormat.

Method Summary

Modifier and Type	Method	Description
MergeDestination	create(File writableInternalPartition, String partitioningColumnValue, String tableName, String operationName, Map<String,String> additionalArguments)
static MergeDestinationFactory	of(Database.StorageFormat format)
void	writeMergeDataHighThroughput(com.fishlib.io.logger.Logger log, String logPrefix, StatusCallback statusCallback, SyncOperator[] syncOperators, com.fishlib.util.process.FatalErrorReporter fatalErrorReporter, ExecutorService executorService, Table inputData, String[] writableColumnNames, List<Future<?>> futures, MergeDestination[] usedDestinations, int maximumConcurrentColumns)

Method Details

of

static MergeDestinationFactory of(@NotNull Database.StorageFormat format)

create

MergeDestination create(@NotNull File writableInternalPartition, @NotNull String partitioningColumnValue, @NotNull String tableName, @NotNull String operationName, @NotNull Map<String,String> additionalArguments)

writeMergeDataHighThroughput

void writeMergeDataHighThroughput(@NotNull com.fishlib.io.logger.Logger log, @NotNull String logPrefix, @NotNull StatusCallback statusCallback, @Nullable SyncOperator[] syncOperators, @NotNull com.fishlib.util.process.FatalErrorReporter fatalErrorReporter, @NotNull ExecutorService executorService, @NotNull Table inputData, @NotNull String[] writableColumnNames, @NotNull List<Future<?>> futures, @NotNull MergeDestination[] usedDestinations, int maximumConcurrentColumns)