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
LocalAppendableTable	getLocalAppendableTable(String columnPartitionValue, boolean forceAppend)	The method validates the destination against the ImportOutputMode included for the CsvImport unless forceAppend is true.
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.

getLocalAppendableTable

@NotNull
public LocalAppendableTable getLocalAppendableTable(String columnPartitionValue,
 boolean forceAppend)

The method validates the destination against the ImportOutputMode included for the CsvImport unless forceAppend is true. Creates a new LocalAppendableTable instance to return.

Specified by:

getLocalAppendableTable in interface ImportTableWriterFactory

Parameters:

columnPartitionValue - the column partition to use. Some implementations allow nulls.

forceAppend - when true will use ImportOutputMode.APPEND when initializing the instance of LocalAppendableTable being returned. A value of false will use the ImportOutputMode provided as part of the import call

Returns:

A new LocalAppendableTable using the destination retrieved using the provided column partition value and resolved ImportOutputMode

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)