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)
Get the computed column partition for the requested one.File
getTableDestination(String nullColumnPartitionValue)
Get aFile
representing the path where the table will be written.Methods inherited from class com.illumon.iris.importers.ImportTableWriterFactoryBase
getTableDefinition, getTableWriter, getTableWriter
-
Constructor Details
-
DirectoryImportTableFactory
public DirectoryImportTableFactory(String namespace, String tableName, ImportOutputMode outputMode, @NotNull TableDefinition tableDefinition, File destinationDirectory)
-
-
Method Details
-
getTableDestination
Description copied from interface:ImportTableWriterFactory
Get aFile
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
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 returnnull
indicating that there is no valid column partition.- Parameters:
inputColumnPartition
- the requested input partition- Returns:
- the computed column partition
-