Serialized Form

Package org.apache.calcite.jdbc

Class org.apache.calcite.jdbc.JavaCollation extends org.apache.calcite.sql.SqlCollation implements Serializable

Serialized Fields

collator

Collator collator

Class org.apache.calcite.jdbc.JavaRecordType extends org.apache.calcite.rel.type.RelRecordType implements Serializable

Serialized Fields

clazz

Class<T> clazz

Class org.apache.calcite.jdbc.SqlTimeoutException extends SQLException implements Serializable

Package org.apache.calcite.sql

Class org.apache.calcite.sql.SqlCollation extends Object implements Serializable

Serialized Fields

collationName

String collationName

wrappedCharset

org.apache.calcite.util.SerializableCharset wrappedCharset

locale

Locale locale

strength

String strength

coercibility

org.apache.calcite.sql.SqlCollation.Coercibility coercibility

Package org.apache.calcite.sql.type

Class org.apache.calcite.sql.type.AbstractSqlType extends org.apache.calcite.rel.type.RelDataTypeImpl implements Serializable

Serialized Fields

typeName

org.apache.calcite.sql.type.SqlTypeName typeName

isNullable

boolean isNullable

Class org.apache.calcite.sql.type.ArraySqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

elementType

org.apache.calcite.rel.type.RelDataType elementType

Class org.apache.calcite.sql.type.BasicSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

precision

int precision

scale

int scale

typeSystem

org.apache.calcite.rel.type.RelDataTypeSystem typeSystem

collation

org.apache.calcite.sql.SqlCollation collation

wrappedCharset

org.apache.calcite.util.SerializableCharset wrappedCharset

Class org.apache.calcite.sql.type.IntervalSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

typeSystem

org.apache.calcite.rel.type.RelDataTypeSystem typeSystem

intervalQualifier

org.apache.calcite.sql.SqlIntervalQualifier intervalQualifier

Class org.apache.calcite.sql.type.MapSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

keyType

org.apache.calcite.rel.type.RelDataType keyType

valueType

org.apache.calcite.rel.type.RelDataType valueType

Class org.apache.calcite.sql.type.MultisetSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

elementType

org.apache.calcite.rel.type.RelDataType elementType

Class org.apache.calcite.sql.type.ObjectSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

sqlIdentifier

org.apache.calcite.sql.SqlIdentifier sqlIdentifier

comparability

org.apache.calcite.rel.type.RelDataTypeComparability comparability

family

org.apache.calcite.rel.type.RelDataTypeFamily family

Package org.apache.calcite.sql.validate

Class org.apache.calcite.sql.validate.CyclicDefinitionException extends RuntimeException implements Serializable

Serialized Fields

depth

int depth

path

List<E> path

Class org.apache.calcite.sql.validate.SqlValidatorException extends Exception implements Serializable

serialVersionUID:

-831683113957131387L

Package org.apache.calcite.sql2rel

Class org.apache.calcite.sql2rel.RelFieldTrimmer.TrimResult extends org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.util.mapping.Mapping> implements Serializable

Package org.apache.calcite.tools

Class org.apache.calcite.tools.RelConversionException extends Exception implements Serializable

Class org.apache.calcite.tools.ValidationException extends Exception implements Serializable

Package org.apache.flink.table.planner.calcite

Class org.apache.flink.table.planner.calcite.RexDistinctKeyVariable extends org.apache.calcite.rex.RexVariable implements Serializable

Serialized Fields

keyTerm

String keyTerm

dataType

org.apache.calcite.rel.type.RelDataType dataType

internalType

org.apache.flink.table.types.logical.LogicalType internalType

Class org.apache.flink.table.planner.calcite.RexDistinctKeyVariable$ extends scala.runtime.AbstractFunction3<String,org.apache.calcite.rel.type.RelDataType,org.apache.flink.table.types.logical.LogicalType,org.apache.flink.table.planner.calcite.RexDistinctKeyVariable> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.calcite.RexFieldVariable extends org.apache.calcite.rex.RexVariable implements Serializable

Serialized Fields

fieldTerm

String fieldTerm

dataType

org.apache.calcite.rel.type.RelDataType dataType

Class org.apache.flink.table.planner.calcite.RexFieldVariable$ extends scala.runtime.AbstractFunction2<String,org.apache.calcite.rel.type.RelDataType,org.apache.flink.table.planner.calcite.RexFieldVariable> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Package org.apache.flink.table.planner.codegen

Class org.apache.flink.table.planner.codegen.CodeGenException extends RuntimeException implements Serializable

Class org.apache.flink.table.planner.codegen.ExternalGeneratedExpression extends org.apache.flink.table.planner.codegen.GeneratedExpression implements Serializable

Serialized Fields

dataType

org.apache.flink.table.types.DataType dataType

externalTerm

String externalTerm

externalCode

String externalCode

Class org.apache.flink.table.planner.codegen.ExternalGeneratedExpression$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.codegen.GeneratedExpression extends Object implements Serializable

Serialized Fields

resultTerm

String resultTerm

nullTerm

String nullTerm

code

String code

resultType

org.apache.flink.table.types.logical.LogicalType resultType

literalValue

scala.Option<A> literalValue

Class org.apache.flink.table.planner.codegen.GeneratedExpression$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

ALWAYS_NULL

String ALWAYS_NULL

NEVER_NULL

String NEVER_NULL

NO_CODE

String NO_CODE

Class org.apache.flink.table.planner.codegen.LookupJoinCodeGenerator.GeneratedTableFunctionWithDataType extends Object implements Serializable

Serialized Fields

tableFunc

org.apache.flink.table.runtime.generated.GeneratedFunction<F extends org.apache.flink.api.common.functions.Function> tableFunc

dataType

org.apache.flink.table.types.DataType dataType

Class org.apache.flink.table.planner.codegen.LookupJoinCodeGenerator.GeneratedTableFunctionWithDataType$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.MatchAgg extends Object implements Serializable

Serialized Fields

aggregations

scala.collection.Seq<A> aggregations

inputExprs

scala.collection.Seq<A> inputExprs

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.MatchAgg$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.SingleAggCall>,scala.collection.Seq<org.apache.calcite.rex.RexNode>,org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.MatchAgg> implements Serializable

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.SingleAggCall extends Object implements Serializable

Serialized Fields

sqlAggFunction

org.apache.calcite.sql.SqlAggFunction sqlAggFunction

resultType

org.apache.calcite.rel.type.RelDataType resultType

exprIndices

scala.collection.Seq<A> exprIndices

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.SingleAggCall$ extends scala.runtime.AbstractFunction3<org.apache.calcite.sql.SqlAggFunction,org.apache.calcite.rel.type.RelDataType,scala.collection.Seq<Integer>,org.apache.flink.table.planner.codegen.MatchCodeGenerator.AggBuilder.SingleAggCall> implements Serializable

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.GeneratedPatternList extends Object implements Serializable

Serialized Fields

resultTerm

String resultTerm

code

String code

Class org.apache.flink.table.planner.codegen.MatchCodeGenerator.GeneratedPatternList$ extends scala.runtime.AbstractFunction2<String,String,org.apache.flink.table.planner.codegen.MatchCodeGenerator.GeneratedPatternList> implements Serializable

Package org.apache.flink.table.planner.expressions

Class org.apache.flink.table.planner.expressions.UnresolvedException extends RuntimeException implements Serializable

Package org.apache.flink.table.planner.functions.aggfunctions

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sum

org.apache.flink.table.expressions.UnresolvedReferenceExpression sum

count

org.apache.flink.table.expressions.UnresolvedReferenceExpression count

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.ByteAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction extends AvgAggFunction implements Serializable

Serialized Fields

resultType

org.apache.flink.table.types.DataType resultType

sumResultType

org.apache.flink.table.types.DataType sumResultType

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.DoubleAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.FloatAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.IntAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.LongAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.ShortAvgAggFunction extends AvgAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Count1AggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

count1

org.apache.flink.table.expressions.UnresolvedReferenceExpression count1

Class org.apache.flink.table.planner.functions.aggfunctions.CountAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

count

org.apache.flink.table.expressions.UnresolvedReferenceExpression count

Class org.apache.flink.table.planner.functions.aggfunctions.CumeDistAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sequence

org.apache.flink.table.expressions.UnresolvedReferenceExpression sequence

Class org.apache.flink.table.planner.functions.aggfunctions.DenseRankAggFunction extends RankLikeAggFunctionBase implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

operandCount

int operandCount

existDefaultValue

boolean existDefaultValue

value

org.apache.flink.table.expressions.UnresolvedReferenceExpression value

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.BooleanLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.ByteLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.CharLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.CharType type

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.DateLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.DecimalLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Serialized Fields

decimalType

org.apache.flink.table.types.logical.DecimalType decimalType

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.DoubleLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.FloatLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.IntLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.LongLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.ShortLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.StringLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.TimeLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction.TimestampLeadLagAggFunction extends LeadLagAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.TimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.ListAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

operandCount

int operandCount

acc

org.apache.flink.table.expressions.UnresolvedReferenceExpression acc

accDelimiter

org.apache.flink.table.expressions.UnresolvedReferenceExpression accDelimiter

delimiter

org.apache.flink.table.expressions.Expression delimiter

operand

org.apache.flink.table.expressions.Expression operand

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

max

org.apache.flink.table.expressions.UnresolvedReferenceExpression max

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.BooleanMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.ByteMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.DateMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.DecimalMaxAggFunction extends MaxAggFunction implements Serializable

Serialized Fields

resultType

org.apache.flink.table.types.DataType resultType

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.DoubleMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.FloatMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.IntMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.LongMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.ShortMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.StringMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.TimeMaxAggFunction extends MaxAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.TimestampLtzMaxAggFunction extends MaxAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.LocalZonedTimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction.TimestampMaxAggFunction extends MaxAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.TimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

min

org.apache.flink.table.expressions.UnresolvedReferenceExpression min

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.BooleanMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.ByteMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.DateMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.DecimalMinAggFunction extends MinAggFunction implements Serializable

Serialized Fields

resultType

org.apache.flink.table.types.DataType resultType

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.DoubleMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.FloatMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.IntMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.LongMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.ShortMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.StringMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.TimeMinAggFunction extends MinAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.TimestampLtzMinAggFunction extends MinAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.LocalZonedTimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction.TimestampMinAggFunction extends MinAggFunction implements Serializable

Serialized Fields

type

org.apache.flink.table.types.logical.TimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.NTILEAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

bucketSize

org.apache.flink.table.expressions.Expression bucketSize

bucketsWithPadding

org.apache.flink.table.expressions.Expression bucketsWithPadding

rowNumber

org.apache.flink.table.expressions.UnresolvedReferenceExpression rowNumber

bucket

org.apache.flink.table.expressions.UnresolvedReferenceExpression bucket

bucketThreshold

org.apache.flink.table.expressions.UnresolvedReferenceExpression bucketThreshold

Class org.apache.flink.table.planner.functions.aggfunctions.PercentRankAggFunction extends RankAggFunction implements Serializable

Serialized Fields

one

org.apache.flink.table.expressions.ValueLiteralExpression one

Class org.apache.flink.table.planner.functions.aggfunctions.RankAggFunction extends RankLikeAggFunctionBase implements Serializable

Serialized Fields

currNumber

org.apache.flink.table.expressions.UnresolvedReferenceExpression currNumber

Class org.apache.flink.table.planner.functions.aggfunctions.RankLikeAggFunctionBase extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sequence

org.apache.flink.table.expressions.UnresolvedReferenceExpression sequence

lastValues

org.apache.flink.table.expressions.UnresolvedReferenceExpression[] lastValues

orderKeyTypes

org.apache.flink.table.types.logical.LogicalType[] orderKeyTypes

Class org.apache.flink.table.planner.functions.aggfunctions.RowNumberAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sequence

org.apache.flink.table.expressions.UnresolvedReferenceExpression sequence

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

serialVersionUID:

8850662568341069949L

Serialized Fields

value

org.apache.flink.table.expressions.UnresolvedReferenceExpression value

count

org.apache.flink.table.expressions.UnresolvedReferenceExpression count

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.BooleanSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.ByteSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.CharSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Serialized Fields

type

org.apache.flink.table.types.logical.CharType type

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.DateSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.DecimalSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Serialized Fields

type

org.apache.flink.table.types.logical.DecimalType type

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.DoubleSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.FloatSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.IntSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.LongSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.ShortSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.StringSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.TimeSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.TimestampLtzSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

1L

Serialized Fields

type

org.apache.flink.table.types.logical.LocalZonedTimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction.TimestampSingleValueAggFunction extends SingleValueAggFunction implements Serializable

serialVersionUID:

320495723666949978L

Serialized Fields

type

org.apache.flink.table.types.logical.TimestampType type

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sum0

org.apache.flink.table.expressions.UnresolvedReferenceExpression sum0

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.ByteSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction extends Sum0AggFunction implements Serializable

Serialized Fields

returnType

org.apache.flink.table.types.DataType returnType

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.DoubleSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.FloatSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.IntSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.LongSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.ShortSum0AggFunction extends Sum0AggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sum

org.apache.flink.table.expressions.UnresolvedReferenceExpression sum

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.ByteSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.DecimalSumAggFunction extends SumAggFunction implements Serializable

Serialized Fields

returnType

org.apache.flink.table.types.DataType returnType

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.DoubleSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.FloatSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.IntSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.LongSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.ShortSumAggFunction extends SumAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction extends org.apache.flink.table.functions.DeclarativeAggregateFunction implements Serializable

Serialized Fields

sum

org.apache.flink.table.expressions.UnresolvedReferenceExpression sum

count

org.apache.flink.table.expressions.UnresolvedReferenceExpression count

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.ByteSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Serialized Fields

resultType

org.apache.flink.table.types.DataType resultType

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.DoubleSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.FloatSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.IntSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.LongSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.ShortSumWithRetractAggFunction extends SumWithRetractAggFunction implements Serializable

Package org.apache.flink.table.planner.plan.logical

Class org.apache.flink.table.planner.plan.logical.MatchRecognize extends Object implements Serializable

Serialized Fields

pattern

org.apache.calcite.rex.RexNode pattern

patternDefinitions

com.google.common.collect.ImmutableMap<K,V> patternDefinitions

measures

com.google.common.collect.ImmutableMap<K,V> measures

after

org.apache.calcite.rex.RexNode after

subsets

com.google.common.collect.ImmutableMap<K,V> subsets

allRows

boolean allRows

partitionKeys

org.apache.calcite.util.ImmutableBitSet partitionKeys

orderKeys

org.apache.calcite.rel.RelCollation orderKeys

interval

org.apache.calcite.rex.RexNode interval

Class org.apache.flink.table.planner.plan.logical.MatchRecognize$ extends scala.runtime.AbstractFunction9<org.apache.calcite.rex.RexNode,com.google.common.collect.ImmutableMap<String,org.apache.calcite.rex.RexNode>,com.google.common.collect.ImmutableMap<String,org.apache.calcite.rex.RexNode>,org.apache.calcite.rex.RexNode,com.google.common.collect.ImmutableMap<String,SortedSet<String>>,Object,org.apache.calcite.util.ImmutableBitSet,org.apache.calcite.rel.RelCollation,org.apache.calcite.rex.RexNode,org.apache.flink.table.planner.plan.logical.MatchRecognize> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.logical.SessionGroupWindow extends org.apache.flink.table.planner.plan.logical.LogicalWindow implements Serializable

Serialized Fields

gap

org.apache.flink.table.expressions.ValueLiteralExpression gap

Class org.apache.flink.table.planner.plan.logical.SessionGroupWindow$ extends scala.runtime.AbstractFunction3<org.apache.flink.table.runtime.groupwindow.WindowReference,org.apache.flink.table.expressions.FieldReferenceExpression,org.apache.flink.table.expressions.ValueLiteralExpression,org.apache.flink.table.planner.plan.logical.SessionGroupWindow> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.logical.SlidingGroupWindow extends org.apache.flink.table.planner.plan.logical.LogicalWindow implements Serializable

Serialized Fields

size

org.apache.flink.table.expressions.ValueLiteralExpression size

slide

org.apache.flink.table.expressions.ValueLiteralExpression slide

Class org.apache.flink.table.planner.plan.logical.SlidingGroupWindow$ extends scala.runtime.AbstractFunction4<org.apache.flink.table.runtime.groupwindow.WindowReference,org.apache.flink.table.expressions.FieldReferenceExpression,org.apache.flink.table.expressions.ValueLiteralExpression,org.apache.flink.table.expressions.ValueLiteralExpression,org.apache.flink.table.planner.plan.logical.SlidingGroupWindow> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.logical.TumblingGroupWindow extends org.apache.flink.table.planner.plan.logical.LogicalWindow implements Serializable

Serialized Fields

size

org.apache.flink.table.expressions.ValueLiteralExpression size

Class org.apache.flink.table.planner.plan.logical.TumblingGroupWindow$ extends scala.runtime.AbstractFunction3<org.apache.flink.table.runtime.groupwindow.WindowReference,org.apache.flink.table.expressions.FieldReferenceExpression,org.apache.flink.table.expressions.ValueLiteralExpression,org.apache.flink.table.planner.plan.logical.TumblingGroupWindow> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Package org.apache.flink.table.planner.plan.optimize.program

Class org.apache.flink.table.planner.plan.optimize.program.HEP_RULES_EXECUTION_TYPE$ extends scala.Enumeration implements Serializable

Serialized Fields

RULE_SEQUENCE

scala.Enumeration.Value RULE_SEQUENCE

RULE_COLLECTION

scala.Enumeration.Value RULE_COLLECTION

Package org.apache.flink.table.planner.plan.rules.logical

Class org.apache.flink.table.planner.plan.rules.logical.TemporalTableFunctionCall extends Object implements Serializable

Serialized Fields

temporalTableFunction

org.apache.flink.table.functions.TemporalTableFunction temporalTableFunction

timeAttribute

org.apache.calcite.rex.RexNode timeAttribute

Class org.apache.flink.table.planner.plan.rules.logical.TemporalTableFunctionCall$ extends scala.runtime.AbstractFunction2<org.apache.flink.table.functions.TemporalTableFunction,org.apache.calcite.rex.RexNode,org.apache.flink.table.planner.plan.rules.logical.TemporalTableFunctionCall> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Package org.apache.flink.table.planner.plan.schema

Class org.apache.flink.table.planner.plan.schema.GenericRelDataType extends org.apache.calcite.sql.type.BasicSqlType implements Serializable

Serialized Fields

genericType

org.apache.flink.table.types.logical.TypeInformationRawType<T> genericType

nullable

boolean nullable

Class org.apache.flink.table.planner.plan.schema.RawRelDataType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

rawType

org.apache.flink.table.types.logical.RawType<T> rawType

Class org.apache.flink.table.planner.plan.schema.StructuredRelDataType extends org.apache.calcite.sql.type.ObjectSqlType implements Serializable

Serialized Fields

structuredType

org.apache.flink.table.types.logical.StructuredType structuredType

Class org.apache.flink.table.planner.plan.schema.TimeIndicatorRelDataType extends org.apache.calcite.sql.type.BasicSqlType implements Serializable

Serialized Fields

typeSystemField

org.apache.calcite.rel.type.RelDataTypeSystem typeSystemField

originalType

org.apache.calcite.sql.type.BasicSqlType originalType

nullable

boolean nullable

isEventTime

boolean isEventTime

Package org.apache.flink.table.planner.plan.utils

Class org.apache.flink.table.planner.plan.utils.AggregateInfo extends Object implements Serializable

Serialized Fields

agg

org.apache.calcite.rel.core.AggregateCall agg

function

org.apache.flink.table.functions.UserDefinedFunction function

aggIndex

int aggIndex

argIndexes

int[] argIndexes

externalArgTypes

org.apache.flink.table.types.DataType[] externalArgTypes

externalAccTypes

org.apache.flink.table.types.DataType[] externalAccTypes

viewSpecs

org.apache.flink.table.runtime.dataview.DataViewSpec[] viewSpecs

externalResultType

org.apache.flink.table.types.DataType externalResultType

consumeRetraction

boolean consumeRetraction

Class org.apache.flink.table.planner.plan.utils.AggregateInfo$ extends scala.runtime.AbstractFunction9<org.apache.calcite.rel.core.AggregateCall,org.apache.flink.table.functions.UserDefinedFunction,Object,int[],org.apache.flink.table.types.DataType[],org.apache.flink.table.types.DataType[],org.apache.flink.table.runtime.dataview.DataViewSpec[],org.apache.flink.table.types.DataType,Object,org.apache.flink.table.planner.plan.utils.AggregateInfo> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.AggregateInfoList extends Object implements Serializable

Serialized Fields

aggInfos

org.apache.flink.table.planner.plan.utils.AggregateInfo[] aggInfos

indexOfCountStar

scala.Option<A> indexOfCountStar

countStarInserted

boolean countStarInserted

distinctInfos

org.apache.flink.table.planner.plan.utils.DistinctInfo[] distinctInfos

Class org.apache.flink.table.planner.plan.utils.AggregateInfoList$ extends scala.runtime.AbstractFunction4<org.apache.flink.table.planner.plan.utils.AggregateInfo[],scala.Option<Object>,Object,org.apache.flink.table.planner.plan.utils.DistinctInfo[],org.apache.flink.table.planner.plan.utils.AggregateInfoList> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.AggregateUtil$ extends scala.Enumeration implements Serializable

Class org.apache.flink.table.planner.plan.utils.DistinctInfo extends Object implements Serializable

Serialized Fields

argIndexes

int[] argIndexes

keyType

org.apache.flink.table.types.DataType keyType

accType

org.apache.flink.table.types.DataType accType

excludeAcc

boolean excludeAcc

dataViewSpec

scala.Option<A> dataViewSpec

consumeRetraction

boolean consumeRetraction

filterArgs

scala.collection.mutable.ArrayBuffer<A> filterArgs

aggIndexes

scala.collection.mutable.ArrayBuffer<A> aggIndexes

Class org.apache.flink.table.planner.plan.utils.DistinctInfo$ extends scala.runtime.AbstractFunction8<int[],org.apache.flink.table.types.DataType,org.apache.flink.table.types.DataType,Object,scala.Option<DataViewUtils.DistinctViewSpec>,Object,scala.collection.mutable.ArrayBuffer<Object>,scala.collection.mutable.ArrayBuffer<Object>,org.apache.flink.table.planner.plan.utils.DistinctInfo> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.ExpressionDetail$ extends scala.Enumeration implements Serializable

Serialized Fields

Explain

scala.Enumeration.Value Explain

Digest

scala.Enumeration.Value Digest

Class org.apache.flink.table.planner.plan.utils.ExpressionFormat$ extends scala.Enumeration implements Serializable

Serialized Fields

Infix

scala.Enumeration.Value Infix

PostFix

scala.Enumeration.Value PostFix

Prefix

scala.Enumeration.Value Prefix

Class org.apache.flink.table.planner.plan.utils.FlinkRexUtil.CnfHelper.OverflowError extends org.apache.calcite.util.ControlFlowException implements Serializable

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimeAttributeAccess extends Object implements Serializable

Serialized Fields

isEventTime

boolean isEventTime

isLeftInput

boolean isLeftInput

idx

int idx

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimeAttributeAccess$ extends scala.runtime.AbstractFunction3<Object,Object,Object,org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimeAttributeAccess> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimePredicate extends Object implements Serializable

Serialized Fields

isEventTime

boolean isEventTime

leftInputOnLeftSide

boolean leftInputOnLeftSide

leftTimeIdx

int leftTimeIdx

rightTimeIdx

int rightTimeIdx

pred

org.apache.calcite.rex.RexCall pred

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimePredicate$ extends scala.runtime.AbstractFunction5<Object,Object,Object,Object,org.apache.calcite.rex.RexCall,org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.TimePredicate> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.WindowBound extends Object implements Serializable

Serialized Fields

bound

long bound

isLeftLower

boolean isLeftLower

Class org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.WindowBound$ extends scala.runtime.AbstractFunction2<Object,Object,org.apache.flink.table.planner.plan.utils.IntervalJoinUtil.WindowBound> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.RankUtil.BothBoundary extends Object implements Serializable

Serialized Fields

lower

long lower

upper

long upper

Class org.apache.flink.table.planner.plan.utils.RankUtil.BothBoundary$ extends scala.runtime.AbstractFunction2<Object,Object,org.apache.flink.table.planner.plan.utils.RankUtil.BothBoundary> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.RankUtil.InputRefBoundary extends Object implements Serializable

Serialized Fields

inputFieldIndex

int inputFieldIndex

Class org.apache.flink.table.planner.plan.utils.RankUtil.InputRefBoundary$ extends scala.runtime.AbstractFunction1<Object,org.apache.flink.table.planner.plan.utils.RankUtil.InputRefBoundary> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.RankUtil.LimitPredicate extends Object implements Serializable

Serialized Fields

rankOnLeftSide

boolean rankOnLeftSide

pred

org.apache.calcite.rex.RexCall pred

Class org.apache.flink.table.planner.plan.utils.RankUtil.LimitPredicate$ extends scala.runtime.AbstractFunction2<Object,org.apache.calcite.rex.RexCall,org.apache.flink.table.planner.plan.utils.RankUtil.LimitPredicate> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.RankUtil.LowerBoundary extends Object implements Serializable

Serialized Fields

lower

long lower

Class org.apache.flink.table.planner.plan.utils.RankUtil.LowerBoundary$ extends scala.runtime.AbstractFunction1<Object,org.apache.flink.table.planner.plan.utils.RankUtil.LowerBoundary> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.planner.plan.utils.RankUtil.UpperBoundary extends Object implements Serializable

Serialized Fields

upper

long upper

Class org.apache.flink.table.planner.plan.utils.RankUtil.UpperBoundary$ extends scala.runtime.AbstractFunction1<Object,org.apache.flink.table.planner.plan.utils.RankUtil.UpperBoundary> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Package org.apache.flink.table.planner.typeutils

Class org.apache.flink.table.planner.typeutils.DataViewUtils.DistinctViewSpec extends org.apache.flink.table.runtime.dataview.MapViewSpec implements Serializable