com.mapd.parser.server.ExtensionFunction Class Reference

Collaboration diagram for com.mapd.parser.server.ExtensionFunction:

Classes
enum	ExtArgumentType

Public Member Functions
Map< String, Comparable<?> >	getDefaultValues ()
Map< String, List < ExtArgumentType > >	getCursorFieldTypes ()
List< ExtArgumentType >	getArgs ()
List< ExtArgumentType >	getOuts ()
List< String >	getArgNames ()
List< String >	getPrettyArgNames ()
List< String >	getOutNames ()
ExtArgumentType	getRet ()
SqlTypeName	getSqlRet ()
Map< String, String >	getOptions ()
boolean	isRowUdf ()
boolean	isTableUdf ()
String	toJson (final String name)
final java.util.List < SqlTypeFamily >	toSqlSignature ()

Static Public Member Functions
static boolean	isPointerType (final ExtArgumentType type)
static boolean	isColumnArrayType (final ExtArgumentType type)
static boolean	isArrayType (final ExtArgumentType type)
static boolean	isColumnListArrayType (final ExtArgumentType type)
static boolean	isColumnType (final ExtArgumentType type)
static boolean	isColumnListType (final ExtArgumentType type)
static ExtArgumentType	getValueType (final ExtArgumentType type)
static ExtArgumentType	toSqlTypeName (final String type)
static RelDataType	toRelDataType (final ExtArgumentType type, RelDataTypeFactory factory)
static SqlTypeName	toSqlTypeName (final ExtArgumentType type)

Package Functions
	ExtensionFunction (final List< ExtArgumentType > args, final ExtArgumentType ret, final List< Map< String, String >> annotations)
	ExtensionFunction (final List< ExtArgumentType > args, final List< ExtArgumentType > outs, final List< String > names, final Map< String, String > options, final Map< String, List< ExtArgumentType >> cursor_field_types, final Map< String, java.lang.Comparable<?>> default_values)

Static Package Attributes
static final Logger	HEAVYDBLOGGER = LoggerFactory.getLogger(ExtensionFunction.class)

Static Private Member Functions
static String	typeName (final ExtArgumentType type)
static String	dq (final String str)

Private Attributes
final List< ExtArgumentType >	args
final List< ExtArgumentType >	outs
final List< String >	names
final ExtArgumentType	ret
final boolean	isRowUdf
final List< Map< String, String > >	annotations
final Map< String, String >	options
final Map< String, List < ExtArgumentType > >	cursor_field_types
final Map< String, Comparable<?> >	default_values

Detailed Description

Definition at line 37 of file ExtensionFunction.java.

Constructor & Destructor Documentation

com.mapd.parser.server.ExtensionFunction.ExtensionFunction ( final List< ExtArgumentType >  args, final ExtArgumentType  ret, final List< Map< String, String >>  annotations  )

inlinepackage

Definition at line 129 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.annotations, com.mapd.parser.server.ExtensionFunction.args, and com.mapd.parser.server.ExtensionFunction.ret.

                                                       {
    this.args = args;
    this.ret = ret;
    this.annotations = annotations;
    this.outs = null;
    this.names = null;
    this.isRowUdf = true;
    this.options = null;
    this.cursor_field_types = null;
    this.default_values = null;
  }

com.mapd.parser.server.ExtensionFunction.ExtensionFunction ( final List< ExtArgumentType >  args, final List< ExtArgumentType >  outs, final List< String >  names, final Map< String, String >  options, final Map< String, List< ExtArgumentType >>  cursor_field_types, final Map< String, java.lang.Comparable<?>>  default_values  )

inlinepackage

Definition at line 143 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.args, com.mapd.parser.server.ExtensionFunction.cursor_field_types, com.mapd.parser.server.ExtensionFunction.default_values, com.mapd.parser.server.ExtensionFunction.names, com.mapd.parser.server.ExtensionFunction.options, and com.mapd.parser.server.ExtensionFunction.outs.

                                                                     {
    this.args = args;
    this.ret = null;
    this.outs = outs;
    this.names = names;
    this.isRowUdf = false;
    this.annotations = null;
    this.options = options;
    this.cursor_field_types = cursor_field_types;
    this.default_values = default_values;
  }

Member Function Documentation

static String com.mapd.parser.server.ExtensionFunction.dq ( final String  str )

inlinestaticprivate

Definition at line 446 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.toJson().

                                             {
    return "\"" + str + "\"";
  }

Here is the caller graph for this function:

List<String> com.mapd.parser.server.ExtensionFunction.getArgNames ( )

inline

Definition at line 178 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.names.

                                    {
    if (this.names != null) {
      return this.names.subList(0, this.args.size());
    }
    return null;
  }

List<ExtArgumentType> com.mapd.parser.server.ExtensionFunction.getArgs ( )

inline

Definition at line 170 of file ExtensionFunction.java.

References run_benchmark_import.args.

                                         {
    return this.args;
  }

Map<String, List<ExtArgumentType> > com.mapd.parser.server.ExtensionFunction.getCursorFieldTypes ( )

inline

Definition at line 165 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.isTableUdf().

                                                                  {
    assert (this.isTableUdf());
    return this.cursor_field_types;
  }

Here is the call graph for this function:

Map<String, Comparable<?> > com.mapd.parser.server.ExtensionFunction.getDefaultValues ( )

inline

Definition at line 160 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.isTableUdf().

                                                       {
    assert (this.isTableUdf());
    return this.default_values;
  }

Here is the call graph for this function:

Map<String, String> com.mapd.parser.server.ExtensionFunction.getOptions ( )

inline

Definition at line 214 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.options.

                                          {
    if (this.options != null) {
      return new HashMap<String, String>(this.options);
    }
    return null;
  }

List<String> com.mapd.parser.server.ExtensionFunction.getOutNames ( )

inline

Definition at line 198 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.names.

                                    {
    if (this.names != null) {
      return this.names.subList(this.args.size(), this.names.size());
    }
    return null;
  }

List<ExtArgumentType> com.mapd.parser.server.ExtensionFunction.getOuts ( )

inline

Definition at line 174 of file ExtensionFunction.java.

                                         {
    return this.outs;
  }

List<String> com.mapd.parser.server.ExtensionFunction.getPrettyArgNames ( )

inline

Definition at line 185 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.names, and split().

                                          {
    if (this.names != null) {
      List<String> pretty_names = new ArrayList<String>();
      for (int arg_idx = 0; arg_idx < this.args.size(); ++arg_idx) {
        // Split on first array opening bracket and take everything preceding
        // For names without array brackets this will just be the name
        pretty_names.add(this.names.get(arg_idx).split("\\[", 2)[0]);
      }
      return pretty_names;
    }
    return null;
  }

Here is the call graph for this function:

ExtArgumentType com.mapd.parser.server.ExtensionFunction.getRet ( )

inline

Definition at line 205 of file ExtensionFunction.java.

                                  {
    return this.ret;
  }

SqlTypeName com.mapd.parser.server.ExtensionFunction.getSqlRet ( )

inline

Definition at line 209 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ret, and com.mapd.parser.server.ExtensionFunction.toSqlTypeName().

                                 {
    assert this.isRowUdf();
    return toSqlTypeName(this.ret);
  }

Here is the call graph for this function:

static ExtArgumentType com.mapd.parser.server.ExtensionFunction.getValueType ( final ExtArgumentType  type )

inlinestatic

Definition at line 552 of file ExtensionFunction.java.

References ArrayBool, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayBool, ArrayDouble, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayDouble, ArrayFloat, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayFloat, ArrayInt16, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt16, ArrayInt32, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt32, ArrayInt64, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt64, ArrayInt8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayTextEncodingDict, ArrayTextEncodingDict, ArrayTextEncodingNone, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayTextEncodingNone, Bool, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Bool, ColumnArrayBool, ColumnArrayDouble, ColumnArrayFloat, ColumnArrayInt16, ColumnArrayInt32, ColumnArrayInt64, ColumnArrayInt8, ColumnArrayTextEncodingDict, ColumnArrayTextEncodingNone, ColumnBool, ColumnDouble, ColumnFloat, ColumnGeoLineString, ColumnGeoMultiLineString, ColumnGeoMultiPoint, ColumnGeoMultiPolygon, ColumnGeoPoint, ColumnGeoPolygon, ColumnInt16, ColumnInt32, ColumnInt64, ColumnInt8, ColumnListArrayBool, ColumnListArrayDouble, ColumnListArrayFloat, ColumnListArrayInt16, ColumnListArrayInt32, ColumnListArrayInt64, ColumnListArrayInt8, ColumnListArrayTextEncodingDict, ColumnListArrayTextEncodingNone, ColumnListBool, ColumnListDouble, ColumnListFloat, ColumnListGeoLineString, ColumnListGeoMultiLineString, ColumnListGeoMultiPoint, ColumnListGeoMultiPolygon, ColumnListGeoPoint, ColumnListGeoPolygon, ColumnListInt16, ColumnListInt32, ColumnListInt64, ColumnListInt8, ColumnListTextEncodingDict, ColumnListTextEncodingNone, ColumnTextEncodingDict, ColumnTextEncodingNone, ColumnTimestamp, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Double, Double, Float, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Float, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoLineString, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoMultiLineString, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoMultiPoint, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoMultiPolygon, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoPoint, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoPolygon, Int16, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int16, Int32, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int32, Int64, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int64, Int8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int8, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.TextEncodingDict, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.TextEncodingNone, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Timestamp, and run_benchmark_import.type.

Referenced by com.mapd.calcite.parser.HeavyDBSqlOperatorTable.ExtFunction.inferReturnType(), and com.mapd.parser.server.ExtensionFunction.toRelDataType().

                                                                         {
    switch (type) {
      case PInt8:
      case ArrayInt8:
      case ColumnInt8:
      case ColumnListInt8:
      case Int8:
        return ExtArgumentType.Int8;
      case ArrayInt16:
      case PInt16:
      case ColumnInt16:
      case ColumnListInt16:
      case Int16:
        return ExtArgumentType.Int16;
      case ArrayInt32:
      case PInt32:
      case ColumnInt32:
      case ColumnListInt32:
      case Int32:
        return ExtArgumentType.Int32;
      case ArrayInt64:
      case PInt64:
      case ColumnInt64:
      case ColumnListInt64:
      case Int64:
        return ExtArgumentType.Int64;
      case ArrayFloat:
      case PFloat:
      case ColumnFloat:
      case ColumnListFloat:
      case Float:
        return ExtArgumentType.Float;
      case ArrayDouble:
      case PDouble:
      case ColumnDouble:
      case ColumnListDouble:
      case Double:
        return ExtArgumentType.Double;
      case ArrayBool:
      case PBool:
      case ColumnBool:
      case ColumnListBool:
      case Bool:
        return ExtArgumentType.Bool;
      case TextEncodingDict:
      case ColumnTextEncodingDict:
      case ColumnListTextEncodingDict:
      case ArrayTextEncodingDict:
        return ExtArgumentType.TextEncodingDict;
      case ColumnArrayTextEncodingDict:
      case ColumnListArrayTextEncodingDict:
        return ExtArgumentType.ArrayTextEncodingDict;
      case ColumnTimestamp:
        return ExtArgumentType.Timestamp;
      case ColumnArrayInt8:
      case ColumnListArrayInt8:
        return ExtArgumentType.ArrayInt8;
      case ColumnArrayInt16:
      case ColumnListArrayInt16:
        return ExtArgumentType.ArrayInt16;
      case ColumnArrayInt32:
      case ColumnListArrayInt32:
        return ExtArgumentType.ArrayInt32;
      case ColumnArrayInt64:
      case ColumnListArrayInt64:
        return ExtArgumentType.ArrayInt64;
      case ColumnArrayFloat:
      case ColumnListArrayFloat:
        return ExtArgumentType.ArrayFloat;
      case ColumnArrayDouble:
      case ColumnListArrayDouble:
        return ExtArgumentType.ArrayDouble;
      case ColumnArrayBool:
      case ColumnListArrayBool:
        return ExtArgumentType.ArrayBool;
      case ColumnGeoPoint:
      case ColumnListGeoPoint:
        return ExtArgumentType.GeoPoint;
      case ColumnGeoLineString:
      case ColumnListGeoLineString:
        return ExtArgumentType.GeoLineString;
      case ColumnGeoPolygon:
      case ColumnListGeoPolygon:
        return ExtArgumentType.GeoPolygon;
      case ColumnGeoMultiPoint:
      case ColumnListGeoMultiPoint:
        return ExtArgumentType.GeoMultiPoint;
      case ColumnGeoMultiLineString:
      case ColumnListGeoMultiLineString:
        return ExtArgumentType.GeoMultiLineString;
      case ColumnGeoMultiPolygon:
      case ColumnListGeoMultiPolygon:
        return ExtArgumentType.GeoMultiPolygon;
      case ArrayTextEncodingNone:
      case ColumnTextEncodingNone:
      case ColumnListTextEncodingNone:
        return ExtArgumentType.TextEncodingNone;
      case ColumnArrayTextEncodingNone:
      case ColumnListArrayTextEncodingNone:
        return ExtArgumentType.ArrayTextEncodingNone;
    }
    HEAVYDBLOGGER.error("getValueType: no value for type " + type);
    assert false;
    return null;
  }

Here is the caller graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isArrayType ( final ExtArgumentType  type )

inlinestatic

Definition at line 497 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayTextEncodingNone.

Referenced by com.mapd.calcite.parser.HeavyDBSqlOperatorTable.ExtFunction.inferReturnType().

                                                                {
    return type == ExtArgumentType.ArrayInt8 || type == ExtArgumentType.ArrayInt16
            || type == ExtArgumentType.ArrayInt32 || type == ExtArgumentType.ArrayInt64
            || type == ExtArgumentType.ArrayFloat || type == ExtArgumentType.ArrayDouble
            || type == ExtArgumentType.ArrayBool
            || type == ExtArgumentType.ArrayTextEncodingDict
            || type == ExtArgumentType.ArrayTextEncodingNone;
  }

Here is the caller graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isColumnArrayType ( final ExtArgumentType  type )

inlinestatic

Definition at line 485 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ColumnArrayTextEncodingNone.

Referenced by com.mapd.calcite.parser.HeavyDBSqlOperatorTable.ExtTableFunction.getRowTypeInference(), and com.mapd.parser.server.ExtensionFunction.isColumnType().

                                                                      {
    return type == ExtArgumentType.ColumnArrayInt8
            || type == ExtArgumentType.ColumnArrayInt16
            || type == ExtArgumentType.ColumnArrayInt32
            || type == ExtArgumentType.ColumnArrayInt64
            || type == ExtArgumentType.ColumnArrayFloat
            || type == ExtArgumentType.ColumnArrayDouble
            || type == ExtArgumentType.ColumnArrayBool
            || type == ExtArgumentType.ColumnArrayTextEncodingDict
            || type == ExtArgumentType.ColumnArrayTextEncodingNone;
  }

Here is the caller graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isColumnListArrayType ( final ExtArgumentType  type )

inlinestatic

Definition at line 506 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ColumnListArrayTextEncodingNone.

Referenced by com.mapd.parser.server.ExtensionFunction.isColumnListType().

                                                                          {
    return type == ExtArgumentType.ColumnListArrayInt8
            || type == ExtArgumentType.ColumnListArrayInt16
            || type == ExtArgumentType.ColumnListArrayInt32
            || type == ExtArgumentType.ColumnListArrayInt64
            || type == ExtArgumentType.ColumnListArrayFloat
            || type == ExtArgumentType.ColumnListArrayDouble
            || type == ExtArgumentType.ColumnListArrayBool
            || type == ExtArgumentType.ColumnListArrayTextEncodingDict
            || type == ExtArgumentType.ColumnListArrayTextEncodingNone;
  }

Here is the caller graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isColumnListType ( final ExtArgumentType  type )

inlinestatic

Definition at line 534 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ColumnListGeoMultiPolygon, and com.mapd.parser.server.ExtensionFunction.isColumnListArrayType().

                                                                     {
    return type == ExtArgumentType.ColumnListInt8
            || type == ExtArgumentType.ColumnListInt16
            || type == ExtArgumentType.ColumnListInt32
            || type == ExtArgumentType.ColumnListInt64
            || type == ExtArgumentType.ColumnListFloat
            || type == ExtArgumentType.ColumnListDouble
            || type == ExtArgumentType.ColumnListBool
            || type == ExtArgumentType.ColumnListTextEncodingDict
            || type == ExtArgumentType.ColumnListTextEncodingNone
            || isColumnListArrayType(type) || type == ExtArgumentType.ColumnListGeoPoint
            || type == ExtArgumentType.ColumnListGeoLineString
            || type == ExtArgumentType.ColumnListGeoPolygon
            || type == ExtArgumentType.ColumnListGeoMultiPoint
            || type == ExtArgumentType.ColumnListGeoMultiLineString
            || type == ExtArgumentType.ColumnListGeoMultiPolygon;
  }

Here is the call graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isColumnType ( final ExtArgumentType  type )

inlinestatic

Definition at line 518 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ColumnGeoMultiPolygon, and com.mapd.parser.server.ExtensionFunction.isColumnArrayType().

                                                                 {
    return type == ExtArgumentType.ColumnInt8 || type == ExtArgumentType.ColumnInt16
            || type == ExtArgumentType.ColumnInt32 || type == ExtArgumentType.ColumnInt64
            || type == ExtArgumentType.ColumnFloat || type == ExtArgumentType.ColumnDouble
            || type == ExtArgumentType.ColumnBool
            || type == ExtArgumentType.ColumnTextEncodingDict
            || type == ExtArgumentType.ColumnTextEncodingNone
            || type == ExtArgumentType.ColumnTimestamp || isColumnArrayType(type)
            || type == ExtArgumentType.ColumnGeoPoint
            || type == ExtArgumentType.ColumnGeoLineString
            || type == ExtArgumentType.ColumnGeoPolygon
            || type == ExtArgumentType.ColumnGeoMultiPoint
            || type == ExtArgumentType.ColumnGeoMultiLineString
            || type == ExtArgumentType.ColumnGeoMultiPolygon;
  }

Here is the call graph for this function:

static boolean com.mapd.parser.server.ExtensionFunction.isPointerType ( final ExtArgumentType  type )

inlinestatic

Definition at line 478 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PBool.

Referenced by com.mapd.parser.server.ExtensionFunction.toSqlSignature().

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

Here is the caller graph for this function:

boolean com.mapd.parser.server.ExtensionFunction.isRowUdf ( )

inline

Definition at line 221 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.toJson(), and com.mapd.parser.server.ExtensionFunction.toSqlSignature().

                            {
    return this.isRowUdf;
  }

Here is the caller graph for this function:

boolean com.mapd.parser.server.ExtensionFunction.isTableUdf ( )

inline

Definition at line 225 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.getCursorFieldTypes(), and com.mapd.parser.server.ExtensionFunction.getDefaultValues().

                              {
    return !this.isRowUdf();
  }

Here is the caller graph for this function:

String com.mapd.parser.server.ExtensionFunction.toJson ( final String  name )

inline

Definition at line 229 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.annotations, File_Namespace.append(), com.mapd.parser.server.ExtensionFunction.args, com.mapd.parser.server.ExtensionFunction.dq(), com.mapd.parser.server.ExtensionFunction.isRowUdf(), setup.name, com.mapd.parser.server.ExtensionFunction.outs, com.mapd.parser.server.ExtensionFunction.ret, and com.mapd.parser.server.ExtensionFunction.typeName().

                                          {
    HEAVYDBLOGGER.debug("Extensionfunction::toJson: " + name);
    StringBuilder json_cons = new StringBuilder();
    json_cons.append("{");
    json_cons.append("\"name\":").append(dq(name)).append(",");
    if (isRowUdf) {
      json_cons.append("\"annotations\":");
      List<String> anns = new ArrayList<String>();
      for (final Map<String, String> m : this.annotations) {
        List<String> lst = new ArrayList<String>();
        for (final Map.Entry<String, String> kv : m.entrySet()) {
          lst.add("\"" + kv.getKey() + "\":\"" + kv.getValue() + "\"");
        }
        anns.add("{" + ExtensionFunctionSignatureParser.join(lst, ",") + "}");
      }
      json_cons.append("[" + ExtensionFunctionSignatureParser.join(anns, ",") + "],");
      json_cons.append("\"ret\":").append(dq(typeName(ret))).append(",");
    } else {
      json_cons.append("\"outs\":");
      json_cons.append("[");
      List<String> param_list = new ArrayList<String>();
      for (final ExtArgumentType out : outs) {
        param_list.add(dq(typeName(out)));
      }
      json_cons.append(ExtensionFunctionSignatureParser.join(param_list, ","));
      json_cons.append("],");
    }
    json_cons.append("\"args\":");
    json_cons.append("[");
    List<String> param_list = new ArrayList<String>();
    for (final ExtArgumentType arg : args) {
      param_list.add(dq(typeName(arg)));
    }
    json_cons.append(ExtensionFunctionSignatureParser.join(param_list, ","));
    json_cons.append("]");
    json_cons.append("}");
    return json_cons.toString();
  }

Here is the call graph for this function:

static RelDataType com.mapd.parser.server.ExtensionFunction.toRelDataType ( final ExtArgumentType  type, RelDataTypeFactory  factory  )

inlinestatic

Definition at line 662 of file ExtensionFunction.java.

References ArrayBool, ArrayDouble, ArrayFloat, ArrayInt16, ArrayInt32, ArrayInt64, ArrayInt8, ArrayTextEncodingDict, ArrayTextEncodingNone, ColumnArrayBool, ColumnArrayDouble, ColumnArrayFloat, ColumnArrayInt16, ColumnArrayInt32, ColumnArrayInt64, ColumnArrayInt8, ColumnArrayTextEncodingDict, ColumnArrayTextEncodingNone, ColumnTimestamp, com.mapd.parser.server.ExtensionFunction.getValueType(), and com.mapd.parser.server.ExtensionFunction.toSqlTypeName().

                                                                  {
    switch (type) {
      case ArrayInt8:
      case ArrayInt16:
      case ArrayInt32:
      case ArrayInt64:
      case ArrayFloat:
      case ArrayDouble:
      case ArrayBool:
      case ArrayTextEncodingDict:
      case ArrayTextEncodingNone:
        return factory.createTypeWithNullability(
                factory.createArrayType(toRelDataType(getValueType(type), factory), -1),
                true);
      case ColumnArrayInt8:
      case ColumnArrayInt16:
      case ColumnArrayInt32:
      case ColumnArrayInt64:
      case ColumnArrayFloat:
      case ColumnArrayDouble:
      case ColumnArrayBool:
      case ColumnArrayTextEncodingDict:
      case ColumnArrayTextEncodingNone:
        return factory.createTypeWithNullability(
                factory.createArrayType(
                        toRelDataType(getValueType(getValueType(type)), factory), -1),
                true);
      case Timestamp:
        return factory.createTypeWithNullability(
                factory.createSqlType(toSqlTypeName(type), 9), true);
      case ColumnTimestamp:
        return factory.createTypeWithNullability(
                toRelDataType(getValueType(type), factory), true);
      case YearMonthTimeInterval:
        SqlIntervalQualifier yearMonthIntervalQualifier =
                new SqlIntervalQualifier(TimeUnit.MONTH, null, SqlParserPos.ZERO);
        return factory.createSqlIntervalType(yearMonthIntervalQualifier);
      case DayTimeInterval:
        SqlIntervalQualifier dayTimeIntervalQualifier =
                new SqlIntervalQualifier(TimeUnit.DAY, null, SqlParserPos.ZERO);
        return factory.createSqlIntervalType(dayTimeIntervalQualifier);
      default:
        return factory.createTypeWithNullability(
                factory.createSqlType(toSqlTypeName(type)), true);
    }
  }

Here is the call graph for this function:

final java.util.List<SqlTypeFamily> com.mapd.parser.server.ExtensionFunction.toSqlSignature ( )

inline

Definition at line 461 of file ExtensionFunction.java.

References com.mapd.parser.server.ExtensionFunction.isPointerType(), com.mapd.parser.server.ExtensionFunction.isRowUdf(), and com.mapd.parser.server.ExtensionFunction.toSqlTypeName().

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

                                                              {
    java.util.List<SqlTypeFamily> sql_sig = new java.util.ArrayList<SqlTypeFamily>();
    boolean isRowUdf = this.isRowUdf();
    for (int arg_idx = 0; arg_idx < this.getArgs().size(); ++arg_idx) {
      final ExtArgumentType arg_type = this.getArgs().get(arg_idx);
      if (isRowUdf) {
        sql_sig.add(toSqlTypeName(arg_type).getFamily());
        if (isPointerType(arg_type)) {
          ++arg_idx;
        }
      } 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 ExtArgumentType com.mapd.parser.server.ExtensionFunction.toSqlTypeName ( final String  type )

inlinestatic

Definition at line 658 of file ExtensionFunction.java.

References run_benchmark_import.type.

Referenced by com.mapd.parser.server.ExtensionFunction.getSqlRet(), com.mapd.parser.server.ExtensionFunction.toRelDataType(), and com.mapd.parser.server.ExtensionFunction.toSqlSignature().

                                                                 {
    return ExtArgumentType.valueOf(type);
  }

Here is the caller graph for this function:

static SqlTypeName com.mapd.parser.server.ExtensionFunction.toSqlTypeName ( final ExtArgumentType  type )

inlinestatic

Definition at line 710 of file ExtensionFunction.java.

References ArrayBool, ArrayDouble, ArrayFloat, ArrayInt16, ArrayInt32, ArrayInt64, ArrayInt8, ArrayTextEncodingDict, ArrayTextEncodingNone, Bool, ColumnArrayBool, ColumnArrayDouble, ColumnArrayFloat, ColumnArrayInt16, ColumnArrayInt32, ColumnArrayInt64, ColumnArrayInt8, ColumnArrayTextEncodingDict, ColumnArrayTextEncodingNone, ColumnBool, ColumnDouble, ColumnFloat, ColumnGeoLineString, ColumnGeoMultiLineString, ColumnGeoMultiPoint, ColumnGeoMultiPolygon, ColumnGeoPoint, ColumnGeoPolygon, ColumnInt16, ColumnInt32, ColumnInt64, ColumnInt8, ColumnListArrayBool, ColumnListArrayDouble, ColumnListArrayFloat, ColumnListArrayInt16, ColumnListArrayInt32, ColumnListArrayInt64, ColumnListArrayInt8, ColumnListArrayTextEncodingDict, ColumnListArrayTextEncodingNone, ColumnListBool, ColumnListDouble, ColumnListFloat, ColumnListGeoLineString, ColumnListGeoMultiLineString, ColumnListGeoMultiPoint, ColumnListGeoMultiPolygon, ColumnListGeoPoint, ColumnListGeoPolygon, ColumnListInt16, ColumnListInt32, ColumnListInt64, ColumnListInt8, ColumnListTextEncodingDict, ColumnListTextEncodingNone, ColumnTextEncodingDict, ColumnTextEncodingNone, ColumnTimestamp, Cursor, Double, Float, Int16, Int32, Int64, Int8, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, and Void.

                                                                      {
    switch (type) {
      // Column types are mapped to their underlying type for CURSOR typechecking
      case Bool:
      case ColumnBool:
        return SqlTypeName.BOOLEAN;
      case ColumnInt8:
      case Int8:
        return SqlTypeName.TINYINT;
      case ColumnInt16:
      case Int16:
        return SqlTypeName.SMALLINT;
      case Int32:
      case ColumnInt32:
        return SqlTypeName.INTEGER;
      case Int64:
      case ColumnInt64:
        return SqlTypeName.BIGINT;
      case Float:
      case ColumnFloat:
        return SqlTypeName.FLOAT;
      case Double:
      case ColumnDouble:
        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:
      case ArrayTextEncodingDict:
      case ArrayTextEncodingNone:
        return SqlTypeName.ARRAY;
      case ColumnArrayInt8:
      case ColumnArrayInt16:
      case ColumnArrayInt32:
      case ColumnArrayInt64:
      case ColumnArrayFloat:
      case ColumnArrayDouble:
      case ColumnArrayBool:
      case ColumnArrayTextEncodingDict:
      case ColumnArrayTextEncodingNone:
        return SqlTypeName.ARRAY;
      case GeoPoint:
      case GeoMultiPoint:
      case GeoLineString:
      case GeoMultiLineString:
      case GeoPolygon:
      case GeoMultiPolygon:
      case ColumnGeoPoint:
      case ColumnGeoLineString:
      case ColumnGeoPolygon:
      case ColumnGeoMultiPoint:
      case ColumnGeoMultiLineString:
      case ColumnGeoMultiPolygon:
        return SqlTypeName.GEOMETRY;
      case Cursor:
        return SqlTypeName.CURSOR;
      case TextEncodingNone:
      case TextEncodingDict:
      case ColumnTextEncodingDict:
      case ColumnTextEncodingNone:
        return SqlTypeName.VARCHAR;
      case Timestamp:
      case ColumnTimestamp:
        return SqlTypeName.TIMESTAMP;
      case ColumnListInt8:
      case ColumnListInt16:
      case ColumnListInt32:
      case ColumnListInt64:
      case ColumnListFloat:
      case ColumnListDouble:
      case ColumnListBool:
      case ColumnListArrayInt8:
      case ColumnListArrayInt16:
      case ColumnListArrayInt32:
      case ColumnListArrayInt64:
      case ColumnListArrayFloat:
      case ColumnListArrayDouble:
      case ColumnListArrayBool:
      case ColumnListArrayTextEncodingDict:
      case ColumnListTextEncodingDict:
      case ColumnListGeoPoint:
      case ColumnListGeoLineString:
      case ColumnListGeoPolygon:
      case ColumnListGeoMultiPoint:
      case ColumnListGeoMultiLineString:
      case ColumnListGeoMultiPolygon:
      case ColumnListTextEncodingNone:
      case ColumnListArrayTextEncodingNone:
        return SqlTypeName.COLUMN_LIST;
      case DayTimeInterval:
        return SqlTypeName.INTERVAL_DAY_HOUR;
      case YearMonthTimeInterval:
        return SqlTypeName.INTERVAL_YEAR_MONTH;
      case Void:
        // some extension functions return void. these functions should be defined in
        // HeavyDBSqlOperatorTable and never have their definition set from the AST file
        return null;
    }
    Set<SqlTypeName> allSqlTypeNames = EnumSet.allOf(SqlTypeName.class);
    HEAVYDBLOGGER.error("toSqlTypeName: unknown type " + type + " to be mapped to {"
            + allSqlTypeNames + "}");
    assert false;
    return null;
  }

static String com.mapd.parser.server.ExtensionFunction.typeName ( final ExtArgumentType  type )

inlinestaticprivate

Definition at line 268 of file ExtensionFunction.java.

References ArrayBool, ArrayDouble, ArrayFloat, ArrayInt16, ArrayInt32, ArrayInt64, ArrayInt8, ArrayTextEncodingDict, ArrayTextEncodingNone, Bool, ColumnArrayBool, ColumnArrayDouble, ColumnArrayFloat, ColumnArrayInt16, ColumnArrayInt32, ColumnArrayInt64, ColumnArrayInt8, ColumnArrayTextEncodingDict, ColumnArrayTextEncodingNone, ColumnBool, ColumnDouble, ColumnFloat, ColumnGeoLineString, ColumnGeoMultiLineString, ColumnGeoMultiPoint, ColumnGeoMultiPolygon, ColumnGeoPoint, ColumnGeoPolygon, ColumnInt16, ColumnInt32, ColumnInt64, ColumnInt8, ColumnListArrayBool, ColumnListArrayDouble, ColumnListArrayFloat, ColumnListArrayInt16, ColumnListArrayInt32, ColumnListArrayInt64, ColumnListArrayInt8, ColumnListArrayTextEncodingDict, ColumnListArrayTextEncodingNone, ColumnListBool, ColumnListDouble, ColumnListFloat, ColumnListGeoLineString, ColumnListGeoMultiLineString, ColumnListGeoMultiPoint, ColumnListGeoMultiPolygon, ColumnListGeoPoint, ColumnListGeoPolygon, ColumnListInt16, ColumnListInt32, ColumnListInt64, ColumnListInt8, ColumnListTextEncodingDict, ColumnListTextEncodingNone, ColumnTextEncodingDict, ColumnTextEncodingNone, ColumnTimestamp, Cursor, Double, Float, Int16, Int32, Int64, Int8, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, and Void.

Referenced by com.mapd.parser.server.ExtensionFunction.toJson().

                                                             {
    switch (type) {
      case Bool:
        return "i1";
      case Int8:
        return "i8";
      case Int16:
        return "i16";
      case Int32:
        return "i32";
      case Int64:
        return "i64";
      case Float:
        return "float";
      case Double:
        return "double";
      case Void:
        return "void";
      case PInt8:
        return "i8*";
      case PInt16:
        return "i16*";
      case PInt32:
        return "i32*";
      case PInt64:
        return "i64*";
      case PFloat:
        return "float*";
      case PDouble:
        return "double*";
      case PBool:
        return "i1*";
      case ArrayInt8:
        return "Array<i8>";
      case ArrayInt16:
        return "Array<i16>";
      case ArrayInt32:
        return "Array<i32>";
      case ArrayInt64:
        return "Array<i64>";
      case ArrayFloat:
        return "Array<float>";
      case ArrayDouble:
        return "Array<double>";
      case ArrayBool:
        return "Array<bool>";
      case ArrayTextEncodingDict:
        return "Array<TextEncodingDict>";
      case ColumnInt8:
        return "Column<i8>";
      case ColumnInt16:
        return "Column<i16>";
      case ColumnInt32:
        return "Column<i32>";
      case ColumnInt64:
        return "Column<i64>";
      case ColumnFloat:
        return "Column<float>";
      case ColumnDouble:
        return "Column<double>";
      case ColumnBool:
        return "Column<bool>";
      case ColumnTextEncodingDict:
        return "Column<TextEncodingDict>";
      case ColumnTimestamp:
        return "Column<timestamp>";
      case GeoPoint:
        return "GeoPoint";
      case GeoMultiPoint:
        return "GeoMultiPoint";
      case Cursor:
        return "cursor";
      case GeoLineString:
        return "GeoLineString";
      case GeoMultiLineString:
        return "GeoMultiLineString";
      case GeoPolygon:
        return "GeoPolygon";
      case GeoMultiPolygon:
        return "GeoMultiPolygon";
      case Timestamp:
        return "timestamp";
      case TextEncodingNone:
        return "TextEncodingNone";
      case TextEncodingDict:
        return "TextEncodingDict";
      case ColumnListInt8:
        return "ColumnList<i8>";
      case ColumnListInt16:
        return "ColumnList<i16>";
      case ColumnListInt32:
        return "ColumnList<i32>";
      case ColumnListInt64:
        return "ColumnList<i64>";
      case ColumnListFloat:
        return "ColumnList<float>";
      case ColumnListDouble:
        return "ColumnList<double>";
      case ColumnListBool:
        return "ColumnList<bool>";
      case ColumnListTextEncodingDict:
        return "ColumnList<TextEncodingDict>";
      case ColumnArrayInt8:
        return "Column<Array<i8>>";
      case ColumnArrayInt16:
        return "Column<Array<i16>>";
      case ColumnArrayInt32:
        return "Column<Array<i32>>";
      case ColumnArrayInt64:
        return "Column<Array<i64>>";
      case ColumnArrayFloat:
        return "Column<Array<float>>";
      case ColumnArrayDouble:
        return "Column<Array<double>>";
      case ColumnArrayBool:
        return "Column<Array<bool>>";
      case ColumnArrayTextEncodingDict:
        return "Column<Array<TextEncodingDict>>";
      case ColumnListArrayInt8:
        return "ColumnList<Array<i8>>";
      case ColumnListArrayInt16:
        return "ColumnList<Array<i16>>";
      case ColumnListArrayInt32:
        return "ColumnList<Array<i32>>";
      case ColumnListArrayInt64:
        return "ColumnList<Array<i64>>";
      case ColumnListArrayFloat:
        return "ColumnList<Array<float>>";
      case ColumnListArrayDouble:
        return "ColumnList<Array<double>>";
      case ColumnListArrayBool:
        return "ColumnList<Array<bool>>";
      case ColumnListArrayTextEncodingDict:
        return "ColumnList<Array<TextEncodingDict>>";
      case DayTimeInterval:
        return "DayTimeInterval";
      case YearMonthTimeInterval:
        return "YearMonthTimeInterval";
      case ColumnGeoPoint:
        return "Column<GeoPoint>";
      case ColumnGeoLineString:
        return "Column<GeoLineString>";
      case ColumnGeoPolygon:
        return "Column<GeoPolygon>";
      case ColumnGeoMultiPoint:
        return "Column<GeoMultiPoint>";
      case ColumnGeoMultiLineString:
        return "Column<GeoMultiLineString>";
      case ColumnGeoMultiPolygon:
        return "Column<GeoMultiPolygon>";
      case ColumnListGeoPoint:
        return "ColumnList<GeoPoint>";
      case ColumnListGeoLineString:
        return "ColumnList<GeoLineString>";
      case ColumnListGeoPolygon:
        return "ColumnList<GeoPolygon>";
      case ColumnListGeoMultiPoint:
        return "ColumnList<GeoMultiPoint>";
      case ColumnListGeoMultiLineString:
        return "ColumnList<GeoMultiLineString>";
      case ColumnListGeoMultiPolygon:
        return "ColumnList<GeoMultiPolygon>";
      case ArrayTextEncodingNone:
        return "Array<TextEncodingNone>";
      case ColumnTextEncodingNone:
        return "Column<TextEncodingNone>";
      case ColumnListTextEncodingNone:
        return "ColumnList<TextEncodingNone>";
      case ColumnArrayTextEncodingNone:
        return "Column<Array<TextEncodingNone>>";
      case ColumnListArrayTextEncodingNone:
        return "ColumnList<Array<TextEncodingNone>>";
    }
    HEAVYDBLOGGER.info("Extensionfunction::typeName: unknown type=`" + type + "`");
    assert false;
    return null;
  }

Here is the caller graph for this function:

Member Data Documentation

final List<Map<String, String> > com.mapd.parser.server.ExtensionFunction.annotations

private

Definition at line 455 of file ExtensionFunction.java.

Referenced by TableFunctionsFactory_node.UdtfNode.__iter__(), TableFunctionsFactory_node.ArgNode.__iter__(), TableFunctionsFactory_declbracket.Declaration.__repr__(), TableFunctionsFactory_declbracket.Declaration.__str__(), TableFunctionsFactory_declbracket.Declaration.apply_column(), TableFunctionsFactory_declbracket.Declaration.apply_namespace(), com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), TableFunctionsFactory_declbracket.Declaration.format_cpp_type(), TableFunctionsFactory_node.ArgNode.get_annotation(), heavydb.extension_functions.ttypes.TUserDefinedFunction.read(), heavydb.extension_functions.ttypes.TUserDefinedTableFunction.read(), TableFunctionsFactory_node.ArgNode.set_annotation(), com.mapd.parser.server.CalciteServerHandler.toExtensionFunction(), com.mapd.parser.server.ExtensionFunction.toJson(), heavydb.extension_functions.ttypes.TUserDefinedFunction.write(), and heavydb.extension_functions.ttypes.TUserDefinedTableFunction.write().

final List<ExtArgumentType> com.mapd.parser.server.ExtensionFunction.args

private

Definition at line 450 of file ExtensionFunction.java.

Referenced by TableFunctionsFactory_declbracket.Bracket.__repr__(), TableFunctionsFactory_declbracket.Bracket.__str__(), TableFunctionsFactory_declbracket.Bracket.apply_namespace(), com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), TableFunctionsFactory_declbracket.Bracket.format_sizer(), TableFunctionsFactory_declbracket.Bracket.normalize(), com.mapd.parser.server.ExtensionFunction.toJson(), and TableFunctionsFactory_declbracket.Bracket.tostring().

final Map<String, List<ExtArgumentType> > com.mapd.parser.server.ExtensionFunction.cursor_field_types

private

Definition at line 458 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction().

final Map<String, Comparable<?> > com.mapd.parser.server.ExtensionFunction.default_values

private

Definition at line 459 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction().

final Logger com.mapd.parser.server.ExtensionFunction.HEAVYDBLOGGER = LoggerFactory.getLogger(ExtensionFunction.class)

staticpackage

Definition at line 38 of file ExtensionFunction.java.

final boolean com.mapd.parser.server.ExtensionFunction.isRowUdf

private

Definition at line 454 of file ExtensionFunction.java.

final List<String> com.mapd.parser.server.ExtensionFunction.names

private

Definition at line 452 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), com.mapd.parser.server.ExtensionFunction.getArgNames(), com.mapd.parser.server.ExtensionFunction.getOutNames(), and com.mapd.parser.server.ExtensionFunction.getPrettyArgNames().

final Map<String, String> com.mapd.parser.server.ExtensionFunction.options

private

Definition at line 456 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), and com.mapd.parser.server.ExtensionFunction.getOptions().

final List<ExtArgumentType> com.mapd.parser.server.ExtensionFunction.outs

private

Definition at line 451 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), and com.mapd.parser.server.ExtensionFunction.toJson().

final ExtArgumentType com.mapd.parser.server.ExtensionFunction.ret

private

Definition at line 453 of file ExtensionFunction.java.

Referenced by com.mapd.parser.server.ExtensionFunction.ExtensionFunction(), com.mapd.parser.server.ExtensionFunction.getSqlRet(), and com.mapd.parser.server.ExtensionFunction.toJson().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/com/mapd/parser/server/ExtensionFunction.java