Package io.deephaven.enterprise.dnd

Class BaseImportJob

java.lang.Object

io.deephaven.enterprise.dnd.BaseImportJob

public class BaseImportJob
extends Object

Base class for import jobs. Provides common functionality such as retrieving the schema for a given namespace and table name. Extensible to override functions like importSourceRequired.

Constructor Summary

Constructors

Constructor	Description
BaseImportJob(String namespace, String tableName, String importSource, String intradayPartitionColumn, String partitionFormula, ImportOutputMode outputMode, long persistentQuerySerial)

Method Summary

Modifier and Type	Method	Description
Optional<String>	getColumnPartitionValue()
Optional<String>	getIntradayPartitionColumn()

Methods inherited from class java.lang.Object

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

Constructor Details

BaseImportJob

public BaseImportJob(String namespace,
 String tableName,
 String importSource,
 String intradayPartitionColumn,
 String partitionFormula,
 ImportOutputMode outputMode,
 long persistentQuerySerial)

Parameters:

namespace - the namespace of the table to import into

tableName - the name of the table to import into

importSource - the name of the import source

intradayPartitionColumn - the intraday partition column

partitionFormula - the partition formula

outputMode - the output mode

persistentQuerySerial - the persistent query serial

Method Details

getIntradayPartitionColumn

public Optional<String> getIntradayPartitionColumn()

getColumnPartitionValue

public Optional<String> getColumnPartitionValue()