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
String	getComputedColumnPartition(String inputColumnPartition)	Get the computed column partition for the requested one.
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

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.

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

getComputedColumnPartition

@Nullable public String getComputedColumnPartition(@Nullable String inputColumnPartition)

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 return null indicating that there is no valid column partition.

Specified by:

getComputedColumnPartition in interface ImportTableWriterFactory

Parameters:

inputColumnPartition - the requested input partition

Returns:

the computed column partition