import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
@SuppressWarnings({ "rawtypes", "unchecked" })
public static <T> Serializer<T> getSerializer(Class<?> valueClass) {
  Serializer serializer = null;
  if (valueClass.equals(Utf8.class) || valueClass.equals(CharSequence.class)) {
    serializer = CharSequenceSerializer.get();
  } else if (valueClass.equals(Boolean.class) || valueClass.equals(boolean.class)) {
    serializer = BooleanSerializer.get();
  } else if (valueClass.equals(ByteBuffer.class)) {
    serializer = ByteBufferSerializer.get();
  } else if (valueClass.equals(Double.class) || valueClass.equals(double.class)) {
    serializer = DoubleSerializer.get();
  } else if (valueClass.equals(Float.class) || valueClass.equals(float.class)) {
    serializer = FloatSerializer.get();
  } else if (valueClass.equals(Integer.class) || valueClass.equals(int.class)) {
    serializer = IntegerSerializer.get();
  } else if (valueClass.equals(Long.class) || valueClass.equals(long.class)) {
    serializer = LongSerializer.get();
  } else if (valueClass.equals(String.class)) {
    serializer = StringSerializer.get();
  } else {
    serializer = SerializerTypeInferer.getSerializer(valueClass);
  }
  return serializer;
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
/**
 * Builds a new data access object with the given data.
 * 
 * @param factory the data access layer factory.
 * @param keyClass the key class.
 * @param valueClass the value class.
 * @param isBidirectional a flag indicating if the map shoulbe be accessed both by value and by key.
 * @param columnFamilyName the column family name.
 */
Cassandra12xMapDAO(
		final DataAccessLayerFactory factory, 
		final Class<K> keyClass, 
		final Class<V> valueClass, 
		final boolean isBidirectional, 
		final String columnFamilyName) {
	_factory = (CumulusDataAccessLayerFactory) factory;
	_keyspace = _factory.getKeyspace();
	
	_serializer_k = SerializerTypeInferer.getSerializer(keyClass);
	_serializer_v = SerializerTypeInferer.getSerializer(valueClass);
	
	_isBidirectional = isBidirectional;
	_cf_name = columnFamilyName;
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
@SuppressWarnings({ "rawtypes", "unchecked" })
public static <T> Serializer<T> getSerializer(Class<?> valueClass) {
  Serializer serializer = null;
  if (valueClass.equals(Utf8.class)) {
    serializer = Utf8Serializer.get();
  } else if (valueClass.equals(Boolean.class) || valueClass.equals(boolean.class)) {
    serializer = BooleanSerializer.get();
  } else if (valueClass.equals(ByteBuffer.class)) {
    serializer = ByteBufferSerializer.get();
  } else if (valueClass.equals(Double.class) || valueClass.equals(double.class)) {
    serializer = DoubleSerializer.get();
  } else if (valueClass.equals(Float.class) || valueClass.equals(float.class)) {
    serializer = FloatSerializer.get();
  } else if (valueClass.equals(Integer.class) || valueClass.equals(int.class)) {
    serializer = IntegerSerializer.get();
  } else if (valueClass.equals(Long.class) || valueClass.equals(long.class)) {
    serializer = LongSerializer.get();
  } else if (valueClass.equals(String.class)) {
    serializer = StringSerializer.get();
  } else {
    serializer = SerializerTypeInferer.getSerializer(valueClass);
  }
  return serializer;
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
public static <A, B> HColumn<A, B> column( final A name, final B value )
{

    return HFactory.createColumn( name, //
                                  value, //
                                  (Serializer<A>) SerializerTypeInferer.getSerializer( name ), //
                                  (Serializer<B>) SerializerTypeInferer.getSerializer( value ) );
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
@Override public <T> Serializer<T> getSerializerForObject(Object obj) {
    if (obj != null && obj.getClass().isEnum()) {
        return new EnumSerializer(obj.getClass());
    }
    return SerializerTypeInferer.getSerializer(obj);
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
@Override public <T> Serializer<T> getSerializerForClass(Class clazz) {
    if (clazz.isEnum()) {
        return new EnumSerializer(clazz);
    }
    return SerializerTypeInferer.getSerializer(clazz);
}
 

import me.prettyprint.cassandra.serializers.SerializerTypeInferer; //导入依赖的package包/类
/**
 * Returns the {@link Serializer} associated with a given class.
 * 
 * @param clazz the class.
 * @param <T> the class kind.
 * @return the {@link Serializer} associated with a given class.
 */
public static <T> Serializer<T> guessSerializer(final Class<T> clazz) {
	return SerializerTypeInferer.getSerializer(clazz);
}