Sha256: a81bdb942f5e9f727a7c280626c25af7d949dd8a04ee94aa4cf84647da580f0c
Contents?: true
Size: 675 Bytes
Versions: 4
Compression:
Stored size: 675 Bytes
Contents
package org.embulk.output.cassandra.setter; import com.datastax.driver.core.BoundStatement; import com.datastax.driver.core.ColumnMetadata; import org.msgpack.value.Value; public class ListColumnSetter extends CassandraColumnSetter { public ListColumnSetter(ColumnMetadata cassandraColumn) { super(cassandraColumn); } @Override public void setJsonValue(Value value, BoundStatement statement) { if (!value.isArrayValue()) { throw new RuntimeException(value.toJson() + " is not array value"); } statement.setList(cassandraColumn.getName(), ValueConverter.convertList(value.asArrayValue().list())); } }
Version data entries
4 entries across 4 versions & 1 rubygems