Package com.illumon.iris.db.v2.updateby

Class BucketedUpdateBy

java.lang.Object

com.illumon.iris.db.v2.updateby.UpdateBy

com.illumon.iris.db.v2.updateby.BucketedUpdateBy

public class BucketedUpdateBy
extends UpdateBy

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.updateby.UpdateBy

UpdateBy.UpdateType

Field Summary

Fields inherited from class com.illumon.iris.db.v2.updateby.UpdateBy

inputSources, operators, source

Method Summary

Modifier and Type	Method	Description
static Table	compute(AggregationControl control, String description, QueryTable source, ChunkedUpdateByOperator[] ops, Map<String,ColumnSource> resultSources, ColumnSource<?>[] keySources)	Perform a bucketed updateBy.
ShiftAwareListener	newListener(String description, QueryTable result)

Methods inherited from class com.illumon.iris.db.v2.updateby.UpdateBy

updateBy

Methods inherited from class java.lang.Object

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

Method Details

compute

public static Table compute(@NotNull AggregationControl control, @NotNull String description, @NotNull QueryTable source, @NotNull ChunkedUpdateByOperator[] ops, @NotNull Map<String,ColumnSource> resultSources, @NotNull ColumnSource<?>[] keySources)

Perform a bucketed updateBy.

Parameters:

control - the AggregationControl to set hashing parameters

description - the operation description

source - the source table

ops - the operations to perform

resultSources - the result sources

keySources - the sources for key columns.

Returns:

the result table

newListener

public ShiftAwareListener newListener(String description, QueryTable result)