Skip to content

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also .

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also .
...
Checking mergeability… Don’t worry, you can still create the pull request.
  • 1 commit
  • 1 file changed
  • 0 commit comments
  • 1 contributor
Showing with 4 additions and 2 deletions.
  1. +4 −2 pycassa/columnfamily.py
View
6 pycassa/columnfamily.py
@@ -850,7 +850,8 @@ def get_range(self, start="", finish="", columns=None, column_start="",
column_finish="", column_reversed=False, column_count=100,
row_count=None, include_timestamp=False,
super_column=None, read_consistency_level=None,
- buffer_size=None, filter_empty=True):
+ buffer_size=None, filter_empty=True,
+ start_token=None, end_token=None):
"""
Get an iterator over rows in a specified key range.
@@ -901,7 +902,8 @@ def get_range(self, start="", finish="", columns=None, column_start="",
else:
buffer_size = min(row_count - count + 1, buffer_size)
- key_range = KeyRange(start_key=last_key, end_key=finish, count=buffer_size)
+ key_range = KeyRange(start_key=last_key, end_key=finish,
+ start_token=start_token, end_token=end_token, count=buffer_size)
key_slices = self.pool.execute('get_range_slices', cp, sp, key_range, cl)
# This may happen if nothing was ever inserted
if key_slices is None:

No commit comments for this range

Something went wrong with that request. Please try again.