flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [487:504]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                DataStream<IN> input, TypeInformation<IN> typeInfo, TypeSerializer<IN> serializer) {
            super(input, typeInfo, serializer);
        }

        @Override
        protected void sanityCheck() {
            super.sanityCheck();
            if (query == null || query.length() == 0) {
                throw new IllegalArgumentException("Query must not be null or empty.");
            }
            if (keyspace != null) {
                throw new IllegalArgumentException(
                        "Specifying a default keyspace is only allowed when using a Pojo-Stream as input.");
            }
        }

        @Override
        public CassandraSink<IN> createSink() throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [633:650]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                DataStream<IN> input, TypeInformation<IN> typeInfo, TypeSerializer<IN> serializer) {
            super(input, typeInfo, serializer);
        }

        @Override
        protected void sanityCheck() {
            super.sanityCheck();
            if (query == null || query.length() == 0) {
                throw new IllegalArgumentException("Query must not be null or empty.");
            }
            if (keyspace != null) {
                throw new IllegalArgumentException(
                        "Specifying a default keyspace is only allowed when using a Pojo-Stream as input.");
            }
        }

        @Override
        public CassandraSink<IN> createSink() throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -