@@ -125,9 +125,7 @@ class ScanRecords:
125125 def __getitem__ (self , index : slice ) -> List [ScanRecord ]: ...
126126 @overload
127127 def __getitem__ (self , bucket : TableBucket ) -> List [ScanRecord ]: ...
128- def __getitem__ (
129- self , key : Union [int , slice , TableBucket ]
130- ) -> Union [ScanRecord , List [ScanRecord ]]: ...
128+ def __getitem__ (self , key : Union [int , slice , TableBucket ]) -> Union [ScanRecord , List [ScanRecord ]]: ...
131129 def __contains__ (self , bucket : TableBucket ) -> bool : ...
132130 def __iter__ (self ) -> Iterator [ScanRecord ]: ...
133131 def __str__ (self ) -> str : ...
@@ -371,6 +369,7 @@ class FlussAdmin:
371369 ...
372370 def __repr__ (self ) -> str : ...
373371
372+
374373class DatabaseDescriptor :
375374 """Descriptor for a Fluss database (comment and custom properties)."""
376375
@@ -384,6 +383,7 @@ class DatabaseDescriptor:
384383 def get_custom_properties (self ) -> Dict [str , str ]: ...
385384 def __repr__ (self ) -> str : ...
386385
386+
387387class DatabaseInfo :
388388 """Information about a Fluss database."""
389389
@@ -604,6 +604,7 @@ class UpsertWriter:
604604 ...
605605 def __repr__ (self ) -> str : ...
606606
607+
607608class WriteResultHandle :
608609 """Handle for a pending write (append/upsert/delete). Ignore for fire-and-forget, or await handle.wait() for ack."""
609610
@@ -612,6 +613,7 @@ class WriteResultHandle:
612613 ...
613614 def __repr__ (self ) -> str : ...
614615
616+
615617class Lookuper :
616618 """Lookuper for performing primary key lookups on a Fluss table."""
617619
0 commit comments