pyflink.datastream.connectors.cassandra.MapperOptions#
- class MapperOptions[source]#
This class is used to configure a Mapper after deployment.
Methods
consistency_level
(cl)Creates a new Option object to add a consistency level value to a mapper operation.
if_not_exists
(enabled)Creates a new Option object to specify whether an IF NOT EXISTS clause should be included in insert queries.
save_null_fields
(enabled)Creates a new Option object to specify whether null entity fields should be included in insert queries.
timestamp
(timestamp)Creates a new Option object to add a timestamp to a mapper operation.
tracing
(enabled)Creates a new Option object to enable query tracing for a mapper operation.
ttl
(ttl)Creates a new Option object to add time-to-live to a mapper operation.