Sha256: ac61ba7a5c6c8467fb9b42172c1a7647e37cc1ea45e81c3aca03202f0f1dd838
Contents?: true
Size: 1.17 KB
Versions: 4
Compression:
Stored size: 1.17 KB
Contents
package org.embulk.output.cassandra.setter;
import com.datastax.driver.core.BoundStatement;
import com.datastax.driver.core.ColumnMetadata;
import java.math.BigInteger;
public class VarintColumnSetter extends CassandraColumnSetter
{
public VarintColumnSetter(ColumnMetadata cassandraColumn)
{
super(cassandraColumn);
}
@Override
public void setBooleanValue(Boolean value, BoundStatement statement)
{
if (value) {
statement.setVarint(cassandraColumn.getName(), BigInteger.ONE);
}
else {
statement.setVarint(cassandraColumn.getName(), BigInteger.ZERO);
}
}
@Override
public void setLongValue(Long value, BoundStatement statement)
{
statement.setVarint(cassandraColumn.getName(), BigInteger.valueOf(value));
}
@Override
public void setDoubleValue(Double value, BoundStatement statement)
{
statement.setVarint(cassandraColumn.getName(), BigInteger.valueOf(value.longValue()));
}
@Override
public void setStringValue(String value, BoundStatement statement)
{
statement.setVarint(cassandraColumn.getName(), new BigInteger(value));
}
}
Version data entries
4 entries across 4 versions & 1 rubygems