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