Problem with get_range

[SC7]

Hi all,
  I have problems getting correct results with the get_range functions. It seems that it truncates the returned results to 100 elements.
  Below is an example of code which produces errors.
 The batch_insert work as I have checked the data using  CQL and the cassandra.cluster library. Therefore, it seems that the get_range does not return everything.
I am using pycassa '1.11.0'

Any idea on the source of the problem ?

another_dico={5738: {34817: 1, 4104: 4, 13: 8, 20498: 1, 23: 1, 30: 3, 40: 4, 43: 19, 44: 1, 46: 1, 12335: 1, 49: 2, 2100: 1, 2103: 2, 57: 6, 59: 4, 61: 20, 64: 18, 68: 3, 70: 12, 71: 4, 76: 2, 78: 3, 79: 9, 82: 95, 83: 6, 12372: 1, 87: 1, 88: 7, 89: 3, 90: 28, 93: 4, 94: 3, 4194: 1, 101: 2, 2150: 1, 104: 1, 6250: 1, 18: 1, 112: 5, 6257: 1, 45171: 1, 6261: 1, 118: 1, 2167: 1, 125: 3, 126: 1, 127: 12, 130: 6, 132: 1, 2184: 1, 138: 5, 139: 3, 2188: 2, 142: 1, 148: 1, 22681: 1, 156: 1, 14494: 1, 6316: 1, 14513: 1, 2229: 1, 190: 1, 12485: 1, 198: 1, 209: 1, 3449: 2, 12512: 1, 2274: 1, 234: 1, 237: 10, 241: 1, 2771: 1, 244: 2, 245: 1, 10505: 2, 268: 3, 6530: 1, 26894: 1, 281: 1, 4386: 2, 24867: 9, 732: 1, 302: 4, 315: 1, 8509: 1, 24894: 1, 2369: 2, 6471: 1, 328: 3, 6473: 1, 37194: 1, 2381: 1, 334: 1, 397: 2, 336: 3, 344: 6, 347: 4, 350: 2, 354: 4, 4451: 1, 356: 1, 359: 1, 2416: 1, 33152: 1, 24962: 1, 6531: 1, 393: 1, 12685: 1, 47502: 1, 403: 1, 408: 1, 14746: 1, 2799: 1, 5872: 4, 10664: 1, 432: 1, 2481: 1, 2487: 1, 449: 1, 451: 1, 455: 1, 456: 2, 12769: 1, 483: 1, 25062: 1, 2535: 1, 10322: 3, 2542: 2, 26749: 1, 2545: 1, 501: 1, 502: 1, 503: 1, 31229: 1, 510: 1, 519: 2, 526: 6, 527: 2, 530: 3, 2582: 1, 13402: 1, 545: 2, 548: 9, 8741: 1, 552: 1, 2621: 1, 8769: 2, 6728: 1, 27211: 1, 596: 2, 12885: 3, 6754: 1, 2661: 2, 8807: 2, 12915: 1, 8824: 2, 8830: 1, 12927: 1, 12928: 6, 12930: 4, 31169: 1, 652: 2, 656: 1, 37525: 1, 665: 1, 12954: 1, 671: 1, 679: 2, 686: 1, 693: 2, 694: 2, 696: 1, 699: 1, 700: 2, 2753: 2, 706: 9, 4214: 1, 8905: 1, 2767: 1, 6867: 1, 10972: 3, 2787: 1, 744: 2, 13035: 1, 2173: 2, 755: 2, 10996: 6, 776: 1, 777: 1, 781: 1, 786: 10, 4884: 2, 791: 1, 798: 1, 2853: 1, 9008: 1, 819: 2, 2870: 1, 824: 2, 47929: 1, 4923: 4, 2879: 1, 2887: 2, 2888: 1, 140: 2, 842: 2, 2892: 1, 846: 2, 13135: 1, 2900: 1, 2907: 1, 2917: 1, 6631: 1, 2924: 1, 883: 1, 11131: 1, 902: 2, 13192: 1, 923: 2, 928: 3, 15268: 1, 23474: 1, 7667: 1, 3007: 1, 5963: 3, 964: 1, 9036: 1, 41944: 1, 27618: 1, 5095: 1, 11245: 1, 5108: 2, 5112: 1, 1046: 4, 7203: 2, 5186: 2, 9284: 1, 1889: 1, 1097: 1, 11354: 3, 11366: 1, 5228: 1, 1140: 1, 6678: 1, 31890: 1, 17558: 1, 6341: 1, 40105: 3, 5292: 1, 9400: 1, 11462: 1, 5321: 1, 11466: 1, 11469: 1, 3282: 3, 3291: 1, 48461: 1, 27895: 1, 15915: 1, 5390: 4, 3350: 1, 3351: 1, 23832: 1, 1313: 3, 5423: 1, 904: 1, 27954: 1, 38196: 1, 13622: 3, 27963: 1, 48446: 1, 48447: 1, 48448: 1, 48449: 1, 48450: 1, 48451: 1, 48452: 1, 1349: 1, 48454: 1, 48455: 1, 48456: 1, 48457: 1, 48458: 1, 48459: 1, 48460: 1, 10466: 1, 48462: 1, 48463: 1, 48464: 1, 48465: 1, 3418: 1, 3419: 1, 5471: 1, 3428: 2, 3429: 2, 5481: 2, 34154: 1, 3435: 3, 40302: 1, 11632: 1, 3445: 5, 5495: 1, 5496: 17, 5497: 25, 3456: 1, 17815: 2, 17816: 2, 11689: 1, 3501: 1, 3503: 3, 3515: 1, 2635: 2, 11724: 1, 1489: 1, 7639: 1, 1496: 1, 15849: 1, 3571: 1, 12884: 1, 5629: 1, 17932: 3, 17936: 2, 5649: 2, 34330: 1, 22046: 2, 17951: 1, 3627: 1, 15939: 1, 3656: 2, 1621: 2, 1622: 2, 3694: 1, 30343: 1, 5769: 1, 28311: 1, 18072: 2, 1689: 1, 11937: 1, 5807: 1, 18106: 1, 5825: 1, 5826: 1, 5827: 1, 1733: 1, 5834: 1, 3812: 3, 28391: 1, 28392: 1, 1772: 2, 1773: 1, 14064: 5, 1789: 1, 28418: 1, 20232: 1, 30475: 1, 3876: 1, 3887: 1, 18229: 2, 5951: 4, 1867: 2, 8018: 3, 8030: 2, 3935: 2, 14177: 1, 5986: 1, 10098: 1, 10117: 1, 2178: 2, 1929: 5, 20371: 1, 6040: 2, 1949: 2, 48453: 1, 1952: 4, 14246: 1, 3399: 3, 8110: 1, 1970: 1, 18378: 1, 1996: 4, 3405: 4, 2008: 11, 2384: 1, 10219: 2, 10220: 9, 42990: 1, 10226: 1}}

col_fam_M_line.batch_insert(another_dico)  

TheDoc = col_fam_M_line.get(5738)
print len(another_dico.values()[0].keys())

388
100

print len(TheDoc)
print TheDoc

OrderedDict([(13, 8.0), (18, 1.0), (23, 1.0), (30, 3.0), (40, 4.0), (43, 19.0), (44, 1.0), (46, 1.0), (49, 2.0), (57, 6.0), (59, 4.0), (61, 20.0), (64, 18.0), (68, 3.0), (70, 12.0), (71, 4.0), (76, 2.0), (78, 3.0), (79, 9.0), (82, 95.0), (83, 6.0), (87, 1.0), (88, 7.0), (89, 3.0), (90, 28.0), (93, 4.0), (94, 3.0), (101, 2.0), (104, 1.0), (112, 5.0), (118, 1.0), (125, 3.0), (126, 1.0), (127, 12.0), (130, 6.0), (132, 1.0), (138, 5.0), (139, 3.0), (140, 2.0), (142, 1.0), (148, 1.0), (156, 1.0), (190, 1.0), (198, 1.0), (209, 1.0), (234, 1.0), (237, 10.0), (241, 1.0), (244, 2.0), (245, 1.0), (268, 3.0), (281, 1.0), (302, 4.0), (315, 1.0), (328, 3.0), (334, 1.0), (336, 3.0), (344, 6.0), (347, 4.0), (350, 2.0), (354, 4.0), (356, 1.0), (359, 1.0), (393, 1.0), (397, 2.0), (403, 1.0), (408, 1.0), (432, 1.0), (449, 1.0), (451, 1.0), (455, 1.0), (456, 2.0), (483, 1.0), (501, 1.0), (502, 1.0), (503, 1.0), (510, 1.0), (519, 2.0), (526, 6.0), (527, 2.0), (530, 3.0), (545, 2.0), (548, 9.0), (552, 1.0), (596, 2.0), (652, 2.0), (656, 1.0), (665, 1.0), (671, 1.0), (679, 2.0), (686, 1.0), (693, 2.0), (694, 2.0), (696, 1.0), (699, 1.0), (700, 2.0), (706, 9.0), (732, 1.0), (744, 2.0), (755, 2.0)])

Thanks for your help.
Stephan

[Tyler Hobbs]

The column_count kwarg for get() and get_range() defaults to 100, so that's why you're limited to 100 elements by default.

--
You received this message because you are subscribed to the Google Groups "pycassa-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to pycassa-discu...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

Tyler Hobbs
DataStax