Package com.illumon.iris.importers.util

Class DownsampleImport.Builder

java.lang.Object

com.illumon.iris.importers.util.ImportBuilder<DownsampleImport.Builder,DownsampleImport>

com.illumon.iris.importers.util.DownsampleImport.Builder

All Implemented Interfaces:

DownsampleImportBuilder

Enclosing class:

DownsampleImport

public static class DownsampleImport.Builder
extends ImportBuilder<DownsampleImport.Builder,DownsampleImport>
implements DownsampleImportBuilder

The Builder class allows setting properties for a downsample import and provides a build() method which returns a DownsampleImport object that will use the configured properties to import batch data.

Field Summary

Fields inherited from class com.illumon.iris.importers.util.ImportBuilder

destinationDirectory, destinationPartitions, namespace, outputMode, partitionColumn, schemaService, sourceName, strict, table

Constructor Summary

Constructors

Constructor	Description
Builder(String namespace, String table, Database db, String timestampColumn, String period, String... keyColumns)

Method Summary

Modifier and Type	Method	Description
DownsampleImport.Builder	addAggregate(AggType aggType, String column)	Adds a combo aggregate method.
DownsampleImport.Builder	addAggregates(ComboAggregateFactory.ComboBy... aggregates)	Adds combo aggregate methods.
DownsampleImport.Builder	addArrayColumns(String... columns)	Adds columns to compute array values for bins.
DownsampleImport.Builder	addAvgColumns(String... columns)	Adds columns to compute the average values for bins.
DownsampleImport.Builder	addFirstColumns(String... columns)	Adds columns to compute the first values for bins.
DownsampleImport.Builder	addLastColumns(String... columns)	Adds columns to compute the last values for bins.
DownsampleImport.Builder	addMaxColumns(String... columns)	Adds columns to compute the max values for bins.
DownsampleImport.Builder	addMinColumns(String... columns)	Adds columns to compute the min values for bins.
DownsampleImport.Builder	addStdColumns(String... columns)	Adds columns to compute the standard deviation values for bins.
DownsampleImport.Builder	addSumColumns(String... columns)	Adds columns to compute the sum values for bins.
DownsampleImport.Builder	addVarColumns(String... columns)	Adds columns to compute the variance values for bins.
DownsampleImport	build()	Builds the importer.
protected DownsampleImport.Builder	getThis()	Returns this builder.
DownsampleImport.Builder	setAllBins(boolean allBins)	Sets whether data will be output for all bins, even if there are no samples.
DownsampleImport.Builder	setCalendar(String calendar)	Sets the calendar.
DownsampleImport.Builder	setLogger(com.fishlib.io.logger.Logger logger)	Sets the logger.
DownsampleImport.Builder	setMaintainStateColumns(String... maintainStateColumns)	Adds columns to keep via as-of-join.
DownsampleImport.Builder	setNumThreads(int numThreads)	Sets the number of threads.
DownsampleImport.Builder	setPartitionColumn(String partitionColumn)	Sets the partition column.
DownsampleImport.Builder	setSourceTable(Table sourceTable)	Sets the source table.
DownsampleImport.Builder	setTimeBinMode(Downsampler.TimeBinMode timeBinMode)	Sets the time bin mode.
DownsampleImport.Builder	setTimeBinMode(String timeBinMode)	Sets the time bin mode.

Methods inherited from class com.illumon.iris.importers.util.ImportBuilder

setDestinationDirectory, setDestinationPartitions, setDestinationPartitions, setOutputMode, setOutputMode, setSchemaService, setSourceName, setStrict

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.importers.util.DownsampleImportBuilder

setDestinationDirectory, setDestinationPartitions, setDestinationPartitions, setOutputMode, setOutputMode, setStrict

Constructor Details

Builder

public Builder(String namespace, String table, Database db, String timestampColumn, String period, String... keyColumns)

Method Details

setSourceTable

public DownsampleImport.Builder setSourceTable(Table sourceTable)

Sets the source table.

Specified by:

setSourceTable in interface DownsampleImportBuilder

Parameters:

sourceTable - source table.

Returns:

this builder.

setTimeBinMode

public DownsampleImport.Builder setTimeBinMode(Downsampler.TimeBinMode timeBinMode)

Sets the time bin mode.

Specified by:

setTimeBinMode in interface DownsampleImportBuilder

Parameters:

timeBinMode - time bin mode.

Returns:

this builder.

setTimeBinMode

public DownsampleImport.Builder setTimeBinMode(String timeBinMode)

Sets the time bin mode.

Specified by:

setTimeBinMode in interface DownsampleImportBuilder

Parameters:

timeBinMode - time bin mode.

Returns:

this builder.

setAllBins

public DownsampleImport.Builder setAllBins(boolean allBins)

Sets whether data will be output for all bins, even if there are no samples.

Specified by:

setAllBins in interface DownsampleImportBuilder

Parameters:

allBins - true to output data for all bins.

Returns:

this builder.

setMaintainStateColumns

public DownsampleImport.Builder setMaintainStateColumns(String... maintainStateColumns)

Adds columns to keep via as-of-join.

Specified by:

setMaintainStateColumns in interface DownsampleImportBuilder

Parameters:

maintainStateColumns - columns to keep via as-of-join.

Returns:

this builder.

addAggregates

public DownsampleImport.Builder addAggregates(ComboAggregateFactory.ComboBy... aggregates)

Adds combo aggregate methods.

Specified by:

addAggregates in interface DownsampleImportBuilder

Parameters:

aggregates - aggregates.

Returns:

this builder.

addAggregate

public DownsampleImport.Builder addAggregate(AggType aggType, String column)

Adds a combo aggregate method.

Specified by:

addAggregate in interface DownsampleImportBuilder

Parameters:

aggType - aggregate type.

column - aggregate column.

Returns:

this builder.

addLastColumns

public DownsampleImport.Builder addLastColumns(String... columns)

Adds columns to compute the last values for bins.

Specified by:

addLastColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addFirstColumns

public DownsampleImport.Builder addFirstColumns(String... columns)

Adds columns to compute the first values for bins.

Specified by:

addFirstColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addMinColumns

public DownsampleImport.Builder addMinColumns(String... columns)

Adds columns to compute the min values for bins.

Specified by:

addMinColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addMaxColumns

public DownsampleImport.Builder addMaxColumns(String... columns)

Adds columns to compute the max values for bins.

Specified by:

addMaxColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addSumColumns

public DownsampleImport.Builder addSumColumns(String... columns)

Adds columns to compute the sum values for bins.

Specified by:

addSumColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addStdColumns

public DownsampleImport.Builder addStdColumns(String... columns)

Adds columns to compute the standard deviation values for bins.

Specified by:

addStdColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addVarColumns

public DownsampleImport.Builder addVarColumns(String... columns)

Adds columns to compute the variance values for bins.

Specified by:

addVarColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addAvgColumns

public DownsampleImport.Builder addAvgColumns(String... columns)

Adds columns to compute the average values for bins.

Specified by:

addAvgColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

addArrayColumns

public DownsampleImport.Builder addArrayColumns(String... columns)

Adds columns to compute array values for bins.

Specified by:

addArrayColumns in interface DownsampleImportBuilder

Parameters:

columns - columns.

Returns:

this builder.

setCalendar

public DownsampleImport.Builder setCalendar(String calendar)

Sets the calendar.

Specified by:

setCalendar in interface DownsampleImportBuilder

Parameters:

calendar - calendar.

Returns:

this builder.

setNumThreads

public DownsampleImport.Builder setNumThreads(int numThreads)

Sets the number of threads.

Specified by:

setNumThreads in interface DownsampleImportBuilder

Parameters:

numThreads - number of threads.

Returns:

this builder.

setPartitionColumn

public DownsampleImport.Builder setPartitionColumn(String partitionColumn)

Description copied from class: ImportBuilder

Sets the partition column.

Specified by:

setPartitionColumn in interface DownsampleImportBuilder

Overrides:

setPartitionColumn in class ImportBuilder<DownsampleImport.Builder,DownsampleImport>

Parameters:

partitionColumn - partition column.

Returns:

this builder.

setLogger

public DownsampleImport.Builder setLogger(com.fishlib.io.logger.Logger logger)

Sets the logger.

Specified by:

setLogger in interface DownsampleImportBuilder

Parameters:

logger - logger.

Returns:

this builder.

getThis

protected DownsampleImport.Builder getThis()

Description copied from class: ImportBuilder

Returns this builder. Concrete subclasses mus provide "this" so that the setters can chain properly.

Specified by:

getThis in class ImportBuilder<DownsampleImport.Builder,DownsampleImport>

Returns:

this builder.

build

public DownsampleImport build()

Description copied from class: ImportBuilder

Builds the importer.

Specified by:

build in interface DownsampleImportBuilder

Specified by:

build in class ImportBuilder<DownsampleImport.Builder,DownsampleImport>

Returns:

importer.