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 final String	namespace
protected final ImportOutputMode	outputMode
protected final TableDefinition	tableDefinition
protected final String	tableName
protected final 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 a TableWriter 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

namespace

protected final String namespace

tableName

protected final String tableName

tableDefinition

protected final TableDefinition tableDefinition

writableTableDefinition

protected final TableDefinition writableTableDefinition

outputMode

protected final ImportOutputMode outputMode

Method Details

getTableDefinition

public TableDefinition getTableDefinition()

Note this returns the full table definition including partitioning columns.

Specified by:

getTableDefinition in interface ImportTableWriterFactory

Returns:

the table definition.

getTableWriter

public TableWriter getTableWriter(String columnPartitionValue,
 boolean forceAppend)

Description copied from interface: ImportTableWriterFactory

Get a TableWriter for the table and specified partition, optionally appending.

Specified by:

getTableWriter in interface ImportTableWriterFactory

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

protected TableWriter getTableWriter(File destinationDirectory,
 boolean forceAppend)