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

control, freeRows, inputSources, inputSourceSlots, maxInnerIndex, operators, redirectionIndex, source

Method Summary

Modifier and Type	Method	Description
static Table	compute(String description, QueryTable source, UpdateByOperator[] ops, Map<String,ColumnSource> resultSources, RedirectionIndex redirectionIndex, ColumnSource<?>[] keySources, MatchPair[] byColumns, UpdateByControl control)	Perform a bucketed updateBy.
ShiftAwareListener	newListener(String description, QueryTable result, MatchPair[] byColumns)	Create an appropriate listener to process upstream updates.

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

processUpdateForRedirection, 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
 String description,
 @NotNull
 QueryTable source,
 @NotNull
 UpdateByOperator[] ops,
 @NotNull
 Map<String,ColumnSource> resultSources,
 @Nullable
 RedirectionIndex redirectionIndex,
 @NotNull
 ColumnSource<?>[] keySources,
 @NotNull
 MatchPair[] byColumns,
 @NotNull
 UpdateByControl control)

Perform a bucketed updateBy.

Parameters:

control - the UpdateByControl to set hashing parameters

description - the operation description

source - the source table

ops - the operations to perform

resultSources - the result sources

redirectionIndex - the redirection index, if one was used.

keySources - the sources for key columns.

byColumns - the grouping column pairs

Returns:

the result table

newListener

public ShiftAwareListener newListener(@NotNull
 String description,
 @NotNull
 QueryTable result,
 @NotNull
 MatchPair[] byColumns)

Create an appropriate listener to process upstream updates.

Parameters:

description - the table description

result - the result table

byColumns - the grouping column pairs

Returns:

a listener to process updates.