Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

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
Show Source

Created using Sphinx 5.3.0.