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 String`	`CONFIGURATION_TYPE`
`static String`	`TYPE_SPECIFIC_FIELDS_SOURCE_DIRECTORY`
`static String`	`TYPE_SPECIFIC_FIELDS_SOURCE_FILE`
`static 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

Class BinaryImportPersistentQuery