Package com.illumon.iris.pqimport

Class DownsampleImportPersistentQuery

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.DownsampleImportPersistentQuery

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

public class DownsampleImportPersistentQuery
extends ImportPersistentQuery

Persistent query that takes a source table, downsamples it and saves into a target table (intraday). We do not base this on BaseImportPersistentQuery for now because we are using the new import "builder" construct, which provides much of the same functionality (creates the table writer factory for example).

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AGGREGATE_COLUMNS
static final String	AGGREGATE_TYPES
static final String	ALL_BINS
static final String	CALENDAR
static final String	CONFIGURATION_TYPE
protected final PersistentQueryDbServerConfig	dbServerConfig
static final String	KEY_COLUMNS
static final String	MAINTAIN_STATE_COLUMNS
static final String	NUM_THREADS
static final String	PERIOD
static final String	SOURCE_NAMESPACE
static final String	SOURCE_TABLE
static final String	TIME_BIN_MODE
static final String	TIMESTAMP_COLUMN

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
DownsampleImportPersistentQuery(PersistentQueryConfiguration config, String scriptBody, PersistentQueryDbServerConfig dbServerConfig, ControllerConfigurationType configurationType, ScriptPathLoaderState scriptLoaderState)

Method Summary

Modifier and Type	Method	Description
PersistentQueryState	execute(Database database)	Execute a query on a remote host.
protected String	getConfigurationType()

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

PERIOD

public static final String PERIOD

See Also:

• Constant Field Values

KEY_COLUMNS

public static final String KEY_COLUMNS

See Also:

• Constant Field Values

TIMESTAMP_COLUMN

public static final String TIMESTAMP_COLUMN

See Also:

• Constant Field Values

SOURCE_NAMESPACE

public static final String SOURCE_NAMESPACE

See Also:

• Constant Field Values

SOURCE_TABLE

public static final String SOURCE_TABLE

See Also:

• Constant Field Values

AGGREGATE_COLUMNS

public static final String AGGREGATE_COLUMNS

See Also:

• Constant Field Values

AGGREGATE_TYPES

public static final String AGGREGATE_TYPES

See Also:

• Constant Field Values

MAINTAIN_STATE_COLUMNS

public static final String MAINTAIN_STATE_COLUMNS

See Also:

• Constant Field Values

CALENDAR

public static final String CALENDAR

See Also:

• Constant Field Values

ALL_BINS

public static final String ALL_BINS

See Also:

• Constant Field Values

TIME_BIN_MODE

public static final String TIME_BIN_MODE

See Also:

• Constant Field Values

NUM_THREADS

public static final String NUM_THREADS

See Also:

• Constant Field Values

dbServerConfig

protected final PersistentQueryDbServerConfig dbServerConfig

Constructor Details

DownsampleImportPersistentQuery

public DownsampleImportPersistentQuery(PersistentQueryConfiguration config,
 String scriptBody,
 PersistentQueryDbServerConfig dbServerConfig,
 ControllerConfigurationType configurationType,
 ScriptPathLoaderState scriptLoaderState)

Method Details

execute

public PersistentQueryState execute(Database database)

Description copied from interface: RemoteQuery

Execute a query on a remote host.

Parameters:

database - database to use for execution.

Returns:

result of the query.

getConfigurationType

@NotNull
protected String getConfigurationType()