public class RowSchema extends Object
Constructor and Description |
---|
RowSchema(org.apache.calcite.rel.type.RelDataType logicalRowType) |
Modifier and Type | Method and Description |
---|---|
int |
logicalArity()
Returns the arity of the logical record.
|
scala.collection.Seq<String> |
logicalFieldNames()
Returns the logical fields names including logical fields (i.e.
|
org.apache.calcite.rel.type.RelDataType |
logicalType()
Returns a logical
RelDataType including logical fields (i.e. |
org.apache.calcite.rel.core.AggregateCall |
mapAggregateCall(org.apache.calcite.rel.core.AggregateCall logicalAggCall)
Converts logical indices of a aggregate call to physical ones.
|
int |
mapIndex(int logicalIndex)
Converts logical indices to physical indices based on this schema.
|
org.apache.calcite.rex.RexNode |
mapRexNode(org.apache.calcite.rex.RexNode logicalRexNode)
Converts logical field references of a
RexNode to physical ones. |
int |
physicalArity()
Returns the arity of the physical record.
|
scala.collection.Seq<String> |
physicalFieldNames()
Returns the physical fields names with no logical fields (i.e.
|
scala.collection.Seq<TypeInformation<?>> |
physicalFieldTypeInfo()
Returns
TypeInformation of the row's fields with no logical fields (i.e. |
org.apache.calcite.rel.type.RelDataType |
physicalType()
Returns a physical
RelDataType with no logical fields (i.e. |
TypeInformation<Row> |
physicalTypeInfo()
Returns a physical
TypeInformation of row with no logical fields (i.e. |
public RowSchema(org.apache.calcite.rel.type.RelDataType logicalRowType)
public int logicalArity()
public int physicalArity()
public org.apache.calcite.rel.type.RelDataType logicalType()
RelDataType
including logical fields (i.e. time indicators).public org.apache.calcite.rel.type.RelDataType physicalType()
RelDataType
with no logical fields (i.e. time indicators).public TypeInformation<Row> physicalTypeInfo()
TypeInformation
of row with no logical fields (i.e. time indicators).public scala.collection.Seq<TypeInformation<?>> physicalFieldTypeInfo()
TypeInformation
of the row's fields with no logical fields (i.e. time indicators).public scala.collection.Seq<String> logicalFieldNames()
public scala.collection.Seq<String> physicalFieldNames()
public int mapIndex(int logicalIndex)
logicalIndex
- (undocumented)public org.apache.calcite.rel.core.AggregateCall mapAggregateCall(org.apache.calcite.rel.core.AggregateCall logicalAggCall)
logicalAggCall
- (undocumented)public org.apache.calcite.rex.RexNode mapRexNode(org.apache.calcite.rex.RexNode logicalRexNode)
RexNode
to physical ones.logicalRexNode
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.