本文整理了Java中com.datastax.driver.core.TypeCodec.getCqlType()方法的一些代码示例，展示了TypeCodec.getCqlType()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TypeCodec.getCqlType()方法的具体详情如下：
包路径：com.datastax.driver.core.TypeCodec
类名称：TypeCodec
方法名：getCqlType

TypeCodec.getCqlType介绍

[英]Return the CQL type that this codec deserializes from and serializes to.
[中]返回此编解码器从中反序列化并序列化到的CQL类型。

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public AddressCodec(TypeCodec<UDTValue> innerCodec, Class<Address> javaType) {
 super(innerCodec, javaType);
 userType = (UserType) innerCodec.getCqlType();
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public LocationCodec(TypeCodec<TupleValue> innerCodec) {
 super(innerCodec, Location.class);
 tupleType = (TupleType) innerCodec.getCqlType();
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public MappingCodec(TypeCodec<I> innerCodec, TypeToken<O> javaType) {
 super(innerCodec.getCqlType(), javaType);
 this.innerCodec = innerCodec;
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public PhoneCodec(TypeCodec<UDTValue> innerCodec, Class<Phone> javaType) {
 super(innerCodec, javaType);
 userType = (UserType) innerCodec.getCqlType();
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

protected AbstractMapCodec(TypeCodec<K> keyCodec, TypeCodec<V> valueCodec) {
 super(
   DataType.map(keyCodec.getCqlType(), valueCodec.getCqlType()),
   TypeTokens.mapOf(keyCodec.getJavaType(), valueCodec.getJavaType()));
 this.keyCodec = keyCodec;
 this.valueCodec = valueCodec;
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

private ListCodec(TypeCodec<T> eltCodec) {
 super(
   DataType.list(eltCodec.getCqlType()),
   TypeTokens.listOf(eltCodec.getJavaType()),
   eltCodec);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

private <T> TypeCodec<T> mockCodec(DataType cqlType, TypeToken<T> javaType) {
  @SuppressWarnings("unchecked")
  TypeCodec<T> newCodec = mock(TypeCodec.class);
  when(newCodec.getCqlType()).thenReturn(cqlType);
  when(newCodec.getJavaType()).thenReturn(javaType);
  when(newCodec.accepts(cqlType)).thenReturn(true);
  when(newCodec.accepts(javaType)).thenReturn(true);
  when(newCodec.toString()).thenReturn(String.format("MockCodec [%s <-> %s]", cqlType, javaType));
  return newCodec;
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
 public <T> T get(int i, TypeCodec<T> codec) {
  checkType(i, codec.getCqlType().getName());
  ByteBuffer value = getValue(i);
  return codec.deserialize(value, protocolVersion);
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public <V> T set(int i, V v, TypeCodec<V> codec) {
 checkType(i, codec.getCqlType().getName());
 return setValue(i, codec.serialize(v, protocolVersion));
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public <V> T set(int i, V v, TypeCodec<V> codec) {
 checkType(i, codec.getCqlType().getName());
 return setValue(i, codec.serialize(v, protocolVersion));
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

if (oldCodec.accepts(newCodec.getCqlType()) && oldCodec.accepts(newCodec.getJavaType())) {
  logger.warn(
    "Ignoring codec {} because it collides with previously registered codec {}",
 if (oldCodec.accepts(newCodec.getCqlType()) && oldCodec.accepts(newCodec.getJavaType())) {
  logger.warn(
    "Ignoring codec {} because it collides with previously registered codec {}",
CacheKey key = new CacheKey(newCodec.getCqlType(), newCodec.getJavaType());
TypeCodec<?> existing = cache.getIfPresent(key);
if (existing != null) {

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

protected NumberBoxCodec(TypeCodec<T> numberCodec) {
 // @formatter:off
 super(
   numberCodec.getCqlType(),
   new TypeToken<NumberBox<T>>() {}.where(
     new TypeParameter<T>() {}, numberCodec.getJavaType()));
 // @formatter:on
 this.numberCodec = numberCodec;
}

代码示例来源：origin: apache/apex-malhar

public AddressCodec(TypeCodec<UDTValue> innerCodec, Class<Address> javaType)
{
 super(innerCodec.getCqlType(), javaType);
 this.innerCodec = innerCodec;
 this.userType = (UserType)innerCodec.getCqlType();
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

public LocationCodec(TypeCodec<TupleValue> innerCodec) {
 super(innerCodec, Location.class);
 tupleType = (TupleType) innerCodec.getCqlType();
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

private static UDTValue newUDTValue(TypeCodec<Object> codec)
{
  DataType dataType = codec.getCqlType();
  return newUDTValue(dataType);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

assertThat(actual.getCqlType()).isEqualTo(expected.getCqlType());
assertThat(actual.getJavaType()).isEqualTo(expected.getJavaType());
assertThat(actualB.getCqlType()).isEqualTo(expectedB.getCqlType());
assertThat(actualB.getJavaType()).isEqualTo(expectedB.getJavaType());

代码示例来源：origin: org.apache.cassandra/cassandra-all

public static ByteBuffer serialize(TypeCodec<?> codec, ProtocolVersion protocolVersion, Object value)
{
  if (!codec.getJavaType().getRawType().isAssignableFrom(value.getClass()))
    throw new InvalidTypeException("Invalid value for CQL type " + codec.getCqlType().getName().toString());
  return ((TypeCodec)codec).serialize(value, com.datastax.driver.core.ProtocolVersion.fromInt(protocolVersion.asInt()));
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

private <T> TypeCodec<T> mockCodec(DataType cqlType, TypeToken<T> javaType) {
  @SuppressWarnings("unchecked")
  TypeCodec<T> newCodec = mock(TypeCodec.class);
  when(newCodec.getCqlType()).thenReturn(cqlType);
  when(newCodec.getJavaType()).thenReturn(javaType);
  when(newCodec.accepts(cqlType)).thenReturn(true);
  when(newCodec.accepts(javaType)).thenReturn(true);
  when(newCodec.toString()).thenReturn(String.format("MockCodec [%s <-> %s]", cqlType, javaType));
  return newCodec;
 }
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

@Override
public <V> T set(int i, V v, TypeCodec<V> codec) {
  checkType(i, codec.getCqlType().getName());
  return setValue(i, codec.serialize(v, protocolVersion));
}

代码示例来源：origin: jsevellec/cassandra-unit

public static ByteBuffer serialize(TypeCodec<?> codec, ProtocolVersion protocolVersion, Object value)
{
  if (!codec.getJavaType().getRawType().isAssignableFrom(value.getClass()))
    throw new InvalidTypeException("Invalid value for CQL type " + codec.getCqlType().getName().toString());
  return ((TypeCodec)codec).serialize(value, com.datastax.driver.core.ProtocolVersion.fromInt(protocolVersion.asInt()));
}