| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.mapping | |
| com.datastax.oss.dsbulk.workflow.commons.schema |
| Modifier and Type | Field and Description |
|---|---|
static CQLWord |
MappingInspector.STAR |
static CQLWord |
MappingInspector.TTL |
static CQLWord |
MappingInspector.WRITETIME |
| Modifier and Type | Method and Description |
|---|---|
static CQLWord |
CQLWord.fromCql(String cql)
Creates an identifier from its
CQL form. |
static CQLWord |
CQLWord.fromCqlIdentifier(CqlIdentifier identifier)
Creates an identifier from a
CqlIdentifier. |
static CQLWord |
CQLWord.fromInternal(String internal)
Creates an identifier from its
internal form. |
CQLWord |
FunctionCall.getFunctionName() |
CQLWord |
MappingInspector.visitColumnName(com.datastax.oss.dsbulk.generated.mapping.MappingParser.ColumnNameContext ctx) |
CQLWord |
MappingInspector.visitFunctionName(com.datastax.oss.dsbulk.generated.mapping.MappingParser.FunctionNameContext ctx) |
CQLWord |
MappingInspector.visitIdentifier(com.datastax.oss.dsbulk.generated.mapping.MappingParser.IdentifierContext ctx) |
CQLWord |
MappingInspector.visitKeyspaceName(com.datastax.oss.dsbulk.generated.mapping.MappingParser.KeyspaceNameContext ctx) |
CQLWord |
MappingInspector.visitVariable(com.datastax.oss.dsbulk.generated.mapping.MappingParser.VariableContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
Set<CQLWord> |
Mapping.fieldToVariables(Field field)
Maps the given field to one or more variables in a write bound statement.
|
Set<CQLWord> |
DefaultMapping.fieldToVariables(Field field) |
List<CQLWord> |
MappingInspector.getExcludedVariables() |
Optional<CQLWord> |
FunctionCall.getKeyspaceName() |
Set<CQLWord> |
Mapping.variables()
Returns all the variables in this mapping.
|
Set<CQLWord> |
DefaultMapping.variables() |
| Modifier and Type | Method and Description |
|---|---|
<T> TypeCodec<T> |
Mapping.codec(CQLWord variable,
DataType cqlType,
GenericType<? extends T> javaType)
Returns the codec to use for the given bound statement or row variable.
|
<T> TypeCodec<T> |
DefaultMapping.codec(CQLWord variable,
DataType cqlType,
GenericType<? extends T> javaType) |
Set<Field> |
Mapping.variableToFields(CQLWord variable)
Maps the given row variable to one or more fields in a record.
|
Set<Field> |
DefaultMapping.variableToFields(CQLWord variable) |
| Constructor and Description |
|---|
FunctionCall(CQLWord keyspaceName,
CQLWord functionName,
CQLFragment... args) |
FunctionCall(CQLWord keyspaceName,
CQLWord functionName,
List<CQLFragment> args) |
| Constructor and Description |
|---|
DefaultMapping(com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSetMultimap<Field,CQLWord> fieldsToVariables,
ConvertingCodecFactory codecFactory,
com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet<CQLWord> writeTimeVariables) |
DefaultMapping(com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSetMultimap<Field,CQLWord> fieldsToVariables,
ConvertingCodecFactory codecFactory,
com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet<CQLWord> writeTimeVariables) |
MappingInspector(String mapping,
boolean write,
MappingPreference mappingPreference,
Supplier<CQLWord> usingTimestampVariable,
Supplier<CQLWord> usingTTLVariable)
Deprecated.
As of DSBulk 1.8.0, the mapping inspector deprecates the special __ttl and
__timestamp tokens; these will be removed in a future release. Therefore, providing
external names for these tokens will also cease to be supported in a future release.
|
MappingInspector(String mapping,
boolean write,
MappingPreference mappingPreference,
Supplier<CQLWord> usingTimestampVariable,
Supplier<CQLWord> usingTTLVariable)
Deprecated.
As of DSBulk 1.8.0, the mapping inspector deprecates the special __ttl and
__timestamp tokens; these will be removed in a future release. Therefore, providing
external names for these tokens will also cease to be supported in a future release.
|
| Modifier and Type | Field and Description |
|---|---|
static CQLWord |
QueryInspector.INTERNAL_TIMESTAMP_VARNAME |
static CQLWord |
QueryInspector.INTERNAL_TTL_VARNAME |
| Modifier and Type | Method and Description |
|---|---|
CQLWord |
QueryInspector.getTableName() |
CQLWord |
QueryInspector.visitAllowedFunctionName(com.datastax.oss.dsbulk.generated.cql3.CqlParser.AllowedFunctionNameContext ctx) |
CQLWord |
QueryInspector.visitCfName(com.datastax.oss.dsbulk.generated.cql3.CqlParser.CfNameContext ctx) |
CQLWord |
QueryInspector.visitCident(com.datastax.oss.dsbulk.generated.cql3.CqlParser.CidentContext ctx) |
CQLWord |
QueryInspector.visitKeyspaceName(com.datastax.oss.dsbulk.generated.cql3.CqlParser.KeyspaceNameContext ctx) |
CQLWord |
QueryInspector.visitKsName(com.datastax.oss.dsbulk.generated.cql3.CqlParser.KsNameContext ctx) |
CQLWord |
QueryInspector.visitNoncolIdent(com.datastax.oss.dsbulk.generated.cql3.CqlParser.NoncolIdentContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap<CQLWord,CQLFragment> |
QueryInspector.getAssignments() |
Optional<CQLWord> |
QueryInspector.getKeyspaceName() |
Optional<CQLWord> |
QueryInspector.getTokenRangeRestrictionEndVariable() |
Optional<CQLWord> |
QueryInspector.getTokenRangeRestrictionStartVariable() |
Optional<CQLWord> |
QueryInspector.getUsingTimestampVariable()
Returns the variable name used in a USING TIMESTAMP clause; or empty if no such clause or no
such variable.
|
Optional<CQLWord> |
QueryInspector.getUsingTTLVariable()
Returns the variable name used in a USING TTL clause; or empty if no such clause or no such
variable.
|
| Modifier and Type | Method and Description |
|---|---|
static InvalidMappingException |
InvalidMappingException.emptyPrimaryKey(CQLWord variable) |
static InvalidMappingException |
InvalidMappingException.encodeFailed(Field field,
CQLWord variable,
GenericType<?> fieldType,
DataType cqlType,
Object raw,
Exception cause) |
static InvalidMappingException |
InvalidMappingException.missingField(Field field,
CQLWord variable) |
static InvalidMappingException |
InvalidMappingException.nullPrimaryKey(CQLWord variable) |
static InvalidMappingException |
InvalidMappingException.unsetPrimaryKey(CQLWord variable) |
| Constructor and Description |
|---|
DefaultRecordMapper(PreparedStatement insertStatement,
Set<CQLWord> partitionKeyVariables,
Set<CQLWord> clusteringColumnVariables,
ProtocolVersion protocolVersion,
Mapping mapping,
RecordMetadata recordMetadata,
boolean nullToUnset,
boolean allowExtraFields,
boolean allowMissingFields) |
DefaultRecordMapper(PreparedStatement insertStatement,
Set<CQLWord> partitionKeyVariables,
Set<CQLWord> clusteringColumnVariables,
ProtocolVersion protocolVersion,
Mapping mapping,
RecordMetadata recordMetadata,
boolean nullToUnset,
boolean allowExtraFields,
boolean allowMissingFields) |
Copyright © 2017–2021 DataStax. All rights reserved.