File tree Expand file tree Collapse file tree 4 files changed +5
-5
lines changed
spark-cassandra-connector-embedded/src/main/scala/com/datastax/spark/connector/embedded
spark-cassandra-connector/src/main/scala/com/datastax Expand file tree Collapse file tree 4 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ object Versions {
25
25
26
26
val Akka = " 2.3.4"
27
27
val Cassandra = " 3.11.3"
28
- val CassandraDriver = " 3.1.4 "
28
+ val CassandraDriver = " 3.7.2 "
29
29
val CommonsIO = " 2.4"
30
30
val CommonsLang3 = " 3.3.2"
31
31
val CommonsBeanUtils = " 1.9.3"
Original file line number Diff line number Diff line change @@ -47,11 +47,11 @@ object YamlTransformations {
47
47
48
48
private def readTemplate (): JMap [String , AnyRef ]@ unchecked = {
49
49
val exactTmplt =
50
- Option (ClassLoader .getSystemResourceAsStream (s " cassandra- $YamlTemplateVersion.yaml.template " ))
50
+ Option (getClass.getResourceAsStream (s " / cassandra- $YamlTemplateVersion.yaml.template " ))
51
51
lazy val fallbackTmplt = {
52
52
System .err.println(s " Warning: Using fallback template for Cassandra 3.2 because " +
53
53
s " the template for Cassandra $YamlTemplateVersion could not be found. " )
54
- Option (ClassLoader .getSystemResourceAsStream (s " cassandra-3.2.yaml.template " ))
54
+ Option (getClass.getResourceAsStream (s " / cassandra-3.2.yaml.template" ))
55
55
}
56
56
57
57
yaml.load(exactTmplt orElse fallbackTmplt orNull) match {
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ package com.datastax.driver.core
9
9
object PreparedIdWorkaround {
10
10
11
11
def getResultMetadata (preparedId : PreparedId ) = {
12
- preparedId.resultSetMetadata
12
+ preparedId.resultSetMetadata.variables
13
13
}
14
14
15
15
}
Original file line number Diff line number Diff line change @@ -132,7 +132,7 @@ object CassandraRowMetadata {
132
132
}
133
133
134
134
def fromPreparedId (columnNames : IndexedSeq [String ], ps : PreparedId ) = {
135
- fromColumnDefs(columnNames, PreparedIdWorkaround .getResultMetadata(ps).asList() )
135
+ fromColumnDefs(columnNames, PreparedIdWorkaround .getResultMetadata(ps).asList)
136
136
}
137
137
138
138
private def fromColumnDefs (columnNames : IndexedSeq [String ], columnDefs : java.util.List [Definition ]) = {
You can’t perform that action at this time.
0 commit comments