Package com.illumon.iris.pqimport

Class BinaryImportPersistentQuery

java.lang.Object

com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery<PersistentQueryState>

com.illumon.iris.pqimport.MergeImportPersistentQuery

com.illumon.iris.pqimport.ImportPersistentQuery

com.illumon.iris.pqimport.BaseImportPersistentQuery

com.illumon.iris.pqimport.BinaryImportPersistentQuery

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

public class BinaryImportPersistentQuery
extends BaseImportPersistentQuery

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIGURATION_TYPE
static final String	TYPE_SPECIFIC_FIELDS_SOURCE_DIRECTORY
static final String	TYPE_SPECIFIC_FIELDS_SOURCE_FILE
static final String	TYPE_SPECIFIC_FIELDS_SOURCE_GLOB

Fields inherited from class com.illumon.iris.pqimport.BaseImportPersistentQuery

dbServerConfig

Fields inherited from class com.illumon.iris.pqimport.ImportPersistentQuery

APPEND, IMPORT_SOURCE, INTRADAY_PARTITION_COLUMN, OUTPUT_MODE_APPEND, OUTPUT_MODE_REPLACE, OUTPUT_MODE_SAFE, STRICT, TYPE_SPECIFIC_FIELDS_OUTPUT_MODE

Fields inherited from class com.illumon.iris.pqimport.MergeImportPersistentQuery

PARTITION_SUBSTITUTION, SUBSTITUTION_DATE_FORMAT

Constructor Summary

Constructors

Constructor	Description
BinaryImportPersistentQuery(PersistentQueryConfiguration config, String scriptBody, PersistentQueryDbServerConfig dbServerConfig, ControllerConfigurationType configurationType, ScriptPathLoaderState scriptLoaderState, PublicPrivateKeyEncryption encryption)

Method Summary

Modifier and Type	Method	Description
protected void	doImport(PersistentQueryConfiguration config, org.jdom2.Element importSource, ImportOutputMode outputMode, ImportTableWriterFactory importTableWriterFactory, String intradayPartitionColumn, Boolean strict, RemoteCommandProgress progress, String columnPartitionValue, Database database, TableDefinitionSchema schema)
protected String	getConfigurationType()
protected String	getImportSourceType()

Methods inherited from class com.illumon.iris.pqimport.BaseImportPersistentQuery

execute

Methods inherited from class com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery

getClient, getLog, getRemoteQueryProcessor, getUserContext, initializeContext, initializeContext

Methods inherited from class java.lang.Object

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

Field Details

CONFIGURATION_TYPE

public static final String CONFIGURATION_TYPE

See Also:

• Constant Field Values

TYPE_SPECIFIC_FIELDS_SOURCE_FILE

public static final String TYPE_SPECIFIC_FIELDS_SOURCE_FILE

See Also:

• Constant Field Values

TYPE_SPECIFIC_FIELDS_SOURCE_GLOB

public static final String TYPE_SPECIFIC_FIELDS_SOURCE_GLOB

See Also:

• Constant Field Values

TYPE_SPECIFIC_FIELDS_SOURCE_DIRECTORY

public static final String TYPE_SPECIFIC_FIELDS_SOURCE_DIRECTORY

See Also:

• Constant Field Values

Constructor Details

BinaryImportPersistentQuery

public BinaryImportPersistentQuery(PersistentQueryConfiguration config,
 String scriptBody,
 PersistentQueryDbServerConfig dbServerConfig,
 ControllerConfigurationType configurationType,
 ScriptPathLoaderState scriptLoaderState,
 PublicPrivateKeyEncryption encryption)

Method Details

doImport

protected void doImport(PersistentQueryConfiguration config,
 org.jdom2.Element importSource,
 ImportOutputMode outputMode,
 ImportTableWriterFactory importTableWriterFactory,
 String intradayPartitionColumn,
 Boolean strict,
 RemoteCommandProgress progress,
 String columnPartitionValue,
 Database database,
 TableDefinitionSchema schema)

Specified by:

doImport in class BaseImportPersistentQuery

getConfigurationType

@NotNull
protected String getConfigurationType()

Specified by:

getConfigurationType in class BaseImportPersistentQuery

getImportSourceType

@NotNull
protected String getImportSourceType()

Specified by:

getImportSourceType in class BaseImportPersistentQuery