Package io.substrait.relation.physical

Class AbstractExchangeRel

java.lang.Object

io.substrait.relation.AbstractRel

io.substrait.relation.SingleInputRel

io.substrait.relation.physical.AbstractExchangeRel

All Implemented Interfaces:

HasExtension, Rel

Direct Known Subclasses:

BroadcastExchange, MultiBucketExchange, RoundRobinExchange, ScatterExchange, SingleBucketExchange

public abstract class AbstractExchangeRel
extends SingleInputRel
implements HasExtension

Physical exchange relation with a single input and extension metadata. Provides partitioning and target information for data exchange.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractExchangeRel.ExchangeTarget	Exchange target specification: partition IDs and target type.

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

Rel.Remap

Constructor Summary

Constructors

Constructor	Description
AbstractExchangeRel()

Method Summary

Modifier and Type	Method	Description
protected Type.Struct	deriveRecordType()	Derives the output record type from the input.
abstract Integer	getPartitionCount()	Returns the number of partitions for this exchange.
abstract List<AbstractExchangeRel.ExchangeTarget>	getTargets()	Returns the configured exchange targets.

Methods inherited from class io.substrait.relation.SingleInputRel

getInput, 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

AbstractExchangeRel

public AbstractExchangeRel()

Method Details

getPartitionCount

public abstract Integer getPartitionCount()

Returns the number of partitions for this exchange.

Returns:

the partition count, or null if unspecified

getTargets

public abstract List<AbstractExchangeRel.ExchangeTarget> getTargets()

Returns the configured exchange targets.

Returns:

the list of exchange targets (never null)

deriveRecordType

protected Type.Struct deriveRecordType()

Derives the output record type from the input.

Specified by:

deriveRecordType in class AbstractRel

Returns:

the output struct type