Searched refs:parsePlan (Results 1 – 12 of 12) sorted by relevance
39 parser.parsePlan(sql)46 parser.parsePlan(query) match {61 val parsed = parser.parsePlan(sql)88 val parsed1 = parser.parsePlan(sql1)89 val parsed2 = parser.parsePlan(sql2)90 val parsed3 = parser.parsePlan(sql3)351 parser.parsePlan(query) match {373 parser.parsePlan(query) match {760 parser.parsePlan(777 ).map(parser.parsePlan)[all …]
42 parser.parsePlan(sql).collect {49 parser.parsePlan(sql)179 parser.parsePlan(190 parser.parsePlan(198 parser.parsePlan(206 parser.parsePlan(219 parser.parsePlan(sql)233 val plan = analyzer.execute(parser.parsePlan(501 parser.parsePlan(v1)507 val parsed = parser.parsePlan(sql)[all …]
133 def ast = spark.sessionState.sqlParser.parsePlan(query)
240 const auto& parsePlan = m_documents[url]; in nextDocumentToParse() local243 if (parsePlan.sequentialProcessingFlags() & ParseJob::RequiresSequentialProcessing in nextDocumentToParse()244 && parsePlan.priority() > bestRunningPriority) { in nextDocumentToParse()284 const DocumentParsePlan parsePlan = *parsePlanConstIt; in parseDocumentsInternal() local293 decorator = createParseJob(url, parsePlan); in parseDocumentsInternal()341 …ver::QObjectDecorator* createParseJob(const IndexedString& url, const DocumentParsePlan& parsePlan) in createParseJob() argument346 const auto& notifyWhenReady = parsePlan.notifyWhenReady(); in createParseJob()358 job->setParsePriority(parsePlan.priority()); in createParseJob()359 job->setMinimumFeatures(parsePlan.features()); in createParseJob()361 job->setSequentialProcessingFlags(parsePlan.sequentialProcessingFlags()); in createParseJob()
29 def parsePlan(sqlText: String): LogicalPlan method
53 override def parsePlan(sqlText: String): LogicalPlan = parse(sqlText) { parser =>
26 val e = intercept[ParseException](CatalystSqlParser.parsePlan(sql))
38 comparePlans(parsePlan(sqlCommand), plan)42 val e = intercept[ParseException](parsePlan(sqlCommand))
55 val normalized1 = normalizePlan(parser.parsePlan(sqlCommand))61 val e = intercept[ParseException](parser.parsePlan(sqlCommand))
470 this(sparkSession, sparkSession.sessionState.sqlParser.parsePlan(sql))
137 sparkSession.sessionState.sqlParser.parsePlan(viewText),
592 Dataset.ofRows(self, sessionState.sqlParser.parsePlan(sqlText))