com.datastax.oss.dsbulk.workflow.commons.settings

Class SchemaSettings

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

public class SchemaSettings
extends Object

Constructor Summary

Constructors

Constructor and Description
SchemaSettings(Config config, SchemaGenerationStrategy schemaGenerationStrategy)

Method Summary

Modifier and Type	Method and Description
ReadResultCounter	createReadResultCounter(CqlSession session, ConvertingCodecFactory codecFactory, EnumSet<StatsSettings.StatisticsMode> modes, int numPartitions)
ReadResultMapper	createReadResultMapper(CqlSession session, RecordMetadata recordMetadata, ConvertingCodecFactory codecFactory, boolean retainRecordSources) Creates a new ReadResultMapper.
List<Statement<?>>	createReadStatements(CqlSession session)
RecordMapper	createRecordMapper(CqlSession session, RecordMetadata recordMetadata, ConvertingCodecFactory codecFactory)
RowType	getRowType()
RelationMetadata	getTargetTable()
void	init(CqlSession session, boolean indexedMappingSupported, boolean mappedMappingSupported)
boolean	isAllowExtraFields()
boolean	isAllowMissingFields()
boolean	isBatchQuery()
boolean	isSearchQuery()

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaSettings

public SchemaSettings(Config config,
                      SchemaGenerationStrategy schemaGenerationStrategy)

Method Detail

init

public void init(CqlSession session,
                 boolean indexedMappingSupported,
                 boolean mappedMappingSupported)

createRecordMapper

public RecordMapper createRecordMapper(CqlSession session,
                                       RecordMetadata recordMetadata,
                                       ConvertingCodecFactory codecFactory)
                                throws IllegalArgumentException

Throws:

IllegalArgumentException

createReadResultMapper

public ReadResultMapper createReadResultMapper(CqlSession session,
                                               RecordMetadata recordMetadata,
                                               ConvertingCodecFactory codecFactory,
                                               boolean retainRecordSources)

Creates a new ReadResultMapper.

Parameters:

session - The session to use when preparing the SELECT statement.

recordMetadata - The RecordMetadata to use for column mappings.

codecFactory - The ConvertingCodecFactory to use to locate codecs for the mapping operation.

retainRecordSources - Whether the mapper should retain record sources; if true, all emitted records will contain the original row as their sources.

createReadResultCounter

public ReadResultCounter createReadResultCounter(CqlSession session,
                                                 ConvertingCodecFactory codecFactory,
                                                 EnumSet<StatsSettings.StatisticsMode> modes,
                                                 int numPartitions)

createReadStatements

public List<Statement<?>> createReadStatements(CqlSession session)

getRowType

@NonNull
public RowType getRowType()

getTargetTable

@NonNull
public RelationMetadata getTargetTable()

isAllowExtraFields

public boolean isAllowExtraFields()

isAllowMissingFields

public boolean isAllowMissingFields()

isSearchQuery

public boolean isSearchQuery()

isBatchQuery

public boolean isBatchQuery()