ikUdZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqmrZrmsZsmtZtmuZumvZvgdZwGdd eZxd d d Zyeezezfe{d <iZ|eezezfe{d<dezdezddfdZ}dezdeezezfdexfdZ~y)a.Lance Namespace interface and plugin registry. This module provides: 1. LanceNamespace ABC interface for namespace implementations 2. connect() factory function for creating namespace instances 3. register_namespace_impl() for external implementation registration 4. Re-exported model types from lance_namespace_urllib3_client 5. Error types for Lance Namespace operations The actual implementations (DirectoryNamespace, RestNamespace) are provided by the lance package. This package only provides the abstract interface and plugin registration mechanism. N)ABCabstractmethod)Dict) ErrorCodeLanceNamespaceErrorUnsupportedOperationErrorNamespaceNotFoundErrorNamespaceAlreadyExistsErrorNamespaceNotEmptyErrorTableNotFoundErrorTableAlreadyExistsErrorTableIndexNotFoundErrorTableIndexAlreadyExistsErrorTableTagNotFoundErrorTableTagAlreadyExistsErrorTransactionNotFoundErrorTableVersionNotFoundErrorTableColumnNotFoundErrorInvalidInputErrorConcurrentModificationErrorPermissionDeniedErrorUnauthenticatedErrorServiceUnavailableError InternalErrorInvalidTableStateErrorTableSchemaValidationErrorThrottlingErrorfrom_error_code)TAlterTableAddColumnsRequestAlterTableAddColumnsResponseAlterTableAlterColumnsRequestAlterTableAlterColumnsResponseAlterTableDropColumnsRequestAlterTableDropColumnsResponseAlterTransactionRequestAlterTransactionResponseAnalyzeTableQueryPlanRequestBatchDeleteTableVersionsRequest BatchDeleteTableVersionsResponseCountTableRowsRequestCreateEmptyTableRequestCreateEmptyTableResponseCreateNamespaceRequestCreateNamespaceResponseCreateTableIndexRequestCreateTableIndexResponseCreateTableScalarIndexResponseCreateTableRequestCreateTableResponseCreateTableTagRequestCreateTableTagResponseCreateTableVersionRequestCreateTableVersionResponseDeclareTableRequestDeclareTableResponseDeleteFromTableRequestDeleteFromTableResponseDeleteTableTagRequestDeleteTableTagResponseDeregisterTableRequestDeregisterTableResponseDescribeNamespaceRequestDescribeNamespaceResponseDescribeTableIndexStatsRequestDescribeTableIndexStatsResponseDescribeTableRequestDescribeTableResponseDescribeTableVersionRequestDescribeTableVersionResponseDescribeTransactionRequestDescribeTransactionResponseDropNamespaceRequestDropNamespaceResponseDropTableIndexRequestDropTableIndexResponseDropTableRequestDropTableResponseExplainTableQueryPlanRequestGetTableStatsRequestGetTableStatsResponseGetTableTagVersionRequestGetTableTagVersionResponseInsertIntoTableRequestInsertIntoTableResponseListNamespacesRequestListNamespacesResponseListTableIndicesRequestListTableIndicesResponseListTableTagsRequestListTableTagsResponseListTableVersionsRequestListTableVersionsResponseListTablesRequestListTablesResponseMergeInsertIntoTableRequestMergeInsertIntoTableResponseNamespaceExistsRequestQueryTableRequestRegisterTableRequestRegisterTableResponseRenameTableRequestRenameTableResponseRestoreTableRequestRestoreTableResponseTableExistsRequest TableVersionUpdateTableRequestUpdateTableResponse UpdateTableSchemaMetadataRequest!UpdateTableSchemaMetadataResponseUpdateTableTagRequestUpdateTableTagResponse)qLanceNamespaceconnectregister_namespace_impl NATIVE_IMPLSrrrr r r r r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrceZdZdZedefdZdedefdZ de de fdZ de defdZdedefdZdedd fd Zdedefd Zdedefd Zdedefd Zdedd fdZde de!fdZ"de#de$fdZ%de&de'fdZ(de)de*de+fdZ,de-de.fdZ/de0de1fdZ2de3de*de4fdZ5de6de*de7fdZ8de9de:fdZ;dede?de*fdZ@deAdeBfdZCdeAdeDfdZEdeFdeGfdZHdeIdeJfdZKdeLdeMfdZNdedefd ZOdePdeQfd!ZRdeSdeTfd"ZUdeVdeWfd#ZXdeYdeZfd$Z[de\de]fd%Z^de_de`fd&Zadebdecfd'Zddeedeffd(Zgdehdefd)Zidejdefd*Zkdeldemfd+Zndeodepfd,Zqderdesfd-Ztdeudevfd.Zwdexdeyfd/Zzde{de|fd0Z}de~defd1Zdedefd2Zdedefd3Zdedefd4Zy )5rsaBase interface for Lance Namespace implementations. This abstract base class defines the contract for namespace implementations that manage Lance tables. Implementations can provide different storage backends (directory-based, REST API, cloud catalogs, etc.). To create a custom namespace implementation, subclass this ABC and implement at least the `namespace_id()` method. Other methods have default implementations that raise `UnsupportedOperationError`. Native implementations (DirectoryNamespace, RestNamespace) are provided by the lance package. External integrations (Glue, Hive, Unity) can be registered using `register_namespace_impl()`. All operations may raise the following common errors: - UnsupportedOperationError: The operation is not supported by this backend - InvalidInputError: The request contains invalid parameters - PermissionDeniedError: The user lacks permission for this operation - UnauthenticatedError: Authentication credentials are missing or invalid - ServiceUnavailableError: The service is temporarily unavailable - InternalError: An unexpected internal error occurred See the individual method docstrings for operation-specific errors. returncy)aReturn a human-readable unique identifier for this namespace instance. This is used for equality comparison and hashing when the namespace is used as part of a storage options provider. Two namespace instances with the same ID are considered equal and will share cached resources. The ID should be human-readable for debugging and logging purposes. For example: - REST namespace: "RestNamespace { uri: 'https://api.example.com' }" - Directory namespace: "DirectoryNamespace { root: '/path/to/data' }" Returns ------- str A human-readable unique identifier string N)selfs T/mnt/e/genesis-system/.venv/lib/python3.12/site-packages/lance_namespace/__init__.py namespace_idzLanceNamespace.namespace_id's$ requestctd)zList namespaces. Raises ------ NamespaceNotFoundError If the parent namespace does not exist. zNot supported: list_namespacesrr{rs r|list_namespaceszLanceNamespace.list_namespaces;s((HIIr~ctd)zDescribe a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. z!Not supported: describe_namespacerrs r|describe_namespacez!LanceNamespace.describe_namespaceEs((KLLr~ctd)zCreate a new namespace. Raises ------ NamespaceAlreadyExistsError If a namespace with the same name already exists. zNot supported: create_namespacerrs r|create_namespacezLanceNamespace.create_namespaceQs((IJJr~ctd)zDrop a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. NamespaceNotEmptyError If the namespace contains tables or child namespaces. zNot supported: drop_namespacerrs r|drop_namespacezLanceNamespace.drop_namespace]s((GHHr~Nctd)zCheck if a namespace exists. Raises ------ NamespaceNotFoundError If the namespace does not exist. zNot supported: namespace_existsrrs r|namespace_existszLanceNamespace.namespace_existsis((IJJr~ctd)zList tables in a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. zNot supported: list_tablesrrs r| list_tableszLanceNamespace.list_tablesss((DEEr~ctd)a Describe a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the specified version does not exist. zNot supported: describe_tablerrs r|describe_tablezLanceNamespace.describe_table}((GHHr~ctd)a=Register a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableAlreadyExistsError If a table with the same name already exists. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: register_tablerrs r|register_tablezLanceNamespace.register_tablerr~ctd)zCheck if a table exists. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: table_existsrrs r| table_existszLanceNamespace.table_existss((EFFr~ctd)zDrop a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: drop_tablerrs r| drop_tablezLanceNamespace.drop_tables((CDDr~ctd)zDeregister a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: deregister_tablerrs r|deregister_tablezLanceNamespace.deregister_table((IJJr~ctd)a%Count rows in a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the specified version does not exist. zNot supported: count_table_rowsrrs r|count_table_rowszLanceNamespace.count_table_rowsrr~ request_datactd)aCreate a new table with data from Arrow IPC stream. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableAlreadyExistsError If a table with the same name already exists. ConcurrentModificationError If a concurrent modification conflict occurs. TableSchemaValidationError If the schema validation fails. zNot supported: create_tablerr{rrs r| create_tablezLanceNamespace.create_table ((EFFr~ctd)aVDeclare a table (metadata only operation). Raises ------ NamespaceNotFoundError If the namespace does not exist. TableAlreadyExistsError If a table with the same name already exists. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: declare_tablerrs r| declare_tablezLanceNamespace.declare_table((FGGr~cPtjdtdtd)aCreate an empty table (metadata only operation). .. deprecated:: Use :meth:`declare_table` instead. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableAlreadyExistsError If a table with the same name already exists. ConcurrentModificationError If a concurrent modification conflict occurs. z;create_empty_table is deprecated, use declare_table instead) stacklevelz!Not supported: create_empty_table)warningswarnDeprecationWarningrrs r|create_empty_tablez!LanceNamespace.create_empty_tables'"  I  ((KLLr~ctd)aInsert data into a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. InvalidTableStateError If the table is in an invalid state for this operation. TableSchemaValidationError If the schema validation fails. z Not supported: insert_into_tablerrs r|insert_into_tablez LanceNamespace.insert_into_tables$((JKKr~ctd)aMerge insert data into a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. InvalidTableStateError If the table is in an invalid state for this operation. z&Not supported: merge_insert_into_tablerrs r|merge_insert_into_tablez&LanceNamespace.merge_insert_into_tables$((PQQr~ctd)aUpdate a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. InvalidTableStateError If the table is in an invalid state for this operation. zNot supported: update_tablerrs r| update_tablezLanceNamespace.update_table/rr~ctd)aDelete from a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. InvalidTableStateError If the table is in an invalid state for this operation. z Not supported: delete_from_tablerrs r|delete_from_tablez LanceNamespace.delete_from_tableAs ((JKKr~ctd)aqQuery a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the specified version does not exist. TableColumnNotFoundError If a referenced column does not exist. zNot supported: query_tablerrs r| query_tablezLanceNamespace.query_tableSs((DEEr~ctd)aCreate a table index. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableIndexAlreadyExistsError If an index with the same name already exists. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z!Not supported: create_table_indexrrs r|create_table_indexz!LanceNamespace.create_table_indexcs$((KLLr~ctd)aCreate a scalar index on a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableIndexAlreadyExistsError If an index with the same name already exists. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z(Not supported: create_table_scalar_indexrrs r|create_table_scalar_indexz(LanceNamespace.create_table_scalar_indexw$((RSSr~ctd)zList table indices. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z!Not supported: list_table_indicesrrs r|list_table_indicesz!LanceNamespace.list_table_indicess((KLLr~ctd)a!Describe table index statistics. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableIndexNotFoundError If the index does not exist. z)Not supported: describe_table_index_statsrrs r|describe_table_index_statsz)LanceNamespace.describe_table_index_statss((STTr~ctd)aDrop a table index. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableIndexNotFoundError If the index does not exist. zNot supported: drop_table_indexrrs r|drop_table_indexzLanceNamespace.drop_table_index((IJJr~ctd)z&List all tables across all namespaces.zNot supported: list_all_tablesrrs r|list_all_tableszLanceNamespace.list_all_tabless'(HIIr~ctd)aRestore a table to a specific version. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the specified version does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: restore_tablerrs r| restore_tablezLanceNamespace.restore_tablerr~ctd)a~Rename a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableAlreadyExistsError If a table with the new name already exists. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: rename_tablerrs r| rename_tablezLanceNamespace.rename_tables((EFFr~ctd)zList all versions of a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z"Not supported: list_table_versionsrrs r|list_table_versionsz"LanceNamespace.list_table_versionss((LMMr~ctd)aCreate a new table version entry. This operation supports put_if_not_exists semantics, where the operation fails if the version already exists. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. ConcurrentModificationError If the version already exists. z#Not supported: create_table_versionrrs r|create_table_versionz#LanceNamespace.create_table_versions"((MNNr~ctd)a|Describe a specific table version. Returns the manifest path and metadata for the specified version. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the specified version does not exist. z%Not supported: describe_table_versionrrs r|describe_table_versionz%LanceNamespace.describe_table_versions ((OPPr~ctd)aDelete table version metadata records. This operation deletes version tracking records, NOT the actual table data. It supports deleting ranges of versions for efficient bulk cleanup. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z*Not supported: batch_delete_table_versionsrrs r|batch_delete_table_versionsz*LanceNamespace.batch_delete_table_versionss((TUUr~ctd)a3Update table schema metadata. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z+Not supported: update_table_schema_metadatarrs r|update_table_schema_metadataz+LanceNamespace.update_table_schema_metadata!s((UVVr~ctd)zGet table statistics. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: get_table_statsrrs r|get_table_statszLanceNamespace.get_table_stats1((HIIr~ctd)zExplain a table query plan. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z'Not supported: explain_table_query_planrrs r|explain_table_query_planz'LanceNamespace.explain_table_query_plan=((QRRr~ctd)zAnalyze a table query plan. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z'Not supported: analyze_table_query_planrrs r|analyze_table_query_planz'LanceNamespace.analyze_table_query_planIrr~ctd)a|Add columns to a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. TableSchemaValidationError If the schema validation fails. z&Not supported: alter_table_add_columnsrrs r|alter_table_add_columnsz&LanceNamespace.alter_table_add_columnsUs ((PQQr~ctd)aAlter columns in a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. TableSchemaValidationError If the schema validation fails. z(Not supported: alter_table_alter_columnsrrs r|alter_table_alter_columnsz(LanceNamespace.alter_table_alter_columnsgrr~ctd)aDrop columns from a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableColumnNotFoundError If a referenced column does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z'Not supported: alter_table_drop_columnsrrs r|alter_table_drop_columnsz'LanceNamespace.alter_table_drop_columns{s ((QRRr~ctd)zList all tags for a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: list_table_tagsrrs r|list_table_tagszLanceNamespace.list_table_tagsrr~ctd)a Get the version for a specific tag. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableTagNotFoundError If the tag does not exist. z$Not supported: get_table_tag_versionrrs r|get_table_tag_versionz$LanceNamespace.get_table_tag_versions((NOOr~ctd)aCreate a tag for a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableTagAlreadyExistsError If a tag with the same name already exists. TableVersionNotFoundError If the specified version does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: create_table_tagrrs r|create_table_tagzLanceNamespace.create_table_tag$((IJJr~ctd)aDelete a tag from a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableTagNotFoundError If the tag does not exist. zNot supported: delete_table_tagrrs r|delete_table_tagzLanceNamespace.delete_table_tagrr~ctd)aUpdate a tag for a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableTagNotFoundError If the tag does not exist. TableVersionNotFoundError If the specified version does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. zNot supported: update_table_tagrrs r|update_table_tagzLanceNamespace.update_table_tagrr~ctd)zDescribe a transaction. Raises ------ TransactionNotFoundError If the transaction does not exist. z#Not supported: describe_transactionrrs r|describe_transactionz#LanceNamespace.describe_transactions((MNNr~ctd)zAlter a transaction. Raises ------ TransactionNotFoundError If the transaction does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z Not supported: alter_transactionrrs r|alter_transactionz LanceNamespace.alter_transactions((JKKr~)__name__ __module__ __qualname____doc__rstrr}rWrXrr@rArr-r.rrJrKrrcrr_r`rrDrErrerfrrkrrNrOrr>r?rr*intrr2bytesr3rr8r9rr+r,rrUrVrrarbrrmrnrr:r;rrdrr/r0rr1rrYrZrrBrCrrLrMrrrirjrrgrhrr]r^rr6r7rrFrGrr(r)rrorprrQrRrrPrr'rrr rr!r"rr#r$rr[r\rrSrTrr4r5rr<r=rrqrrrrHrIrr%r&rrzr~r|rsrs s4 c  &J'<JAWJ M/ M " M K- K  K I&: I?T IK(>K4KF#4F9KF I&: I?T I I&: I?T I G$6 G4 G E"2 E7H E K- K  K K(= K# KG)G9>G G$H*H H M.M !M0L-L=BL L(R2RBGR %R(G$6G;NG$L-L L$F#4FF M.M !M(T.T 'T( M. M ! MU5U (U K,K K J'8J=OJH%8H=QH G$6G;NG N/ N " NO0O #O&Q2Q %Q$V6V )V"W7W *W J'; J@U J S0L SQT S S0L SQT SR2R %R$T4T 'T(S3S &S$ J'; J@U JP0P #P K,K K(K,K K K,K K( O1 O $ O L. L ! Lr~rszlance.namespace.RestNamespacez"lance.namespace.DirectoryNamespace)restdirrv_REGISTERED_IMPLSname class_pathrxc|t|<y)amRegister a namespace implementation with a short name. External libraries can use this to register their implementations, allowing users to use short names like "glue" instead of full class paths. Parameters ---------- name : str Short name for the implementation (e.g., "glue", "hive2", "unity") class_path : str Full class path (e.g., "lance_glue.GlueNamespace") Examples -------- >>> # Register a custom implementation >>> register_namespace_impl("glue", "lance_glue.GlueNamespace") >>> # Now users can use: connect("glue", {"catalog": "my_catalog"}) N)r)rrs r|rurus&)dr~impl propertiescbtj|xstj|xs|} |jdd\}}t j |}t ||}t|tstd|d|di|S#t$r}td|d|d}~wwxYw) anConnect to a Lance namespace implementation. This factory function creates namespace instances based on implementation aliases or full class paths. It provides a unified way to instantiate different namespace backends. Parameters ---------- impl : str Implementation alias or full class path. Built-in aliases: - "rest": RestNamespace (REST API client, provided by lance) - "dir": DirectoryNamespace (local/cloud filesystem, provided by lance) You can also use full class paths like "my.custom.Namespace" External libraries can register additional aliases using `register_namespace_impl()`. properties : Dict[str, str] Configuration properties passed to the namespace constructor Returns ------- LanceNamespace The connected namespace instance Raises ------ ValueError If the implementation class cannot be loaded or does not implement LanceNamespace interface Examples -------- >>> # Connect to a directory namespace (requires lance package) >>> ns = connect("dir", {"root": "/path/to/data"}) >>> >>> # Connect to a REST namespace (requires lance package) >>> ns = connect("rest", {"uri": "http://localhost:4099"}) >>> >>> # Use a full class path >>> ns = connect("my_package.MyNamespace", {"key": "value"}) .zClass z, does not implement LanceNamespace interfacez#Failed to construct namespace impl z: Nrz) rvgetrrsplit importlib import_modulegetattr issubclassrs ValueError Exception)rr impl_class module_name class_namemodulenamespace_classes r|rtrtsT!!$'N+<+@+@+FN$J R","3"3C"; Z((5!&*5/>: $PQ ,,, R>zl"QCPQQRsAB B.B))B.)rrrabcrrtypingrlance_namespace.errorsrrrr r r r r rrrrrrrrrrrrrrrrr%lance_namespace_urllib3_client.modelsrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrr__all__rsrvr__annotations__rrurtrzr~r|rsM #8UUUUUUUUUUUUUUUUUUUUUUnv rm LSm Ld , /  d38n %'4S>&)#)3)4),7R#7R4S>7Rn7Rr~