[python] Expose CatalogFactory and Schema APIs directly

docs/content/program-api/python-api.md

@@ -44,7 +44,7 @@ pip install pypaimon
 Before coming into contact with the Table, you need to create a Catalog.
 
 ```python
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 
 # Note that keys and values are all string
 catalog_options = {

paimon-python/pypaimon/__init__.py

@@ -16,7 +16,11 @@
 #  under the License.
 
 from pypaimon.filesystem.pvfs import PaimonVirtualFileSystem
+from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon.schema.schema import Schema
 
 __all__ = [
     "PaimonVirtualFileSystem",
+    "CatalogFactory",
+    "Schema",
 ]

paimon-python/pypaimon/tests/filesystem_catalog_test.py

@@ -23,9 +23,9 @@
                                                 DatabaseNotExistException,
                                                 TableAlreadyExistException,
                                                 TableNotExistException)
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 from pypaimon.schema.data_types import AtomicType, DataField
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.table.file_store_table import FileStoreTable
 
 

paimon-python/pypaimon/tests/predicate_push_down_test.py

@@ -23,9 +23,9 @@
 
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 from pypaimon.common.predicate_builder import PredicateBuilder
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 
 
 class PredicatePushDownTest(unittest.TestCase):

paimon-python/pypaimon/tests/predicates_test.py

@@ -23,8 +23,8 @@
 import pandas as pd
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 
 
 def _check_filtered_result(read_builder, expected_df):

paimon-python/pypaimon/tests/py36/ao_predicate_test.py

@@ -22,8 +22,8 @@
 import pandas as pd
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 from pypaimon.tests.predicates_test import _random_format, _check_filtered_result
 
 

paimon-python/pypaimon/tests/py36/ao_read_write_test.py

@@ -23,15 +23,15 @@
 import pyarrow as pa
 from pypaimon.api.options import Options
 from pypaimon.catalog.catalog_context import CatalogContext
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 from pypaimon.catalog.rest.rest_catalog import RESTCatalog
 from pypaimon.common.identifier import Identifier
 from pypaimon.manifest.manifest_file_manager import ManifestFileManager
 from pypaimon.manifest.schema.data_file_meta import DataFileMeta
 from pypaimon.manifest.schema.manifest_entry import ManifestEntry
 from pypaimon.manifest.schema.simple_stats import SimpleStats
 from pypaimon.schema.data_types import DataField, AtomicType
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.table.row.generic_row import GenericRow, GenericRowSerializer, GenericRowDeserializer
 from pypaimon.table.row.row_kind import RowKind
 from pypaimon.tests.py36.pyarrow_compat import table_sort_by

paimon-python/pypaimon/tests/reader_append_only_test.py

@@ -22,8 +22,8 @@
 
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 
 
 class AoReaderTest(unittest.TestCase):

paimon-python/pypaimon/tests/reader_basic_test.py

@@ -30,8 +30,8 @@
 
 from pypaimon.schema.data_types import DataField, AtomicType
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 from pypaimon.manifest.manifest_file_manager import ManifestFileManager
 from pypaimon.manifest.schema.simple_stats import SimpleStats
 from pypaimon.manifest.schema.data_file_meta import DataFileMeta

paimon-python/pypaimon/tests/reader_primary_key_test.py

@@ -23,8 +23,8 @@
 
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 
 
 class PkReaderTest(unittest.TestCase):

paimon-python/pypaimon/tests/rest_catalog_base_test.py

@@ -29,13 +29,13 @@
 from pypaimon.api.auth import BearTokenAuthProvider
 from pypaimon.api.options import Options
 from pypaimon.catalog.catalog_context import CatalogContext
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 from pypaimon.catalog.rest.rest_catalog import RESTCatalog
 from pypaimon.catalog.rest.table_metadata import TableMetadata
 from pypaimon.common.identifier import Identifier
 from pypaimon.schema.data_types import (ArrayType, AtomicType, DataField,
                                         MapType)
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.schema.table_schema import TableSchema
 from pypaimon.tests.rest_server import RESTCatalogServer
 

paimon-python/pypaimon/tests/rest_server.py

@@ -42,7 +42,7 @@
 from pypaimon.catalog.rest.table_metadata import TableMetadata
 from pypaimon.common.identifier import Identifier
 from pypaimon.common.json_util import JSON
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.schema.table_schema import TableSchema
 
 

paimon-python/pypaimon/tests/rest_table_read_write_test.py

@@ -23,10 +23,10 @@
 
 from pypaimon.api.options import Options
 from pypaimon.catalog.catalog_context import CatalogContext
-from pypaimon.catalog.catalog_factory import CatalogFactory
+from pypaimon import CatalogFactory
 from pypaimon.catalog.rest.rest_catalog import RESTCatalog
 from pypaimon.common.identifier import Identifier
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.tests.rest_catalog_base_test import RESTCatalogBaseTest
 
 

paimon-python/pypaimon/tests/rest_table_test.py

@@ -20,7 +20,7 @@
 
 import pyarrow as pa
 
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.tests.rest_catalog_base_test import RESTCatalogBaseTest
 from pypaimon.write.row_key_extractor import (DynamicBucketRowKeyExtractor,
                                               FixedBucketRowKeyExtractor,

paimon-python/pypaimon/tests/schema_test.py

@@ -22,7 +22,7 @@
 
 from pypaimon.schema.data_types import (ArrayType, AtomicType, DataField,
                                         MapType, PyarrowFieldParser)
-from pypaimon.schema.schema import Schema
+from pypaimon import Schema
 from pypaimon.schema.table_schema import TableSchema
 
 

paimon-python/pypaimon/tests/serializable_test.py

@@ -23,8 +23,8 @@
 
 import pyarrow as pa
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 
 
 class SerializableTest(unittest.TestCase):

paimon-python/pypaimon/tests/writer_test.py

@@ -23,8 +23,8 @@
 
 import pyarrow
 
-from pypaimon.catalog.catalog_factory import CatalogFactory
-from pypaimon.schema.schema import Schema
+from pypaimon import CatalogFactory
+from pypaimon import Schema
 
 
 class WriterTest(unittest.TestCase):