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.