Package com.illumon.iris.importers

Class DirectoryImportTableFactory

java.lang.Object

com.illumon.iris.importers.ImportTableWriterFactoryBase

com.illumon.iris.importers.DirectoryImportTableFactory

All Implemented Interfaces:

ImportTableWriterFactory

public class DirectoryImportTableFactory
extends ImportTableWriterFactoryBase

A table writer factory that takes a single destination directory.

Field Summary

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

namespace, outputMode, tableDefinition, tableName, writableTableDefinition

Constructor Summary

Constructors

Constructor	Description
DirectoryImportTableFactory(String namespace, String tableName, ImportOutputMode outputMode, TableDefinition tableDefinition, File destinationDirectory)

Method Summary

Modifier and Type	Method	Description
String	getComputedColumnPartition(String inputColumnPartition)	The method is invoked to determine the partition value to which the current row of data needs to be associated.
File	getTableDestination(String nullColumnPartitionValue)	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

DirectoryImportTableFactory

public DirectoryImportTableFactory(String namespace,
 String tableName,
 ImportOutputMode outputMode,
 @NotNull
 TableDefinition tableDefinition,
 File destinationDirectory)

Method Details

getTableDestination

public File getTableDestination(String nullColumnPartitionValue)

Description copied from interface: ImportTableWriterFactory

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

Parameters:

nullColumnPartitionValue - 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

The method is invoked to determine the partition value to which the current row of data needs to be associated. So in the case where user wants a single partition value for the import this should return that value. In other cases this may simply return the passed in value, 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