Sha256: b3ca9d1b1bad20a57523153a8862909d97c49fc20091f82650204287105f093a
Contents?: true
Size: 984 Bytes
Versions: 4
Compression:
Stored size: 984 Bytes
Contents
package org.embulk.output.cassandra.setter; import com.datastax.driver.core.BoundStatement; import com.datastax.driver.core.ColumnMetadata; import org.embulk.spi.time.Timestamp; import java.time.LocalDate; public class DateColumnSetter extends CassandraColumnSetter { public DateColumnSetter(ColumnMetadata cassandraColumn) { super(cassandraColumn); } @Override public void setStringValue(String value, BoundStatement statement) { LocalDate date = LocalDate.parse(value); statement.setDate(cassandraColumn.getName(), com.datastax.driver.core.LocalDate.fromYearMonthDay(date.getYear(), date.getMonthValue(), date.getDayOfMonth())); } @Override public void setTimestampValue(Timestamp value, BoundStatement statement) { com.datastax.driver.core.LocalDate date = com.datastax.driver.core.LocalDate.fromMillisSinceEpoch(value.toEpochMilli()); statement.setDate(cassandraColumn.getName(), date); } }
Version data entries
4 entries across 4 versions & 1 rubygems