Package com.illumon.iris.importers
Class ImportTableWriterFactoryBase
java.lang.Object
com.illumon.iris.importers.ImportTableWriterFactoryBase
- All Implemented Interfaces:
ImportTableWriterFactory
- Direct Known Subclasses:
DirectoryImportTableFactory
,MultiPartitionImportTableWriterFactory
,SinglePartitionImportTableFactory
public abstract class ImportTableWriterFactoryBase extends Object implements ImportTableWriterFactory
A base for table writer factories with common utility code to validate and prepare table destination directories,
and create the table writers.
-
Field Summary
Fields Modifier and Type Field Description protected String
namespace
protected ImportOutputMode
outputMode
protected TableDefinition
tableDefinition
protected String
tableName
protected TableDefinition
writableTableDefinition
-
Method Summary
Modifier and Type Method Description TableDefinition
getTableDefinition()
Note this returns the full table definition including partitioning columns.protected TableWriter
getTableWriter(File destinationDirectory, boolean forceAppend)
TableWriter
getTableWriter(String columnPartitionValue, boolean forceAppend)
Get aTableWriter
for the table and specified partition, optionally appending.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
getComputedColumnPartition, getTableDestination, getTableWriter
-
Field Details
-
Method Details
-
getTableDefinition
Note this returns the full table definition including partitioning columns.- Specified by:
getTableDefinition
in interfaceImportTableWriterFactory
- Returns:
- the table definition.
-
getTableWriter
Description copied from interface:ImportTableWriterFactory
Get aTableWriter
for the table and specified partition, optionally appending.- Specified by:
getTableWriter
in interfaceImportTableWriterFactory
- Parameters:
columnPartitionValue
- the column partition to use. Some implementations allow nulls.forceAppend
- if the table should be appended or replaced.- Returns:
- an appropriate
TableWriter
-
getTableWriter
-