File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
src/main/java/com/marklogic/spark Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ reading data from and writing data to MarkLogic.
10
10
The connector has the following system requirements:
11
11
12
12
* Apache Spark 3.4.0 or higher; earlier versions of Spark 3.x may work but have not been tested.
13
- * For writing data, MarkLogic 9 or higher.
14
- * For reading data, MarkLogic 10.0-6 or higher.
13
+ * For writing data, MarkLogic 9.0-9 or higher.
14
+ * For reading data, MarkLogic 10.0-9 or higher.
15
15
16
16
Please see the [ Getting Started guide] ( getting-started/getting-started.md ) to begin using the connector.
Original file line number Diff line number Diff line change @@ -54,6 +54,7 @@ public StructType inferSchema(CaseInsensitiveStringMap options) {
54
54
RowManager rowManager = new ContextSupport (caseSensitiveOptions ).connectToMarkLogic ().newRowManager ();
55
55
RawQueryDSLPlan dslPlan = rowManager .newRawQueryDSLPlan (new StringHandle (query ));
56
56
try {
57
+ // columnInfo is what forces a minimum MarkLogic version of 10.0-9 or higher.
57
58
StringHandle columnInfoHandle = rowManager .columnInfo (dslPlan , new StringHandle ());
58
59
return SchemaInferrer .inferSchema (columnInfoHandle .get ());
59
60
} catch (Exception ex ) {
You can’t perform that action at this time.
0 commit comments