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

Class UpdateBy

java.lang.Object

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

Direct Known Subclasses:

BucketedUpdateBy

public abstract class UpdateBy
extends Object

The core of the Table.updateBy(Collection, MatchPair...) operation. This currently supports ticking forward fill but will eventually support cumulative sum.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	UpdateBy.UpdateType	The type of update to be applied.

Field Summary

Fields

Modifier and Type	Field	Description
protected ChunkSource.WithPrev<Attributes.Values>[]	inputSources
protected ChunkedUpdateByOperator[]	operators
protected QueryTable	source

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UpdateBy(ChunkedUpdateByOperator[] operators, QueryTable source)

Method Summary

Modifier and Type	Method	Description
static Table	updateBy(QueryTable source, Collection<UpdateByClause> clauses, MatchPair[] byColumns)	Apply the specified operations to each group of rows in the source table and produce a result table with the same index as the source with each operator applied.

Methods inherited from class java.lang.Object

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

Field Details

inputSources

protected final ChunkSource.WithPrev<Attributes.Values>[] inputSources

operators

protected final ChunkedUpdateByOperator[] operators

source

protected final QueryTable source

Constructor Details

UpdateBy

protected UpdateBy(@NotNull ChunkedUpdateByOperator[] operators, @NotNull QueryTable source)

Method Details

updateBy

public static Table updateBy(@NotNull QueryTable source, Collection<UpdateByClause> clauses, MatchPair[] byColumns)

Apply the specified operations to each group of rows in the source table and produce a result table with the same index as the source with each operator applied.

Parameters:

source - the source to apply to.

clauses - the operations to apply.

byColumns - the columns to group by before applying operations

Returns:

a new table with the same index as the source with all the operations applied.