dQjUdZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"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/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqmrZrmsZsmtZtmuZumvZvmwZwmxZxmyZymzZzm{Z{m|Z|m}Z}m~Z~mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZeEZeFZgdZGdd eZd d d Zeeefed <iZeeefed<dededdfdZdedeeefdefdZy)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 InternalErrorInvalidTableStateErrorTableSchemaValidationErrorThrottlingErrorTableBranchNotFoundErrorTableBranchAlreadyExistsErrorfrom_error_code)lAlterTableAddColumnsRequestAlterTableAddColumnsResponseAlterTableAlterColumnsRequestAlterTableAlterColumnsResponse AlterTableBackfillColumnsRequest!AlterTableBackfillColumnsResponseAlterTableDropColumnsRequestAlterTableDropColumnsResponseAlterTransactionRequestAlterTransactionResponseAnalyzeTableQueryPlanRequestBatchCommitTablesRequestBatchCommitTablesResponseBatchCreateTableVersionsRequest BatchCreateTableVersionsResponseBatchDeleteTableVersionsRequest BatchDeleteTableVersionsResponseCommitTableOperationCommitTableResultCountTableRowsRequestCountTableRowsResponseCreateMaterializedViewRequestCreateMaterializedViewResponseMaterializedViewUdtfEntryCreateTableVersionEntryCreateNamespaceRequestCreateNamespaceResponseCreateTableBranchRequestCreateTableBranchResponseCreateTableIndexRequestCreateTableIndexResponseCreateTableScalarIndexResponseCreateTableRequestCreateTableResponseCreateTableTagRequestCreateTableTagResponseCreateTableVersionRequestCreateTableVersionResponseDeclareTableRequestDeclareTableResponseDeleteFromTableRequestDeleteFromTableResponseDeleteTableBranchRequestDeleteTableBranchResponseDeleteTableTagRequestDeleteTableTagResponseDeregisterTableRequestDeregisterTableResponseDescribeNamespaceRequestDescribeNamespaceResponseDescribeTableIndexStatsRequestDescribeTableIndexStatsResponseDescribeTableRequestDescribeTableResponseDescribeTableVersionRequestDescribeTableVersionResponseDescribeTransactionRequestDescribeTransactionResponseDropNamespaceRequestDropNamespaceResponseDropTableIndexRequestDropTableIndexResponseDropTableRequestDropTableResponseExplainTableQueryPlanRequestGetTableStatsRequestGetTableStatsResponseGetTableTagVersionRequestGetTableTagVersionResponseInsertIntoTableRequestInsertIntoTableResponseListNamespacesRequestListNamespacesResponseListTableBranchesRequestListTableBranchesResponseListTableIndicesRequestListTableIndicesResponseListTableTagsRequestListTableTagsResponseListTableVersionsRequestListTableVersionsResponseListTablesRequestListTablesResponseMergeInsertIntoTableRequestMergeInsertIntoTableResponseNamespaceExistsRequestNamespaceExistsResponseQueryTableRequestQueryTableResponseRefreshMaterializedViewRequestRefreshMaterializedViewResponseRegisterTableRequestRegisterTableResponseRenameTableRequestRenameTableResponseRestoreTableRequestRestoreTableResponseTableExistsRequestTableExistsResponse TableVersionUpdateFieldMetadataRequestUpdateFieldMetadataResponseUpdateTableRequestUpdateTableResponse UpdateTableSchemaMetadataRequest!UpdateTableSchemaMetadataResponseUpdateTableTagRequestUpdateTableTagResponse)LanceNamespaceconnectregister_namespace_impl NATIVE_IMPLSrrrr r r r r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9CreateEmptyTableRequestCreateEmptyTableResponser:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrrrrrrrrrrrrceZdZdZedefdZdedefdZ de de fdZ de defdZdedefdZdedefd Zdedefd Zdedefd Zdedefd Zdede fd Z!de"de#fdZ$de%de&fdZ'de(de)fdZ*de+de,de-fdZ.de/de0fdZ1 d>dZ2de3de,de4fdZ5de6de,de7fdZ8de9de:fdZ;dede?de@fdZAdeBdeCfdZDdeBdeEfdZFdeGdeHfdZIdeJdeKfdZLdeMdeNfdZOdedefdZPdeQdeRfd ZSdeTdeUfd!ZVdeWdeXfd"ZYdeZde[fd#Z\de]de^fd$Z_de`deafd%Zbdecdedfd&Zedefdegfd'Zhdeidejfd(Zkdeldemfd)Zndeodepfd*Zqderdefd+Zsdetdefd,Zudevdewfd-Zxdeydezfd.Z{de|de}fd/Z~dedefd0Zdedefd1Zdedefd2Zdedefd3Zdedefd4Zdedefd5Zdedefd6Zdedefd7Zdedefd8Zdedefd9Zdedefd:Zdedefd;Zdedefd<Zy=)?raBase 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 ]/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lance_namespace/__init__.py namespace_idzLanceNamespace.namespace_idfs$ requestctd)zList namespaces. Raises ------ NamespaceNotFoundError If the parent namespace does not exist. zNot supported: list_namespacesrrrs rlist_namespaceszLanceNamespace.list_namespaceszs((HIIrctd)zDescribe a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. z!Not supported: describe_namespacerrs rdescribe_namespacez!LanceNamespace.describe_namespaces((KLLrctd)zCreate a new namespace. Raises ------ NamespaceAlreadyExistsError If a namespace with the same name already exists. zNot supported: create_namespacerrs rcreate_namespacezLanceNamespace.create_namespaces((IJJrctd)zDrop a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. NamespaceNotEmptyError If the namespace contains tables or child namespaces. zNot supported: drop_namespacerrs rdrop_namespacezLanceNamespace.drop_namespaces((GHHrctd)aCheck if a namespace exists. Returns ------- NamespaceExistsResponse The response returned when the namespace exists. Raises ------ NamespaceNotFoundError If the namespace does not exist. zNot supported: namespace_existsrrs rnamespace_existszLanceNamespace.namespace_existss((IJJrctd)zList tables in a namespace. Raises ------ NamespaceNotFoundError If the namespace does not exist. zNot supported: list_tablesrrs r list_tableszLanceNamespace.list_tabless((DEErctd)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 rdescribe_tablezLanceNamespace.describe_table((GHHrctd)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 rregister_tablezLanceNamespace.register_tablerrctd)aFCheck if a table exists. Returns ------- TableExistsResponse The response returned when the 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((EFFrctd)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((CDDrctd)zDeregister a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: deregister_tablerrs rderegister_tablezLanceNamespace.deregister_tables((IJJrctd)aCount rows in a table. Returns ------- CountTableRowsResponse The response containing the row count. 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 rcount_table_rowszLanceNamespace.count_table_rows s&((IJJr 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_tablerrrrs r create_tablezLanceNamespace.create_table ((EFFrctd)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_table1((FGGrcPtjdtdtd)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 rcreate_empty_tablez!LanceNamespace.create_empty_tableAs'"  I  ((KLLrctd)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 rinsert_into_tablez LanceNamespace.insert_into_tableYs$((JKKrctd)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 rmerge_insert_into_tablez&LanceNamespace.merge_insert_into_tablems$((PQQrctd)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_tablerrctd)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 rdelete_from_tablez LanceNamespace.delete_from_tables ((JKKrctd)aQuery a table. Returns ------- QueryTableResponse The response containing the query results as Arrow IPC file data. 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_tables&((DEErctd)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 rcreate_table_indexz!LanceNamespace.create_table_indexs$((KLLrctd)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 rcreate_table_scalar_indexz(LanceNamespace.create_table_scalar_index$((RSSrctd)zList table indices. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z!Not supported: list_table_indicesrrs rlist_table_indicesz!LanceNamespace.list_table_indicess((KLLrctd)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 rdescribe_table_index_statsz)LanceNamespace.describe_table_index_statss((STTrctd)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 rdrop_table_indexzLanceNamespace.drop_table_index((IJJrctd)z&List all tables across all namespaces.zNot supported: list_all_tablesrrs rlist_all_tableszLanceNamespace.list_all_tabless'(HIIrctd)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_tablerrctd)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_table$s((EFFrctd)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 rlist_table_versionsz"LanceNamespace.list_table_versions4((LMMrctd)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 rcreate_table_versionz#LanceNamespace.create_table_versionBs"((MNNrctd)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 rdescribe_table_versionz%LanceNamespace.describe_table_versionUs ((OPPrctd)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 rbatch_delete_table_versionsz*LanceNamespace.batch_delete_table_versionsgs((TUUrctd)aAtomically create new version entries for multiple tables. This operation is atomic: either all table versions are created successfully, or none are created. If any version creation fails (e.g., due to conflict), the entire batch operation fails. Each entry in the request specifies the table identifier and version details. This supports put_if_not_exists semantics for each version entry. Raises ------ NamespaceNotFoundError If any namespace does not exist. TableNotFoundError If any table does not exist. ConcurrentModificationError If any version already exists. z*Not supported: batch_create_table_versionsrrs rbatch_create_table_versionsz*LanceNamespace.batch_create_table_versionsxs*((TUUrctd)aAtomically commit a batch of mixed table operations. This is a generalized version of `batch_create_table_versions` that supports mixed operation types (DeclareTable, CreateTableVersion, DeleteTableVersions, DeregisterTable) within a single atomic transaction at the metadata layer. All operations are committed atomically: either all succeed or none are applied. Raises ------ NamespaceNotFoundError If any namespace does not exist. TableNotFoundError If any table does not exist. ConcurrentModificationError If any operation conflicts. z"Not supported: batch_commit_tablesrrs rbatch_commit_tablesz"LanceNamespace.batch_commit_tabless(((LMMrctd)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 rupdate_table_schema_metadataz+LanceNamespace.update_table_schema_metadatas((UVVrctd)a0Update per-field 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_field_metadatarrs rupdate_field_metadataz$LanceNamespace.update_field_metadata((NOOrctd)zGet table statistics. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. zNot supported: get_table_statsrrs rget_table_statszLanceNamespace.get_table_stats((HIIrctd)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 rexplain_table_query_planz'LanceNamespace.explain_table_query_plan((QRRrctd)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 ranalyze_table_query_planz'LanceNamespace.analyze_table_query_planrrctd)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 ralter_table_add_columnsz&LanceNamespace.alter_table_add_columnss ((PQQrctd)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 ralter_table_alter_columnsz(LanceNamespace.alter_table_alter_columnsrrctd)zTrigger an async backfill job for a computed column. Raises ------ TableNotFoundError If the table does not exist. z+Not supported: alter_table_backfill_columnsrrs ralter_table_backfill_columnsz+LanceNamespace.alter_table_backfill_columnss( 9  rctd)zCreate a materialized view. Raises ------ TableAlreadyExistsError If a table with the same identifier already exists. z'Not supported: create_materialized_viewrrs rcreate_materialized_viewz'LanceNamespace.create_materialized_views( 5  rctd)zTrigger an async materialized view refresh. Raises ------ TableNotFoundError If the table does not exist. z(Not supported: refresh_materialized_viewrrs rrefresh_materialized_viewz(LanceNamespace.refresh_materialized_view+s( 6  rctd)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 ralter_table_drop_columnsz'LanceNamespace.alter_table_drop_columns9s ((QRRrctd)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 rlist_table_tagszLanceNamespace.list_table_tagsKrrctd)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 rget_table_tag_versionz$LanceNamespace.get_table_tag_versionWrrctd)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 rcreate_table_tagzLanceNamespace.create_table_tagg$((IJJrctd)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 rdelete_table_tagzLanceNamespace.delete_table_tag{rrctd)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 rupdate_table_tagzLanceNamespace.update_table_tagrrctd)aCreate a branch for a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. TableVersionNotFoundError If the source version does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z"Not supported: create_table_branchrrs rcreate_table_branchz"LanceNamespace.create_table_branchs ((LMMrctd)zList all branches for a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z"Not supported: list_table_branchesrrs rlist_table_branchesz"LanceNamespace.list_table_branchesrrctd)zDelete a branch from a table. Raises ------ NamespaceNotFoundError If the namespace does not exist. TableNotFoundError If the table does not exist. z"Not supported: delete_table_branchrrs rdelete_table_branchz"LanceNamespace.delete_table_branchrrctd)zDescribe a transaction. Raises ------ TransactionNotFoundError If the transaction does not exist. z#Not supported: describe_transactionrrs rdescribe_transactionz#LanceNamespace.describe_transactions((MNNrctd)zAlter a transaction. Raises ------ TransactionNotFoundError If the transaction does not exist. ConcurrentModificationError If a concurrent modification conflict occurs. z Not supported: alter_transactionrrs ralter_transactionz LanceNamespace.alter_transactions((JKKrN)rrrr)__name__ __module__ __qualname____doc__rstrrrhrirrQrRrr:r;rr[r\rrvrwrrrrsrrUrVrr|r}rrrrr_r`rrOrPrr4r5rrAbytesrBrrGrHrrrfrgrrtrurrrrrIrJrrxryrr>r?rr@rrlrmrrSrTrr]r^rrrrrr~rrrprqrrErFrrWrXrr0r1rr.r/rr,r-rrrrrrrrbrcrrarr+rr!r"rr#r$rr%r&rr6r7rrzr{rr'r(rrnror rdrer rCrDr rMrNrrrrr<r=rrjrkrrKrLrrYrZrr)r*rrrrrrKs\4 c  &J'<JAWJ M/ M " M K- K  K I&: I?T IK-K K"F#4F9KF I&: I?T I I&: I?T IG$6G;NG" E"2 E7H E K- K  KK,K K*G)G9>G G$H*H H M0M #M0L-L=BL L(R2RBGR %R(G$6G;NG$L-L L$F#4F9KF*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"V6V )V.N/N "N,W7W *W P1P $P J'; J@U J S0L SQT S S0L SQT SR2R %R$T4T 'T(  7  *    4  '    5  (  S3S &S$ J'; J@U JP0P #P K,K K(K,K K K,K K(N/N "N$ N/ N " N N/ N " N O1 O $ O L. L ! Lrrzlance.namespace.RestNamespacez"lance.namespace.DirectoryNamespace)restdirr_REGISTERED_IMPLSname class_pathrc|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%)r&r's rrrs&)drimpl 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: Nr) rgetr%rsplit importlib import_modulegetattr issubclassr ValueError Exception)r)r* impl_class module_name class_namemodulenamespace_classes rrrsT!!$'N+<+@+@+FN$J R","3"3C"; Z((5!&*5/>: $PQ ,,, R>zl"QCPQQRsAB B.B))B.)r r0rabcrrtypingrlance_namespace.errorsrrrr r r r r rrrrrrrrrrrrrrrrrrr %lance_namespace_urllib3_client.modelsr!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`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrrrrrrrrrrrrrr__all__rrr!__annotations__r%rrrrrrBs #&)#)3)4),7R#7R4S>7Rn7Rr