Package | Description |
---|---|
org.apache.flink.streaming.connectors.cassandra |
Modifier and Type | Method and Description |
---|---|
SimpleMapperOptions |
SimpleMapperOptions.consistencyLevel(com.datastax.driver.core.ConsistencyLevel cl)
Adds a consistency level value option to a mapper operation.
|
SimpleMapperOptions |
SimpleMapperOptions.ifNotExists(boolean enabled)
Specifies whether an IF NOT EXISTS clause should be included in insert queries.
|
SimpleMapperOptions |
SimpleMapperOptions.saveNullFields(boolean enabled)
Specifies whether null entity fields should be included in insert queries.
|
SimpleMapperOptions |
SimpleMapperOptions.timestamp(long timestamp)
Adds a timestamp option to a mapper operation.
|
SimpleMapperOptions |
SimpleMapperOptions.tracing(boolean enabled)
Enables query tracing for a mapper operation.
|
SimpleMapperOptions |
SimpleMapperOptions.ttl(int ttl)
Adds time-to-live option to a mapper operation.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.