Package io.substrait.relation

Class ProtoRelConverter

java.lang.Object

io.substrait.relation.ProtoRelConverter

public class ProtoRelConverter
extends Object

Converts from Rel to Rel

Field Summary

Fields

Modifier and Type	Field	Description
protected final @NonNull SimpleExtension.ExtensionCollection	extensions
protected final @NonNull ExtensionLookup	lookup
protected final @NonNull ProtoExtensionConverter	protoExtensionConverter
protected final @NonNull ProtoTypeConverter	protoTypeConverter

Constructor Summary

Constructors

Constructor	Description
ProtoRelConverter(@NonNull ExtensionLookup lookup)	Constructor with custom ExtensionLookup.
ProtoRelConverter(@NonNull ExtensionLookup lookup, @NonNull ProtoExtensionConverter protoExtensionConverter)	Constructor with custom ExtensionLookup and ProtoExtensionConverter.
ProtoRelConverter(@NonNull ExtensionLookup lookup, @NonNull SimpleExtension.ExtensionCollection extensions)	Constructor with custom ExtensionLookup and SimpleExtension.ExtensionCollection.
ProtoRelConverter(@NonNull ExtensionLookup lookup, @NonNull SimpleExtension.ExtensionCollection extensions, @NonNull ProtoExtensionConverter protoExtensionConverter)	Constructor with custom ExtensionLookup, SimpleExtension.ExtensionCollection and ProtoExtensionConverter.

Method Summary

Modifier and Type	Method	Description
protected Extension.DdlExtensionObject	detailFromDdlExtensionObject(com.google.protobuf.Any any)
protected Extension.LeafRelDetail	detailFromExtensionLeafRel(com.google.protobuf.Any any)	Override to provide a custom converter for ExtensionLeafRel.getDetail() data
protected Extension.MultiRelDetail	detailFromExtensionMultiRel(com.google.protobuf.Any any)	Override to provide a custom converter for ExtensionMultiRel.getDetail() data
protected Extension.SingleRelDetail	detailFromExtensionSingleRel(com.google.protobuf.Any any)	Override to provide a custom converter for ExtensionSingleRel.getDetail() data
protected Extension.ExtensionTableDetail	detailFromExtensionTable(com.google.protobuf.Any any)	Override to provide a custom converter for ReadRel.ExtensionTable.getDetail() data
protected Extension.WriteExtensionObject	detailFromWriteExtensionObject(com.google.protobuf.Any any)
Rel	from(Rel rel)
Plan.Root	from(RelRoot rel)
protected Aggregate	newAggregate(AggregateRel rel)
protected BroadcastExchange	newBroadcastExchange(ExchangeRel rel)
protected ConsistentPartitionWindow	newConsistentPartitionWindow(ConsistentPartitionWindowRel rel)
protected Rel	newCross(CrossRel rel)
protected Rel	newDdl(DdlRel rel)
protected AbstractExchangeRel	newExchange(ExchangeRel rel)
protected AbstractExchangeRel.ExchangeTarget	newExchangeTarget(ExchangeRel.ExchangeTarget target)
protected Expand	newExpand(ExpandRel rel)
protected ExtensionDdl	newExtensionDdl(DdlRel rel)
protected ExtensionLeaf	newExtensionLeaf(ExtensionLeafRel rel)
protected ExtensionMulti	newExtensionMulti(ExtensionMultiRel rel)
protected ExtensionSingle	newExtensionSingle(ExtensionSingleRel rel)
protected ExtensionTable	newExtensionTable(ReadRel rel)
protected Rel	newExtensionWrite(WriteRel rel)
protected Fetch	newFetch(FetchRel rel)
protected FileOrFiles	newFileOrFiles(ReadRel.LocalFiles.FileOrFiles file)
protected Filter	newFilter(FilterRel rel)
protected Rel	newHashJoin(HashJoinRel rel)
protected Join	newJoin(JoinRel rel)
protected LocalFiles	newLocalFiles(ReadRel rel)
protected Rel	newMergeJoin(MergeJoinRel rel)
protected MultiBucketExchange	newMultiBucketExchange(ExchangeRel rel)
protected NamedDdl	newNamedDdl(DdlRel rel)
protected NamedScan	newNamedScan(ReadRel rel)
protected NamedStruct	newNamedStruct(NamedStruct namedStruct)
protected NamedStruct	newNamedStruct(ReadRel rel)
protected Rel	newNamedUpdate(UpdateRel rel)
protected NamedWrite	newNamedWrite(WriteRel rel)
protected NestedLoopJoin	newNestedLoopJoin(NestedLoopJoinRel rel)
protected Project	newProject(ProjectRel rel)
protected Rel	newRead(ReadRel rel)
protected RoundRobinExchange	newRoundRobinExchange(ExchangeRel rel)
protected ScatterExchange	newScatterExchange(ExchangeRel rel)
protected Set	newSet(SetRel rel)
protected SingleBucketExchange	newSingleBucketExchange(ExchangeRel rel)
protected Sort	newSort(SortRel rel)
protected Rel	newUpdate(UpdateRel rel)
protected VirtualTableScan	newVirtualTable(ReadRel rel)
protected Rel	newWrite(WriteRel rel)
protected Optional<AdvancedExtension>	optionalAdvancedExtension(RelCommon relCommon)
protected Optional<Hint>	optionalHint(RelCommon relCommon)
protected static Optional<Rel.Remap>	optionalRelmap(RelCommon relCommon)
protected Optional<Rel>	optionalViewDefinition(DdlRel rel)
protected Expression.StructLiteral	tableDefaults(Expression.Literal.Struct struct, NamedStruct tableSchema)

Methods inherited from class java.lang.Object

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

Field Details

lookup

protected final @NonNull ExtensionLookup lookup

extensions

protected final @NonNull SimpleExtension.ExtensionCollection extensions

protoTypeConverter

protected final @NonNull ProtoTypeConverter protoTypeConverter

protoExtensionConverter

protected final @NonNull ProtoExtensionConverter protoExtensionConverter

Constructor Details

ProtoRelConverter

public ProtoRelConverter(@NonNull ExtensionLookup lookup)

Constructor with custom ExtensionLookup.

Parameters:

lookup - the custom ExtensionLookup to use, must not be null

ProtoRelConverter

public ProtoRelConverter(@NonNull ExtensionLookup lookup,
 @NonNull SimpleExtension.ExtensionCollection extensions)

Constructor with custom ExtensionLookup and SimpleExtension.ExtensionCollection.

Parameters:

lookup - custom ExtensionLookup to use, must not be null

extensions - custom SimpleExtension.ExtensionCollection to use, must not be null

ProtoRelConverter

public ProtoRelConverter(@NonNull ExtensionLookup lookup,
 @NonNull ProtoExtensionConverter protoExtensionConverter)

Constructor with custom ExtensionLookup and ProtoExtensionConverter.

Parameters:

lookup - custom ExtensionLookup to use, must not be null

protoExtensionConverter - custom ProtoExtensionConverter to use, must not be null

ProtoRelConverter

public ProtoRelConverter(@NonNull ExtensionLookup lookup,
 @NonNull SimpleExtension.ExtensionCollection extensions,
 @NonNull ProtoExtensionConverter protoExtensionConverter)

Constructor with custom ExtensionLookup, SimpleExtension.ExtensionCollection and ProtoExtensionConverter.

Parameters:

lookup - custom ExtensionLookup to use, must not be null

extensions - custom SimpleExtension.ExtensionCollection to use, must not be null

protoExtensionConverter - custom ProtoExtensionConverter to use, must not be null

Method Details

from

public Plan.Root from(RelRoot rel)

from

public Rel from(Rel rel)

newRead

protected Rel newRead(ReadRel rel)

newWrite

protected Rel newWrite(WriteRel rel)

newNamedWrite

protected NamedWrite newNamedWrite(WriteRel rel)

newExtensionWrite

protected Rel newExtensionWrite(WriteRel rel)

newDdl

protected Rel newDdl(DdlRel rel)

newNamedDdl

protected NamedDdl newNamedDdl(DdlRel rel)

newExtensionDdl

protected ExtensionDdl newExtensionDdl(DdlRel rel)

optionalViewDefinition

protected Optional<Rel> optionalViewDefinition(DdlRel rel)

tableDefaults

protected Expression.StructLiteral tableDefaults(Expression.Literal.Struct struct,
 NamedStruct tableSchema)

newUpdate

protected Rel newUpdate(UpdateRel rel)

newNamedUpdate

protected Rel newNamedUpdate(UpdateRel rel)

newFilter

protected Filter newFilter(FilterRel rel)

newNamedStruct

protected NamedStruct newNamedStruct(ReadRel rel)

newNamedStruct

protected NamedStruct newNamedStruct(NamedStruct namedStruct)

newExtensionLeaf

protected ExtensionLeaf newExtensionLeaf(ExtensionLeafRel rel)

newExtensionSingle

protected ExtensionSingle newExtensionSingle(ExtensionSingleRel rel)

newExtensionMulti

protected ExtensionMulti newExtensionMulti(ExtensionMultiRel rel)

newNamedScan

protected NamedScan newNamedScan(ReadRel rel)

newExtensionTable

protected ExtensionTable newExtensionTable(ReadRel rel)

newLocalFiles

protected LocalFiles newLocalFiles(ReadRel rel)

newFileOrFiles

protected FileOrFiles newFileOrFiles(ReadRel.LocalFiles.FileOrFiles file)

newVirtualTable

protected VirtualTableScan newVirtualTable(ReadRel rel)

newFetch

protected Fetch newFetch(FetchRel rel)

newProject

protected Project newProject(ProjectRel rel)

newExpand

protected Expand newExpand(ExpandRel rel)

newAggregate

protected Aggregate newAggregate(AggregateRel rel)

newSort

protected Sort newSort(SortRel rel)

newJoin

protected Join newJoin(JoinRel rel)

newCross

protected Rel newCross(CrossRel rel)

newSet

protected Set newSet(SetRel rel)

newHashJoin

protected Rel newHashJoin(HashJoinRel rel)

newMergeJoin

protected Rel newMergeJoin(MergeJoinRel rel)

newNestedLoopJoin

protected NestedLoopJoin newNestedLoopJoin(NestedLoopJoinRel rel)

newConsistentPartitionWindow

protected ConsistentPartitionWindow newConsistentPartitionWindow(ConsistentPartitionWindowRel rel)

newExchange

protected AbstractExchangeRel newExchange(ExchangeRel rel)

newScatterExchange

protected ScatterExchange newScatterExchange(ExchangeRel rel)

newSingleBucketExchange

protected SingleBucketExchange newSingleBucketExchange(ExchangeRel rel)

newMultiBucketExchange

protected MultiBucketExchange newMultiBucketExchange(ExchangeRel rel)

newRoundRobinExchange

protected RoundRobinExchange newRoundRobinExchange(ExchangeRel rel)

newBroadcastExchange

protected BroadcastExchange newBroadcastExchange(ExchangeRel rel)

newExchangeTarget

protected AbstractExchangeRel.ExchangeTarget newExchangeTarget(ExchangeRel.ExchangeTarget target)

optionalRelmap

protected static Optional<Rel.Remap> optionalRelmap(RelCommon relCommon)

optionalHint

protected Optional<Hint> optionalHint(RelCommon relCommon)

optionalAdvancedExtension

protected Optional<AdvancedExtension> optionalAdvancedExtension(RelCommon relCommon)

detailFromExtensionLeafRel

protected Extension.LeafRelDetail detailFromExtensionLeafRel(com.google.protobuf.Any any)

Override to provide a custom converter for ExtensionLeafRel.getDetail() data

detailFromExtensionSingleRel

protected Extension.SingleRelDetail detailFromExtensionSingleRel(com.google.protobuf.Any any)

Override to provide a custom converter for ExtensionSingleRel.getDetail() data

detailFromExtensionMultiRel

protected Extension.MultiRelDetail detailFromExtensionMultiRel(com.google.protobuf.Any any)

Override to provide a custom converter for ExtensionMultiRel.getDetail() data

detailFromExtensionTable

protected Extension.ExtensionTableDetail detailFromExtensionTable(com.google.protobuf.Any any)

Override to provide a custom converter for ReadRel.ExtensionTable.getDetail() data

detailFromWriteExtensionObject

protected Extension.WriteExtensionObject detailFromWriteExtensionObject(com.google.protobuf.Any any)

detailFromDdlExtensionObject

protected Extension.DdlExtensionObject detailFromDdlExtensionObject(com.google.protobuf.Any any)