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)