This is an automated email from the ASF dual-hosted git repository.
wenchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 5fc44dabe50 [SPARK-42488][BUILD] Upgrade commons-crypto to 1.2.0
add 70a098c83da [SPARK-42398][SQL] Refine default column value DS v2
interface
No new revisions were added by this update.
Summary of changes:
.../sql/connect/ProtoToParsedPlanTestSuite.scala | 8 +-
.../spark/sql/jdbc/v2/V2JDBCNamespaceTest.scala | 3 +-
.../apache/spark/sql/connector/catalog/Column.java | 90 ++++++++++++++++++
.../sql/connector/catalog/ColumnDefaultValue.java | 84 +++++++++++++++++
.../sql/connector/catalog/StagingTableCatalog.java | 67 ++++++++++++--
.../apache/spark/sql/connector/catalog/Table.java | 11 +++
.../spark/sql/connector/catalog/TableCatalog.java | 23 ++++-
.../spark/sql/connector/catalog/TableChange.java | 20 ++--
.../spark/sql/catalyst/analysis/Analyzer.scala | 4 +-
.../sql/catalyst/analysis/v2ResolutionPlans.scala | 2 +-
.../sql/catalyst/plans/logical/statements.scala | 13 +++
.../plans/logical/v2AlterTableCommands.scala | 4 +-
.../catalyst/util/ResolveDefaultColumnsUtil.scala | 30 ++++--
.../sql/connector/catalog/CatalogV2Implicits.scala | 7 ++
.../sql/connector/catalog/CatalogV2Util.scala | 89 +++++++++++++++++-
.../connector/write/RowLevelOperationTable.scala | 3 +-
.../datasources/v2/DataSourceV2Relation.scala | 3 +-
...pressionWithToString.scala => ColumnImpl.scala} | 15 ++-
.../internal/connector/SimpleTableProvider.scala | 3 +-
.../spark/sql/connector/catalog/CatalogSuite.scala | 103 +++++++++++----------
.../sql/connector/catalog/CatalogV2UtilSuite.scala | 4 +-
.../connector/catalog/InMemoryTableCatalog.scala | 10 ++
.../SupportsAtomicPartitionManagementSuite.scala | 4 +-
.../catalog/SupportsPartitionManagementSuite.scala | 7 +-
.../spark/sql/execution/datasources/rules.scala | 1 -
.../execution/datasources/v2/CreateTableExec.scala | 7 +-
.../datasources/v2/DataSourceV2Strategy.scala | 8 +-
.../datasources/v2/FileDataSourceV2.scala | 3 +-
.../datasources/v2/ReplaceTableExec.scala | 13 ++-
.../datasources/v2/ShowCreateTableExec.scala | 3 +-
.../datasources/v2/V2SessionCatalog.scala | 11 ++-
.../datasources/v2/WriteToDataSourceV2Exec.scala | 22 +++--
.../sources/TextSocketSourceProvider.scala | 5 +-
.../spark/sql/streaming/DataStreamReader.scala | 3 +-
.../sql/connector/DataSourceV2DataFrameSuite.scala | 3 +-
.../spark/sql/connector/DataSourceV2SQLSuite.scala | 20 ++--
.../sql/connector/DeleteFromTableSuiteBase.scala | 4 +-
.../sql/connector/TestV2SessionCatalogBase.scala | 11 ++-
.../WriteDistributionAndOrderingSuite.scala | 2 +-
.../execution/command/PlanResolutionSuite.scala | 56 ++++++-----
.../datasources/InMemoryTableMetricSuite.scala | 3 +-
.../datasources/v2/V2SessionCatalogSuite.scala | 96 +++++++++----------
.../org/apache/spark/sql/hive/InsertSuite.scala | 6 +-
43 files changed, 650 insertions(+), 234 deletions(-)
create mode 100644
sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Column.java
create mode 100644
sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ColumnDefaultValue.java
copy
sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/{ExpressionWithToString.scala
=> ColumnImpl.scala} (69%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
