mirror of https://github.com/apache/cassandra
cleanup
This commit is contained in:
parent
7abc634d52
commit
f07effb1c3
|
|
@ -84,7 +84,7 @@ public abstract class Operation
|
||||||
int times = session.getColumnSize() / hash.length();
|
int times = session.getColumnSize() / hash.length();
|
||||||
int sumReminder = session.getColumnSize() % hash.length();
|
int sumReminder = session.getColumnSize() % hash.length();
|
||||||
|
|
||||||
String value = new StringBuilder(multiplyString(hash, times)).append(hash.substring(0, sumReminder)).toString();
|
String value = multiplyString(hash, times) + hash.substring(0, sumReminder);
|
||||||
values.add(ByteBuffer.wrap(value.getBytes()));
|
values.add(ByteBuffer.wrap(value.getBytes()));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -244,7 +244,6 @@ public abstract class Operation
|
||||||
{
|
{
|
||||||
return Lists.transform(queryParams, new Function<String, ByteBuffer>()
|
return Lists.transform(queryParams, new Function<String, ByteBuffer>()
|
||||||
{
|
{
|
||||||
@Override
|
|
||||||
public ByteBuffer apply(String param)
|
public ByteBuffer apply(String param)
|
||||||
{
|
{
|
||||||
return ByteBufferUtil.bytes(param);
|
return ByteBufferUtil.bytes(param);
|
||||||
|
|
@ -262,7 +261,7 @@ public abstract class Operation
|
||||||
*/
|
*/
|
||||||
protected static String formatCqlQuery(String query, List<String> parms)
|
protected static String formatCqlQuery(String query, List<String> parms)
|
||||||
{
|
{
|
||||||
int marker = 0, position = 0;
|
int marker, position = 0;
|
||||||
StringBuilder result = new StringBuilder();
|
StringBuilder result = new StringBuilder();
|
||||||
|
|
||||||
if (-1 == (marker = query.indexOf('?')) || parms.size() == 0)
|
if (-1 == (marker = query.indexOf('?')) || parms.size() == 0)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue