flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java [48:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private static final long serialVersionUID = 1L;

    protected transient Cluster cluster;
    protected transient Session session;

    private final String insertQuery;
    private transient PreparedStatement preparedStatement;

    private ClusterBuilder builder;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java [50:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private static final long serialVersionUID = 1L;

    protected transient Cluster cluster;
    protected transient Session session;

    private final String insertQuery;
    private transient PreparedStatement preparedStatement;

    private ClusterBuilder builder;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -