connector/src/it/scala/com/datastax/spark/connector/cql/sai/IndexedMapSpec.scala (4 lines): - line 60: // TODO: SPARKC-630 - line 76: // TODO: SPARKC-630 - line 92: // TODO: SPARKC-630 - line 113: // TODO: SPARKC-630: Unsupported literal type class scala.collection.immutable.Map$Map1 Map(102 -> 112) connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/ReplicaPartitioner.scala (2 lines): - line 51: val _keyspace = CqlIdentifier.fromInternal(keyspace) // TODO Fix this - line 60: @transient lazy private val tokenMap = connector.withSessionDo(_.getMetadata.getTokenMap.get)//TODO Handle missing connector/src/it/scala/com/datastax/spark/connector/writer/ThrottlingSpec.scala (2 lines): - line 43: //TODO FIX This after we figure out profiles - line 56: /* TODO: connector/src/it/scala/com/datastax/spark/connector/rdd/CassandraRDDSpec.scala (2 lines): - line 1229: val poolingOptions = rdd.connector.withSessionDo(_.getContext.getConfig).getDefaultProfile //TODO we gotta do something here I suppose - line 1240: val poolingOptions = rdd.connector.withSessionDo(_.getContext.getConfig).getDefaultProfile //TODO we gotta do something here I suppose connector/src/it/scala/com/datastax/spark/connector/cql/sai/SaiCollectionBaseSpec.scala (2 lines): - line 35: // TODO: SPARKC-630 - line 42: // TODO: SPARKC-630 connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraScanPartitionReaderFactory.scala (1 line): - line 101: //Currently Does not take into account TODO filters or pruning connector/src/it/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGeneratorSpec.scala (1 line): - line 41: // TODO: Currently CassandraPartitionGenerator uses a size-based algorithm that doesn't guarantee exact connector/src/it/scala/com/datastax/spark/connector/writer/BoundStatementBuilderSpec.scala (1 line): - line 45: //TODO Switch to ```((InternalDriverContext)session.getContext()).getProtocolVersionRegistry()``` connector/src/main/scala/org/apache/spark/sql/cassandra/DsePredicateRules.scala (1 line): - line 82: // TODO: InClausePredicateRules is applied after DsePredicateRules, it may remove some of the IN clause from connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnectionFactory.scala (1 line): - line 120: .withBoolean(SSL_HOSTNAME_VALIDATION, false) // TODO: this needs to be configurable by users. Set to false for our integration tests connector/src/it/scala/com/datastax/spark/connector/sql/CassandraSQLSpec.scala (1 line): - line 575: //TODO: SPARK-9269 is opened to address Set matching issue. I change the Set data type to List for now driver/src/main/scala/com/datastax/spark/connector/util/AnyObjectFactory.scala (1 line): - line 23: // FIXME: driver/src/main/scala/com/datastax/spark/connector/util/DriverUtil.scala (1 line): - line 29: //TODO use CqlIdentifier instead? Use implicit conversion to String? To internal string? connector/src/it/scala/com/datastax/spark/connector/cql/sai/IndexedListSpec.scala (1 line): - line 59: // TODO: SPARKC-630 driver/src/main/scala/com/datastax/spark/connector/cql/Schema.scala (1 line): - line 404: private def systemKeyspaces = Set.empty[String] // TODO FIX THIS DriverUtil.getSystemKeyspaces(session) connector/src/it/scala/com/datastax/spark/connector/cql/sai/IndexedSetSpec.scala (1 line): - line 58: // TODO: SPARKC-630 connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala (1 line): - line 407: val queryFuture = session.executeAsync(queryRequest)//TODO THIS can be done in a more reactive way I believe driver/src/main/scala/com/datastax/spark/connector/mapper/JavaBeanColumnMapper.scala (1 line): - line 76: // TODO: Implement connector/src/main/scala/org/apache/spark/metrics/CassandraSink.scala (1 line): - line 79: // TODO consider improving performance of this method if it turns out slow connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala (1 line): - line 49: private val keyspaceName = CqlIdentifier.fromInternal(tableDef.keyspaceName) // TODO Lets fix all this later connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/NodeAddresses.scala (1 line): - line 46: // TODO: fetch information about the local node from system.local, when CASSANDRA-9436 is done