Inheritance diagram for com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction:

Collaboration diagram for com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction:

Public Member Functions
RelDataType	inferReturnType (SqlOperatorBinding opBinding)

Package Functions
	ExtFunction (final String name, final ExtensionFunction sig)

Static Private Member Functions
static java.util.List < SqlTypeFamily >	toSqlSignature (final ExtensionFunction sig)

static boolean	isPointerType (final ExtensionFunction.ExtArgumentType type)

static ExtensionFunction.ExtArgumentType	getValueType (final ExtensionFunction.ExtArgumentType type)

static SqlTypeName	toSqlTypeName (final ExtensionFunction.ExtArgumentType type)

Private Attributes
final boolean	isRowUdf

final SqlTypeName	ret

Detailed Description

Definition at line 1737 of file MapDSqlOperatorTable.java.

Constructor & Destructor Documentation

com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.ExtFunction	(	final String	name,
		final ExtensionFunction	sig
	)

inlinepackage

Definition at line 1738 of file MapDSqlOperatorTable.java.

References com.mapd.parser.server.ExtensionFunction.getRet(), com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.isRowUdf, com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.ret, com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlSignature(), and com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlTypeName().

                                                                 {
       super(name,
               SqlKind.OTHER_FUNCTION,
               null,
               null,
               OperandTypes.family(toSqlSignature(sig)),
               sig.isRowUdf() ? SqlFunctionCategory.SYSTEM
                              : SqlFunctionCategory.USER_DEFINED_TABLE_FUNCTION);
       isRowUdf = sig.isRowUdf();
       if (isRowUdf) {
         ret = toSqlTypeName(sig.getRet());
       } else {
         ret = null;
       }
     }

Here is the call graph for this function:

Member Function Documentation

static ExtensionFunction.ExtArgumentType com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.getValueType ( final ExtensionFunction.ExtArgumentType type )

inlinestaticprivate

Definition at line 1799 of file MapDSqlOperatorTable.java.

References assert(), Double, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, and run_benchmark_import.type.

Referenced by com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlSignature().

                                                           {
       switch (type) {
         case PInt8:
           return ExtensionFunction.ExtArgumentType.Int8;
         case PInt16:
           return ExtensionFunction.ExtArgumentType.Int16;
         case PInt32:
           return ExtensionFunction.ExtArgumentType.Int32;
         case PInt64:
           return ExtensionFunction.ExtArgumentType.Int64;
         case PFloat:
           return ExtensionFunction.ExtArgumentType.Float;
         case PDouble:
           return ExtensionFunction.ExtArgumentType.Double;
         case PBool:
           return ExtensionFunction.ExtArgumentType.Bool;
       }
       MAPDLOGGER.error("getValueType: no value for type " + type);
       assert false;
       return null;
     }

Here is the call graph for this function:

Here is the caller graph for this function:

RelDataType com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.inferReturnType ( SqlOperatorBinding opBinding )

inline

Definition at line 1788 of file MapDSqlOperatorTable.java.

References assert(), com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.isRowUdf, and com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.ret.

                                                                      {
       if (isRowUdf) {
         final RelDataTypeFactory typeFactory = opBinding.getTypeFactory();
         return typeFactory.createTypeWithNullability(
                 typeFactory.createSqlType(ret), true);
       } else {
         assert opBinding.getOperandCount() == 2;
         return opBinding.getCursorOperand(0);
       }
     }

Here is the call graph for this function:

static boolean com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.isPointerType ( final ExtensionFunction.ExtArgumentType type )

inlinestaticprivate

Definition at line 1777 of file MapDSqlOperatorTable.java.

References run_benchmark_import.type.

Referenced by com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlSignature().

                                                                                        {
       return type == ExtensionFunction.ExtArgumentType.PInt8
               || type == ExtensionFunction.ExtArgumentType.PInt16
               || type == ExtensionFunction.ExtArgumentType.PInt32
               || type == ExtensionFunction.ExtArgumentType.PInt64
               || type == ExtensionFunction.ExtArgumentType.PFloat
               || type == ExtensionFunction.ExtArgumentType.PDouble
               || type == ExtensionFunction.ExtArgumentType.PBool;
     }

Here is the caller graph for this function:

static java.util.List<SqlTypeFamily> com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlSignature ( final ExtensionFunction sig )

inlinestaticprivate

Definition at line 1754 of file MapDSqlOperatorTable.java.

References com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.getValueType(), com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.isPointerType(), com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.isRowUdf, and com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlTypeName().

Referenced by com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.ExtFunction().

                                          {
       java.util.List<SqlTypeFamily> sql_sig = new java.util.ArrayList<SqlTypeFamily>();
       boolean isRowUdf = sig.isRowUdf();
       for (int arg_idx = 0; arg_idx < sig.getArgs().size(); ++arg_idx) {
         final ExtensionFunction.ExtArgumentType arg_type = sig.getArgs().get(arg_idx);
         if (isRowUdf) {
           sql_sig.add(toSqlTypeName(arg_type).getFamily());
           if (isPointerType(arg_type)) {
             ++arg_idx;
           }
         } else {
           if (isPointerType(arg_type)) {
             /* TODO: eliminate using getValueType */
             sql_sig.add(toSqlTypeName(getValueType(arg_type)).getFamily());
           } else {
             sql_sig.add(toSqlTypeName(arg_type).getFamily());
           }
         }
       }
       return sql_sig;
     }

Here is the call graph for this function:

Here is the caller graph for this function:

static SqlTypeName com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlTypeName ( final ExtensionFunction.ExtArgumentType type )

inlinestaticprivate

Definition at line 1822 of file MapDSqlOperatorTable.java.

References ArrayBool, ArrayDouble, ArrayFloat, ArrayInt16, ArrayInt32, ArrayInt64, ArrayInt8, assert(), Bool, Cursor, Double, Int16, Int32, Int64, Int8, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, and run_benchmark_import.type.

Referenced by com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.ExtFunction(), and com.mapd.calcite.parser.MapDSqlOperatorTable.ExtFunction.toSqlSignature().

                                                           {
       switch (type) {
         case Bool:
           return SqlTypeName.BOOLEAN;
         case Int8:
           return SqlTypeName.TINYINT;
         case Int16:
           return SqlTypeName.SMALLINT;
         case Int32:
           return SqlTypeName.INTEGER;
         case Int64:
           return SqlTypeName.BIGINT;
         case Float:
           return SqlTypeName.FLOAT;
         case Double:
           return SqlTypeName.DOUBLE;
         case PInt8:
         case PInt16:
         case PInt32:
         case PInt64:
         case PFloat:
         case PDouble:
         case PBool:
         case ArrayInt8:
         case ArrayInt16:
         case ArrayInt32:
         case ArrayInt64:
         case ArrayFloat:
         case ArrayDouble:
         case ArrayBool:
           return SqlTypeName.ARRAY;
         case GeoPoint:
         case GeoLineString:
         case GeoPolygon:
         case GeoMultiPolygon:
           return SqlTypeName.GEOMETRY;
         case Cursor:
           return SqlTypeName.CURSOR;
       }
       MAPDLOGGER.error("toSqlTypeName: unknown type " + type);
       assert false;
       return null;
     }