Package com.illumon.iris.importers

Class AppendingImportTableWriterFactory

java.lang.Object

com.illumon.iris.importers.AppendingImportTableWriterFactory

All Implemented Interfaces:

ImportTableWriterFactory

public class AppendingImportTableWriterFactory
extends Object
implements ImportTableWriterFactory

A wrapper for table writer factory that forces append mode after a table is requested the 1st time.

This is useful if the factory is used repeatedly with the same partition(s) and we don't want to wipe out the table after the 1st run.

Constructor Summary

Constructors

Constructor	Description
AppendingImportTableWriterFactory(ImportTableWriterFactory tableWriterFactory)

Method Summary

Modifier and Type	Method	Description
LocalAppendableTable	getLocalAppendableTable(String columnPartitionValue, boolean forceAppend)	Returns the LocalAppendableTable for given column partition value.
TableDefinition	getTableDefinition()	Get the table definition associated with the table that will be written.
File	getTableDestination(String columnPartitionValue)	Get a File representing the path where the table will be written.
TableWriter	getTableWriter(String columnPartitionValue, boolean append)	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, getTableWriter

Constructor Details

AppendingImportTableWriterFactory

public AppendingImportTableWriterFactory(ImportTableWriterFactory tableWriterFactory)

Method Details

getTableDefinition

public TableDefinition getTableDefinition()

Description copied from interface: ImportTableWriterFactory

Get the table definition associated with the table that will be written.

Specified by:

getTableDefinition in interface ImportTableWriterFactory

Returns:

the table definition.

getTableDestination

public File getTableDestination(String columnPartitionValue)

Description copied from interface: ImportTableWriterFactory

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

Specified by:

getTableDestination in interface ImportTableWriterFactory

Parameters:

columnPartitionValue - the column partition to find the destination for

Returns:

a file at the path the table will be written.

getLocalAppendableTable

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

Description copied from interface: ImportTableWriterFactory

Returns the LocalAppendableTable for given column partition value.

Specified by:

getLocalAppendableTable in interface ImportTableWriterFactory

Parameters:

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

forceAppend - When true, the LocalAppendableTable will be initialized to append to any existing data. When false, append/replace/fail behavior is implementation defined.

Returns:

Returned appropriate LocalAppendableTable for column partition value.

getTableWriter

public TableWriter getTableWriter(String columnPartitionValue,
 boolean append)

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.

append - if the table should be appended or replaced.

Returns:

an appropriate TableWriter