Package com.illumon.iris.importers

Class MultiPartitionImportTableWriterFactory

java.lang.Object

com.illumon.iris.importers.ImportTableWriterFactoryBase

com.illumon.iris.importers.MultiPartitionImportTableWriterFactory

All Implemented Interfaces:

ImportTableWriterFactory

public class MultiPartitionImportTableWriterFactory
extends ImportTableWriterFactoryBase

A table writer factory that accepts a partition at runtime (used when we want to use data from an import column to direct each row to a specific partition).

Field Summary

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

namespace, outputMode, tableDefinition, tableName, writableTableDefinition

Constructor Summary

Constructors

Constructor	Description
MultiPartitionImportTableWriterFactory(String namespace, String tableName, ImportOutputMode outputMode, TableDefinition tableDefinition, String internalPartition)

Method Summary

Modifier and Type	Method	Description
String	getComputedColumnPartition(String inputColumnPartition)	Get the computed column partition for the requested one.
File	getTableDestination(String columnPartitionValue)	Get a File representing the path where the table will be written.

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

getTableDefinition, getTableWriter, getTableWriter

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.importers.ImportTableWriterFactory

getTableWriter

Constructor Details

MultiPartitionImportTableWriterFactory

public MultiPartitionImportTableWriterFactory(String namespace, String tableName, ImportOutputMode outputMode, @NotNull TableDefinition tableDefinition, String internalPartition)

Method Details

getTableDestination

public File getTableDestination(String columnPartitionValue)

Description copied from interface: ImportTableWriterFactory

Get a File representing the path where the table will be written.

Parameters:

columnPartitionValue - the column partition to find the destination for

Returns:

a file at the path the table will be written.

getComputedColumnPartition

@Nullable public String getComputedColumnPartition(@Nullable String inputColumnPartition)

Description copied from interface: ImportTableWriterFactory

Get the computed column partition for the requested one. In Most cases the result will be the same as inputColumnPartition, however it is possible to return null indicating that there is no valid column partition.

Parameters:

inputColumnPartition - the requested input partition

Returns:

the computed column partition