diff --git a/node/src/remote/index.ts b/node/src/remote/index.ts index 4c6838dd..92219302 100644 --- a/node/src/remote/index.ts +++ b/node/src/remote/index.ts @@ -157,6 +157,6 @@ export class RemoteTable implements Table { } async delete (filter: string): Promise { - throw new Error('Not implemented') + await this._client.post(`/v1/table/${this._name}/delete/`, { predicate: filter }) } } diff --git a/python/lancedb/remote/table.py b/python/lancedb/remote/table.py index 8e51234d..3f3faa0c 100644 --- a/python/lancedb/remote/table.py +++ b/python/lancedb/remote/table.py @@ -105,4 +105,8 @@ class RemoteTable(Table): return self._conn._loop.run_until_complete(result).to_arrow() def delete(self, predicate: str): - raise NotImplementedError + """Delete rows from the table.""" + payload = {"predicate": predicate} + self._conn._loop.run_until_complete( + self._conn._client.post(f"/v1/table/{self._name}/delete/", data=payload) + )