com.datastax.oss.dsbulk.workflow.commons.schema

Class DefaultRecordMapper

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.schema.DefaultRecordMapper

All Implemented Interfaces:

RecordMapper

public class DefaultRecordMapper
extends Object
implements RecordMapper

Constructor Summary

Constructors

Constructor and Description
DefaultRecordMapper(PreparedStatement insertStatement, Set<CQLWord> partitionKeyVariables, Set<CQLWord> clusteringColumnVariables, ProtocolVersion protocolVersion, Mapping mapping, RecordMetadata recordMetadata, boolean nullToUnset, boolean allowExtraFields, boolean allowMissingFields)

Method Summary

Modifier and Type	Method and Description
BatchableStatement<?>	map(Record record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultRecordMapper

public DefaultRecordMapper(PreparedStatement insertStatement,
                           Set<CQLWord> partitionKeyVariables,
                           Set<CQLWord> clusteringColumnVariables,
                           ProtocolVersion protocolVersion,
                           Mapping mapping,
                           RecordMetadata recordMetadata,
                           boolean nullToUnset,
                           boolean allowExtraFields,
                           boolean allowMissingFields)

Method Detail

map

@NonNull
public BatchableStatement<?> map(@NonNull
                                          Record record)

Specified by:

map in interface RecordMapper