natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update cqlsh COPY for new internal driver serialization interface 

Patch by Stefania Alborghetti; reviewed by Adam Holmberg for CASSANDRA-10318
This commit is contained in:
Stefania Alborghetti 2015-09-15 12:11:09 +08:00 committed by T Jake Luciani
parent 06336377f7
commit b4544846de
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -1,4 +1,5 @@
3.0.0-rc1
* Update cqlsh COPY for new internal driver serialization interface (CASSANDRA-10318)
* Give index implementations more control over rebuild operations (CASSANDRA-10312)
* Update index file format (CASSANDRA-10314)
* Add "shadowable" row tombstones to deal with mv timestamp issues (CASSANDRA-10261)

7
bin/cqlsh.py
View File

@ -2388,16 +2388,11 @@ class ImportProcess(multiprocessing.Process):
fetch_size=None, paging_state=None, timestamp=insert_timestamp)
request_id = conn.get_request_id()
binary_message = query_message.to_binary(
stream_id=request_id, protocol_version=DEFAULT_PROTOCOL_VERSION, compression=None)
conn.send_msg(query_message, request_id=request_id, cb=partial(callback, current_record))
# add the message directly to the connection's queue
with conn.lock:
conn.in_flight += 1
conn._callbacks[request_id] = partial(callback, current_record)
conn.deque.append(binary_message)
# every 50 records, clear the pending writes queue and read
# any responses we have
if insert_num % 50 == 0: