Package io.substrait.relation

Class AbstractUpdate

java.lang.Object

io.substrait.relation.AbstractRel

io.substrait.relation.ZeroInputRel

io.substrait.relation.AbstractUpdate

All Implemented Interfaces:

HasExtension, Rel

Direct Known Subclasses:

NamedUpdate

public abstract class AbstractUpdate
extends ZeroInputRel
implements HasExtension

Represents an update operation on a table.

Defines the target schema, update condition, and column transformations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractUpdate.TransformExpression	Represents a transformation applied to a specific column during an update.

Nested classes/interfaces inherited from interface io.substrait.relation.Rel

Rel.Remap

Constructor Summary

Constructors

Constructor	Description
AbstractUpdate()

Method Summary

Modifier and Type	Method	Description
Type.Struct	deriveRecordType()	Derives the output record type from the table schema.
abstract Expression	getCondition()	Returns the condition that determines which rows to update.
abstract NamedStruct	getTableSchema()	Returns the schema of the target table.
abstract List<AbstractUpdate.TransformExpression>	getTransformations()	Returns the list of column transformations to apply.

Methods inherited from class io.substrait.relation.ZeroInputRel

getInputs

Methods inherited from class io.substrait.relation.AbstractRel

getRecordType

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.substrait.relation.HasExtension

getExtension

Methods inherited from interface io.substrait.relation.Rel

accept, getCommonExtension, getHint, getRemap

Constructor Details

AbstractUpdate

public AbstractUpdate()

Method Details

getTableSchema

public abstract NamedStruct getTableSchema()

Returns the schema of the target table.

Returns:

table schema as NamedStruct

getCondition

public abstract Expression getCondition()

Returns the condition that determines which rows to update.

Returns:

update condition expression

getTransformations

public abstract List<AbstractUpdate.TransformExpression> getTransformations()

Returns the list of column transformations to apply.

Returns:

list of AbstractUpdate.TransformExpression

deriveRecordType

public Type.Struct deriveRecordType()

Derives the output record type from the table schema.

Specified by:

deriveRecordType in class AbstractRel

Returns:

Type.Struct based on getTableSchema()