Skip to content

Commit 00e57e7

Browse files
add row_limit to Thrift backend
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent eba17c1 commit 00e57e7

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/databricks/sql/backend/databricks_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ def execute_command(
104104
parameters: List of parameters to bind to the query
105105
async_op: Whether to execute the command asynchronously
106106
enforce_embedded_schema_correctness: Whether to enforce schema correctness
107-
row_limit: Maximum number of rows to fetch overall. Only supported for SEA protocol.
107+
row_limit: Maximum number of rows in the operation result.
108108
109109
Returns:
110110
If async_op is False, returns a ResultSet object containing the

src/databricks/sql/backend/thrift_backend.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -970,6 +970,7 @@ def execute_command(
970970
useArrowNativeTypes=spark_arrow_types,
971971
parameters=parameters,
972972
enforceEmbeddedSchemaCorrectness=enforce_embedded_schema_correctness,
973+
resultRowLimit=row_limit,
973974
)
974975
resp = self.make_request(self._client.ExecuteStatement, req)
975976

0 commit comments

Comments
 (0)