File tree Expand file tree Collapse file tree 1 file changed +9
-1
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis Expand file tree Collapse file tree 1 file changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,11 @@ object ResolveInlineTables extends Rule[LogicalPlan] {
3434 convert(table)
3535 }
3636
37- /** Validates that all inline table data are foldable expressions. */
37+ /**
38+ * Validates that all inline table data are foldable expressions.
39+ *
40+ * This is publicly visible for unit testing.
41+ */
3842 def validateInputFoldable (table : UnresolvedInlineTable ): Unit = {
3943 table.rows.foreach { row =>
4044 row.foreach { e =>
@@ -49,6 +53,8 @@ object ResolveInlineTables extends Rule[LogicalPlan] {
4953 * Validates the input data dimension:
5054 * 1. All rows have the same cardinality.
5155 * 2. The number of column aliases defined is consistent with the number of columns in data.
56+ *
57+ * This is publicly visible for unit testing.
5258 */
5359 def validateInputDimension (table : UnresolvedInlineTable ): Unit = {
5460 if (table.rows.nonEmpty) {
@@ -70,6 +76,8 @@ object ResolveInlineTables extends Rule[LogicalPlan] {
7076 * into a [[LocalRelation ]].
7177 *
7278 * This function attempts to coerce inputs into consistent types.
79+ *
80+ * This is publicly visible for unit testing.
7381 */
7482 def convert (table : UnresolvedInlineTable ): LocalRelation = {
7583 val numCols = table.rows.head.size
You can’t perform that action at this time.
0 commit comments