com.mapd.calcite.parser.HeavyDBSqlOperatorTable Class Reference

Inheritance diagram for com.mapd.calcite.parser.HeavyDBSqlOperatorTable:

Collaboration diagram for com.mapd.calcite.parser.HeavyDBSqlOperatorTable:

Classes
class	All
class	Any
class	ApproxCountDistinct
class	ApproxMedian
class	ApproxPercentile
class	ApproxQuantile
class	ArrayLength
class	Base64Decode
class	Base64Encode
class	CastToGeography
class	CharLength
class	convert_meters_to_pixel_height
class	convert_meters_to_pixel_width
class	CountIf
class	Dateadd
class	Datediff
class	Datepart
class	Datetime
class	DedupFunction
class	EncodeText
class	ExtFunction
class	ExtTableFunction
class	HeavyDB_Geo_PolyBoundsPtr
class	HeavyDB_Geo_PolyCoordsArray
class	HeavyDB_Geo_PolyPolyRingsArray
class	HeavyDB_Geo_PolyRenderGroup
class	HeavyDB_Geo_PolyRingSizesArray
class	is_point_in_view
class	is_point_size_in_view
class	KeyForString
class	LagInFrame
class	LastSample
class	LeadInFrame
class	LeftRightPad
class	LeftRightTrim
class	Length
class	Likely
class	LPad
class	LTrim
class	MapDAvg
class	Mode
class	MyUDFFunction
class	Now
class	nsTimestamp
class	NthValueInFrame
class	OffsetInFragment
class	PgDateTrunc
class	PgExtract
class	PgILike
class	PgUnnest
class	RampFunction
class	RegexpLike
class	RegexpMatch
class	RegexpReplace
class	RegexpSubstr
class	Repeat
class	Replace
class	Reverse
class	RPad
class	RTrim
class	Sample
class	SampleRatio
class	Sign
class	SplitPart
class	SqlArrayValueConstructorAllowingEmpty
class	ST_Approx_Overlaps
class	ST_Area
class	ST_Buffer
class	ST_Centroid
class	ST_ConcaveHull
class	ST_Contains
class	ST_ConvexHull
class	ST_DFullyWithin
class	ST_Difference
class	ST_Disjoint
class	ST_Distance
class	ST_DWithin
class	ST_EndPoint
class	ST_Equals
class	ST_GeogFromText
class	ST_GeomFromText
class	ST_Intersection
class	ST_Intersects
class	ST_IsEmpty
class	ST_IsValid
class	ST_Length
class	ST_MaxDistance
class	ST_NPoints
class	ST_NRings
class	ST_NumGeometries
class	ST_Overlaps
class	ST_Perimeter
class	ST_Point
class	ST_PointN
class	ST_SetSRID
class	ST_SRID
class	ST_StartPoint
class	ST_Transform
class	ST_Union
class	ST_Within
class	ST_X
class	ST_XMax
class	ST_XMin
class	ST_Y
class	ST_YMax
class	ST_YMin
class	SumIf
class	Truncate
class	TryCast
class	Unlikely
class	usTimestamp
class	WidthBucket

Public Member Functions
	HeavyDBSqlOperatorTable (SqlOperatorTable parentTable)
void	addOperator (SqlOperator op)
void	addUDF (final Map< String, ExtensionFunction > extSigs)

Static Public Attributes
static final SqlArrayValueConstructorAllowingEmpty	ARRAY_VALUE_CONSTRUCTOR
static final SqlFunction	TRY_CAST = new TryCast()

Static Package Functions
	[static initializer]

Static Package Attributes
static final Logger	HEAVYDBLOGGER

Static Private Member Functions
static String	dropSuffix (final String str)

Private Attributes
final ListSqlOperatorTable	listOpTab

Detailed Description

Definition at line 120 of file HeavyDBSqlOperatorTable.java.

Constructor & Destructor Documentation

com.mapd.calcite.parser.HeavyDBSqlOperatorTable.HeavyDBSqlOperatorTable ( SqlOperatorTable  parentTable )

inline

Definition at line 179 of file HeavyDBSqlOperatorTable.java.

References com.mapd.calcite.parser.HeavyDBSqlOperatorTable.listOpTab.

                                                               {
    super(ImmutableList.of(parentTable, new CaseInsensitiveListSqlOperatorTable()));
    listOpTab = (ListSqlOperatorTable) tableList.get(1);
  }

Member Function Documentation

com.mapd.calcite.parser.HeavyDBSqlOperatorTable.[static initializer] ( )

inlinestaticpackage

void com.mapd.calcite.parser.HeavyDBSqlOperatorTable.addOperator ( SqlOperator  op )

inline

Adds an operator to this table.

Parameters

op

Definition at line 189 of file HeavyDBSqlOperatorTable.java.

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

                                          {
    listOpTab.add(op);
  }

Here is the caller graph for this function:

void com.mapd.calcite.parser.HeavyDBSqlOperatorTable.addUDF ( final Map< String, ExtensionFunction >  extSigs )

inline

Definition at line 193 of file HeavyDBSqlOperatorTable.java.

References com.mapd.calcite.parser.HeavyDBSqlOperatorTable.addOperator(), convert_meters_to_pixel_height(), convert_meters_to_pixel_width(), com.mapd.calcite.parser.HeavyDBSqlOperatorTable.dropSuffix(), HeavyDB_Geo_PolyBoundsPtr(), HeavyDB_Geo_PolyCoordsArray(), HeavyDB_Geo_PolyPolyRingsArray(), HeavyDB_Geo_PolyRenderGroup(), HeavyDB_Geo_PolyRingSizesArray(), is_point_in_view(), is_point_size_in_view(), ST_XMax(), ST_XMin(), ST_YMax(), ST_YMin(), and Truncate().

                                                                   {
    // Don't use anonymous inner classes. They can't be instantiated
    // using reflection when we are deserializing from JSON.
    addOperator(new MyUDFFunction());
    addOperator(new PgUnnest());
    addOperator(new Any());
    addOperator(new All());
    addOperator(new Now());
    addOperator(new Datetime());
    addOperator(new PgExtract());
    addOperator(new Dateadd());
    addOperator(new Datediff());
    addOperator(new Datepart());
    addOperator(new PgDateTrunc());
    addOperator(new Length());
    addOperator(new CharLength());
    addOperator(new KeyForString());
    addOperator(new SampleRatio());
    addOperator(new WidthBucket());
    addOperator(new ArrayLength());
    addOperator(new PgILike());
    addOperator(new LTrim());
    addOperator(new RTrim());
    addOperator(new LPad());
    addOperator(new RPad());
    addOperator(new Replace());
    addOperator(new Reverse());
    addOperator(new Repeat());
    addOperator(new SplitPart());
    addOperator(new RegexpLike());
    addOperator(new RegexpReplace());
    addOperator(new RegexpSubstr());
    addOperator(new RegexpMatch());
    addOperator(new Base64Encode());
    addOperator(new Base64Decode());
    addOperator(new Likely());
    addOperator(new Unlikely());
    addOperator(new Sign());
    addOperator(new Truncate());
    addOperator(new TryCast());
    addOperator(new ST_IsEmpty());
    addOperator(new ST_IsValid());
    addOperator(new ST_Contains());
    addOperator(new ST_Equals());
    addOperator(new ST_Intersects());
    addOperator(new ST_Overlaps());
    addOperator(new ST_Approx_Overlaps());
    addOperator(new ST_Disjoint());
    addOperator(new ST_Within());
    addOperator(new ST_DWithin());
    addOperator(new ST_DFullyWithin());
    addOperator(new ST_Distance());
    addOperator(new ST_MaxDistance());
    addOperator(new ST_GeogFromText());
    addOperator(new ST_GeomFromText());
    addOperator(new ST_Transform());
    addOperator(new ST_X());
    addOperator(new ST_Y());
    addOperator(new ST_XMin());
    addOperator(new ST_XMax());
    addOperator(new ST_YMin());
    addOperator(new ST_YMax());
    addOperator(new ST_PointN());
    addOperator(new ST_StartPoint());
    addOperator(new ST_EndPoint());
    addOperator(new ST_Length());
    addOperator(new ST_Perimeter());
    addOperator(new ST_Area());
    addOperator(new ST_NPoints());
    addOperator(new ST_NRings());
    addOperator(new ST_NumGeometries());
    addOperator(new ST_SRID());
    addOperator(new ST_SetSRID());
    addOperator(new ST_Point());
    addOperator(new ST_Centroid());
    addOperator(new ST_Buffer());
    addOperator(new ST_ConcaveHull());
    addOperator(new ST_ConvexHull());
    addOperator(new ST_Intersection());
    addOperator(new ST_Union());
    addOperator(new ST_Difference());
    addOperator(new CastToGeography());
    addOperator(new EncodeText());
    addOperator(new OffsetInFragment());
    addOperator(new ApproxCountDistinct());
    addOperator(new ApproxMedian());
    addOperator(new ApproxPercentile());
    addOperator(new ApproxQuantile());
    addOperator(new MapDAvg());
    addOperator(new Mode());
    addOperator(new Sample());
    addOperator(new LastSample());

    // window functions on window frame
    addOperator(new NthValueInFrame());
    addOperator(new LagInFrame());
    addOperator(new LeadInFrame());

    // conditional window aggregate functions
    addOperator(new CountIf());
    addOperator(new SumIf());

    addOperator(new HeavyDB_Geo_PolyBoundsPtr());
    addOperator(new HeavyDB_Geo_PolyRenderGroup());
    addOperator(new HeavyDB_Geo_PolyCoordsArray());
    addOperator(new HeavyDB_Geo_PolyRingSizesArray());
    addOperator(new HeavyDB_Geo_PolyPolyRingsArray());
    addOperator(new convert_meters_to_pixel_width());
    addOperator(new convert_meters_to_pixel_height());
    addOperator(new is_point_in_view());
    addOperator(new is_point_size_in_view());
    addOperator(new usTimestamp());
    addOperator(new nsTimestamp());

    if (extSigs == null) {
      return;
    }
    HashSet<String> demangledNames = new HashSet<String>();
    for (Map.Entry<String, ExtensionFunction> extSig : extSigs.entrySet()) {
      final String demangledName = dropSuffix(extSig.getKey());
      final String demangledNameArity = extSig.getValue().isTableUdf()
              ? String.format("%s-%s-%s",
                      demangledName,
                      extSig.getValue().getArgs(),
                      extSig.getValue().getCursorFieldTypes())
              : String.format("%s-%d", demangledName, extSig.getValue().getArgs().size());
      if (demangledNames.contains(demangledNameArity)) {
        continue;
      }
      demangledNames.add(demangledNameArity);
      if (extSig.getValue().isRowUdf()) {
        addOperator(new ExtFunction(demangledName, extSig.getValue()));
      } else {
        addOperator(new ExtTableFunction(demangledName, extSig.getValue()));
      }
    }
  }

Here is the call graph for this function:

static String com.mapd.calcite.parser.HeavyDBSqlOperatorTable.dropSuffix ( final String  str )

inlinestaticprivate

Definition at line 331 of file HeavyDBSqlOperatorTable.java.

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

                                                     {
    int suffix_idx = str.indexOf("__");
    if (suffix_idx == -1) {
      return str;
    }
    assert suffix_idx > 0;
    return str.substring(0, suffix_idx);
  }

Here is the caller graph for this function:

Member Data Documentation

final SqlArrayValueConstructorAllowingEmpty com.mapd.calcite.parser.HeavyDBSqlOperatorTable.ARRAY_VALUE_CONSTRUCTOR

static

Initial value:

=
          new SqlArrayValueConstructorAllowingEmpty()

Definition at line 121 of file HeavyDBSqlOperatorTable.java.

Referenced by com.mapd.calcite.parser.HeavyDBParser.rewriteUpdateAsSelect().

final Logger com.mapd.calcite.parser.HeavyDBSqlOperatorTable.HEAVYDBLOGGER

staticpackage

Initial value:

=
          LoggerFactory.getLogger(HeavyDBSqlOperatorTable.class)

Definition at line 168 of file HeavyDBSqlOperatorTable.java.

final ListSqlOperatorTable com.mapd.calcite.parser.HeavyDBSqlOperatorTable.listOpTab

private

Mock operator table for testing purposes. Contains the standard SQL operator table, plus a list of operators.

Definition at line 176 of file HeavyDBSqlOperatorTable.java.

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

final SqlFunction com.mapd.calcite.parser.HeavyDBSqlOperatorTable.TRY_CAST = new TryCast()

static

Definition at line 123 of file HeavyDBSqlOperatorTable.java.

Referenced by org.apache.calcite.sql2rel.StandardConvertletTable.convertTryCast(), and org.apache.calcite.sql2rel.StandardConvertletTable.StandardConvertletTable().

---

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/calcite/parser/HeavyDBSqlOperatorTable.java