org.apache.cassandra.utils
Class FBUtilities
java.lang.Object
org.apache.cassandra.utils.FBUtilities
public class FBUtilities
- extends java.lang.Object
Field Summary |
static java.math.BigInteger |
TWO
|
Method Summary |
static long |
absoluteFromFraction(double fractOrAbs,
long total)
|
static void |
atomicSetMax(java.util.concurrent.atomic.AtomicInteger atomic,
int i)
|
static void |
atomicSetMax(java.util.concurrent.atomic.AtomicLong atomic,
long i)
|
static int |
byteArrayToInt(byte[] bytes)
|
static int |
byteArrayToInt(byte[] bytes,
int offset)
|
static java.lang.String |
bytesToHex(byte... bytes)
|
static int |
compareByteArrays(byte[] bytes1,
byte[] bytes2)
|
static void |
compressToStream(byte[] input,
java.io.ByteArrayOutputStream bos)
|
static byte[] |
decompress(byte[] compressedData,
int off,
int len)
|
static void |
deserialize(org.apache.thrift.TDeserializer deserializer,
org.apache.thrift.TBase struct,
java.io.DataInput in)
|
static int |
encodedUTF8Length(java.lang.String st)
|
static boolean |
equals(java.lang.Object a,
java.lang.Object b)
|
static
<T extends java.lang.Comparable<T>>
org.apache.commons.collections.iterators.CollatingIterator |
|
getCollatingIterator()
|
static AbstractType |
getComparator(java.lang.String compareWith)
|
static java.net.InetAddress |
getLocalAddress()
|
static java.math.BigInteger |
hash(java.lang.String data)
|
static byte[] |
hash(java.lang.String type,
byte[]... data)
|
static byte[] |
hexToBytes(java.lang.String str)
|
static java.lang.String |
mapToString(java.util.Map<?,?> map)
|
static Pair<java.math.BigInteger,java.lang.Boolean> |
midpoint(java.math.BigInteger left,
java.math.BigInteger right,
int sigbits)
Given two bit arrays represented as BigIntegers, containing the given
number of significant bits, calculate a midpoint. |
static IPartitioner |
newPartitioner(java.lang.String partitionerClassName)
|
static double |
parseDoubleOrPercent(java.lang.String value)
Parses a string representing either a fraction, absolute value or percentage. |
static java.lang.String |
readNullableString(java.io.DataInput dis)
|
static void |
renameWithConfirm(java.lang.String tmpFilename,
java.lang.String filename)
|
static void |
serialize(org.apache.thrift.TSerializer serializer,
org.apache.thrift.TBase struct,
java.io.DataOutput out)
|
static void |
sortSampledKeys(java.util.List<DecoratedKey> keys,
Range range)
|
static java.lang.String[] |
strip(java.lang.String string,
java.lang.String token)
|
static byte[] |
toByteArray(int i)
|
static byte[] |
toByteArray(long n)
|
static void |
waitOnFutures(java.util.Collection<java.util.concurrent.Future<?>> futures)
|
static void |
writeByteArray(byte[] bytes,
java.io.DataOutput out)
|
static void |
writeNullableString(java.lang.String key,
java.io.DataOutput dos)
|
static byte[] |
xor(byte[] left,
byte[] right)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TWO
public static final java.math.BigInteger TWO
FBUtilities
public FBUtilities()
strip
public static java.lang.String[] strip(java.lang.String string,
java.lang.String token)
parseDoubleOrPercent
public static double parseDoubleOrPercent(java.lang.String value)
- Parses a string representing either a fraction, absolute value or percentage.
getLocalAddress
public static java.net.InetAddress getLocalAddress()
absoluteFromFraction
public static long absoluteFromFraction(double fractOrAbs,
long total)
- Parameters:
fractOrAbs
- A double that may represent a fraction or absolute value.total
- If fractionOrAbs is a fraction, the total to take the fraction from
- Returns:
- An absolute value which may be larger than the total.
midpoint
public static Pair<java.math.BigInteger,java.lang.Boolean> midpoint(java.math.BigInteger left,
java.math.BigInteger right,
int sigbits)
- Given two bit arrays represented as BigIntegers, containing the given
number of significant bits, calculate a midpoint.
- Parameters:
left
- The left point.right
- The right point.sigbits
- The number of bits in the points that are significant.
- Returns:
- A midpoint that will compare bitwise halfway between the params, and
a boolean representing whether a non-zero lsbit remainder was generated.
toByteArray
public static byte[] toByteArray(int i)
byteArrayToInt
public static int byteArrayToInt(byte[] bytes)
byteArrayToInt
public static int byteArrayToInt(byte[] bytes,
int offset)
compareByteArrays
public static int compareByteArrays(byte[] bytes1,
byte[] bytes2)
xor
public static byte[] xor(byte[] left,
byte[] right)
- Returns:
- The bitwise XOR of the inputs. The output will be the same length as the
longer input, but if either input is null, the output will be null.
hash
public static java.math.BigInteger hash(java.lang.String data)
hash
public static byte[] hash(java.lang.String type,
byte[]... data)
compressToStream
public static void compressToStream(byte[] input,
java.io.ByteArrayOutputStream bos)
throws java.io.IOException
- Throws:
java.io.IOException
decompress
public static byte[] decompress(byte[] compressedData,
int off,
int len)
throws java.io.IOException,
java.util.zip.DataFormatException
- Throws:
java.io.IOException
java.util.zip.DataFormatException
writeByteArray
public static void writeByteArray(byte[] bytes,
java.io.DataOutput out)
throws java.io.IOException
- Throws:
java.io.IOException
hexToBytes
public static byte[] hexToBytes(java.lang.String str)
bytesToHex
public static java.lang.String bytesToHex(byte... bytes)
mapToString
public static java.lang.String mapToString(java.util.Map<?,?> map)
writeNullableString
public static void writeNullableString(java.lang.String key,
java.io.DataOutput dos)
throws java.io.IOException
- Throws:
java.io.IOException
readNullableString
public static java.lang.String readNullableString(java.io.DataInput dis)
throws java.io.IOException
- Throws:
java.io.IOException
renameWithConfirm
public static void renameWithConfirm(java.lang.String tmpFilename,
java.lang.String filename)
throws java.io.IOException
- Throws:
java.io.IOException
getCollatingIterator
public static <T extends java.lang.Comparable<T>> org.apache.commons.collections.iterators.CollatingIterator getCollatingIterator()
atomicSetMax
public static void atomicSetMax(java.util.concurrent.atomic.AtomicInteger atomic,
int i)
atomicSetMax
public static void atomicSetMax(java.util.concurrent.atomic.AtomicLong atomic,
long i)
serialize
public static void serialize(org.apache.thrift.TSerializer serializer,
org.apache.thrift.TBase struct,
java.io.DataOutput out)
throws java.io.IOException
- Throws:
java.io.IOException
deserialize
public static void deserialize(org.apache.thrift.TDeserializer deserializer,
org.apache.thrift.TBase struct,
java.io.DataInput in)
throws java.io.IOException
- Throws:
java.io.IOException
sortSampledKeys
public static void sortSampledKeys(java.util.List<DecoratedKey> keys,
Range range)
equals
public static boolean equals(java.lang.Object a,
java.lang.Object b)
encodedUTF8Length
public static int encodedUTF8Length(java.lang.String st)
toByteArray
public static byte[] toByteArray(long n)
waitOnFutures
public static void waitOnFutures(java.util.Collection<java.util.concurrent.Future<?>> futures)
newPartitioner
public static IPartitioner newPartitioner(java.lang.String partitionerClassName)
getComparator
public static AbstractType getComparator(java.lang.String compareWith)
Copyright © 2010 The Apache Software Foundation