import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
public void close()
{
    FileUtils.closeQuietly(writer);
    byte[] bytes = digest.digest();
    if (bytes == null)
        return;
    SequentialWriter out = SequentialWriter.open(new File(descriptor.filenameFor(SSTable.COMPONENT_DIGEST)), true);
    // Writting output compatible with sha1sum
    Descriptor newdesc = descriptor.asTemporary(false);
    String[] tmp = newdesc.filenameFor(SSTable.COMPONENT_DATA).split(Pattern.quote(File.separator));
    String dataFileName = tmp[tmp.length - 1];
    try
    {
        out.write(String.format("%s  %s", Hex.bytesToHex(bytes), dataFileName).getBytes());
    }
    catch (ClosedChannelException e)
    {
        throw new AssertionError(); // can't happen.
    }
    finally
    {
        FileUtils.closeQuietly(out);
    }
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
public void close()
{
    FileUtils.closeQuietly(writer);
    byte[] bytes = digest.digest();
    if (bytes == null)
        return;
    SequentialWriter out = SequentialWriter.open(new File(descriptor.filenameFor(Component.DIGEST)), true);
    // Writting output compatible with sha1sum
    Descriptor newdesc = descriptor.asTemporary(false);
    String[] tmp = newdesc.filenameFor(Component.DATA).split(Pattern.quote(File.separator));
    String dataFileName = tmp[tmp.length - 1];
    try
    {
        out.write(String.format("%s  %s", Hex.bytesToHex(bytes), dataFileName).getBytes());
    }
    catch (ClosedChannelException e)
    {
        throw new AssertionError(); // can't happen.
    }
    finally
    {
        FileUtils.closeQuietly(out);
    }
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
/**
 * Serialize a set of ColumnDefs for indexed columns, read from Job
 * configuration
 *
 * @param serialized column metadata
 * @return list of column metadata objects which may be empty, but not null
 */
public static Set<ColumnDef> deserializeIndexedColumns(String serialized) {
    Set<ColumnDef> columns = new HashSet<ColumnDef>();
    if (null == serialized) {
        return columns;
    }

    Iterable<String> strings = Splitter.on(AbstractCassandraSerDe.DELIMITER).omitEmptyStrings().trimResults().split(serialized);
    TDeserializer deserializer = new TDeserializer(new TBinaryProtocol.Factory());
    for (String encoded : strings) {
        ColumnDef column = new ColumnDef();
        try {
            logger.info("Encoded column def: " + encoded);
            deserializer.deserialize(column, Hex.hexToBytes(encoded));
        } catch (TException e) {
            logger.warn("Error deserializing indexed column definition", e);
        }
        if (null == column.getName() || null == column.validation_class) {
            continue;
        }
        columns.add(column);
    }
    return columns;
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
public ByteBuffer fromString(String source)
{
    try
    {
        return ByteBuffer.wrap(Hex.hexToBytes(source));
    }
    catch (NumberFormatException e)
    {
        throw new MarshalException(String.format("cannot parse '%s' as hex bytes", source), e);
    }
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
public void validate(String token) throws ConfigurationException
{
    try
    {
        if (token.length() % 2 == 1)
            token = "0" + token;
        Hex.hexToBytes(token);
    }
    catch (NumberFormatException e)
    {
        throw new ConfigurationException("Token " + token + " contains non-hex digits");
    }
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
@Deprecated
public static String toString(List<Object> resource)
{
    StringBuilder buff = new StringBuilder();
    for (Object component : resource)
    {
        buff.append("/");
        if (component instanceof byte[])
            buff.append(Hex.bytesToHex((byte[])component));
        else
            buff.append(component.toString());
    }
    return buff.toString();
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
@Deprecated
public static String toString(List<Object> resource)
{
    StringBuilder buff = new StringBuilder();
    for (Object component : resource)
    {
        buff.append("/");
        if (component instanceof byte[])
            buff.append(Hex.bytesToHex((byte[])component));
        else
            buff.append(component);
    }
    return buff.toString();
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
@Test
public void testValueBytes() {
    ColumnMapperBlob mapper = new ColumnMapperBlob();
    byte[] bytes = Hex.hexToBytes("f1");
    String parsed = mapper.indexValue("test", bytes);
    Assert.assertEquals("f1", parsed);
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
/**
 * Serialize a set of ColumnDefs for indexed columns, so that it can be
 * written to Job configuration
 *
 * @param columns column metadata
 * @return serialized form
 */
public static String serializeIndexedColumns(Set<ColumnDef> columns) {
    TSerializer serializer = new TSerializer(new TBinaryProtocol.Factory());
    try {
        List<String> hexStrings = new ArrayList<String>();
        for (ColumnDef column : columns) {
            String encoded = Hex.bytesToHex(serializer.serialize(column));
            logger.info("Encoded column def: " + encoded);
            hexStrings.add(encoded);
        }
        return Joiner.on(AbstractCassandraSerDe.DELIMITER).join(hexStrings);
    } catch (TException e) {
        throw new RuntimeException(e);
    }
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
@Override
public String toString() {
  StringBuilder valuesAsStrings = new StringBuilder();
  valuesAsStrings.append("[");
  for (ByteBuffer value : values) {
    valuesAsStrings.append(Hex.bytesToHex(value.array()));
    valuesAsStrings.append(",");
  }
  valuesAsStrings.deleteCharAt(valuesAsStrings.length()-1);
  valuesAsStrings.append("]");
  return String.format("CQLRecord(key=%s, values=%s", valuesAsStrings);
}
 

import org.apache.cassandra.utils.Hex; //导入依赖的package包/类
@Override
public String toString()
{
    return Hex.bytesToHex(token);
}