Github user rdblue commented on a diff in the pull request:

    https://github.com/apache/spark/pull/21306#discussion_r211057651
  
    --- Diff: 
sql/core/src/main/scala/org/apache/spark/sql/catalog/v2/V1MetadataTable.scala 
---
    @@ -0,0 +1,118 @@
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more
    + * contributor license agreements.  See the NOTICE file distributed with
    + * this work for additional information regarding copyright ownership.
    + * The ASF licenses this file to You under the Apache License, Version 2.0
    + * (the "License"); you may not use this file except in compliance with
    + * the License.  You may obtain a copy of the License at
    + *
    + *    http://www.apache.org/licenses/LICENSE-2.0
    + *
    + * Unless required by applicable law or agreed to in writing, software
    + * distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    + * See the License for the specific language governing permissions and
    + * limitations under the License.
    + */
    +
    +package org.apache.spark.sql.catalog.v2
    +
    +import java.util
    +
    +import scala.collection.JavaConverters._
    +
    +import org.apache.spark.sql.SaveMode
    +import org.apache.spark.sql.catalog.v2.PartitionTransforms.{bucket, 
identity}
    +import org.apache.spark.sql.catalyst.catalog.CatalogTable
    +import org.apache.spark.sql.sources.v2.{DataSourceOptions, DataSourceV2, 
ReadSupport, WriteSupport}
    +import org.apache.spark.sql.sources.v2.reader.DataSourceReader
    +import org.apache.spark.sql.sources.v2.writer.DataSourceWriter
    +import org.apache.spark.sql.types.StructType
    +
    +/**
    + * An implementation of catalog v2 [[Table]] to expose v1 table metadata.
    + */
    +private[sql] class V1MetadataTable(
    --- End diff --
    
    @cloud-fan, I updated this PR that adds the `TableCatalog` API to include 
an implementation that uses the existing `SessionCatalog`. This `Table` class 
demonstrates how `Table` would implement `ReadSupport` and `WriteSupport`.
    
    The catalog returns these tables, which have `ReadSupport` and 
`WriteSupport` mixed in depending on whether the underlying `DataSourceV2` also 
supports them. In your updated API, it would use the `ReadSupportProvider` 
instead of the `DataSourceV2` directly, but the difference isn't very large.
    
    The follow-up PR for CTAS and RTAS, #21877, demonstrates how this would be 
used in the new logical plans.


---

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to