Sha256: c03d9018462273d664a9ed37038767796bed2f93e54a879309015d7aa08403fc
Contents?: true
Size: 1.07 KB
Versions: 4
Compression:
Stored size: 1.07 KB
Contents
package org.embulk.output.cassandra.setter; import com.datastax.driver.core.BoundStatement; import com.datastax.driver.core.ColumnMetadata; public class BigintColumnSetter extends CassandraColumnSetter { public BigintColumnSetter(ColumnMetadata cassandraColumn) { super(cassandraColumn); } @Override public void setBooleanValue(Boolean value, BoundStatement statement) { if (value) { statement.setLong(cassandraColumn.getName(), 1); } else { statement.setLong(cassandraColumn.getName(), 0); } } @Override public void setLongValue(Long value, BoundStatement statement) { statement.setLong(cassandraColumn.getName(), value); } @Override public void setDoubleValue(Double value, BoundStatement statement) { statement.setLong(cassandraColumn.getName(), value.longValue()); } @Override public void setStringValue(String value, BoundStatement statement) { statement.setLong(cassandraColumn.getName(), Long.parseLong(value)); } }
Version data entries
4 entries across 4 versions & 1 rubygems