Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Asynchronous I/O
    • Connectors
    • Formats
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink DataStream
  • Connectors
  • pyflink.datastream.connectors.cassandra.MapperOptions

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.

previous

pyflink.datastream.connectors.cassandra.ConsistencyLevel

next

pyflink.datastream.connectors.cassandra.ClusterBuilder

On this page
  • MapperOptions

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.