Package io.deephaven.importers

Class DirectoryImportTableFactory

java.lang.Object

io.deephaven.importers.ImportTableWriterFactoryBase

io.deephaven.importers.DirectoryImportTableFactory

All Implemented Interfaces:

ImportTableWriterFactory

public class DirectoryImportTableFactory
extends ImportTableWriterFactoryBase

A table writer factory that takes a single destination directory.

Field Summary

Fields inherited from class io.deephaven.importers.ImportTableWriterFactoryBase

namespace, outputMode, tableDefinition, tableName, writableTableDefinition

Constructor Summary

Constructors

Constructor	Description
DirectoryImportTableFactory(String namespace, String tableName, ImportOutputMode outputMode, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition, File destinationDirectory)

Method Summary

Modifier and Type	Method	Description
@Nullable String	getComputedColumnPartition(@Nullable String inputColumnPartition)	The method is invoked to determine the partition value to which the current row of data needs to be associated.
File	getTableDestination(String nullColumnPartitionValue)	Get a File representing the path where the table will be written.

Methods inherited from class io.deephaven.importers.ImportTableWriterFactoryBase

getLocalAppendableTable, getTableDefinition, getTableWriter, getTableWriter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.deephaven.importers.ImportTableWriterFactory

getTableWriter

Constructor Details

DirectoryImportTableFactory

public DirectoryImportTableFactory(String namespace,
 String tableName,
 ImportOutputMode outputMode,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition,
 File destinationDirectory)

Parameters:

namespace - the namespace

tableName - the table name

outputMode - the ImportOutputMode output mode

tableDefinition - the TableDefinition for the table

destinationDirectory - the destination directory where the table will be written

Method Details

getTableDestination

public File getTableDestination(String nullColumnPartitionValue)

Description copied from interface: ImportTableWriterFactory

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

Parameters:

nullColumnPartitionValue - the column partition to find the destination for

Returns:

a file at the path the table will be written.

getComputedColumnPartition

@Nullable
public @Nullable String getComputedColumnPartition(@Nullable
 @Nullable String inputColumnPartition)

Description copied from interface: ImportTableWriterFactory

The method is invoked to determine the partition value to which the current row of data needs to be associated. So in the case where user wants a single partition value for the import this should return that value. In other cases this may simply return the passed in value, however, it is possible to return null indicating that there is no valid column partition.

Parameters:

inputColumnPartition - the requested input partition

Returns:

the computed column partition