File tree Expand file tree Collapse file tree 2 files changed +13
-1
lines changed
marklogic-client-api/src/main/java/com/marklogic/client/datamovement Expand file tree Collapse file tree 2 files changed +13
-1
lines changed Original file line number Diff line number Diff line change @@ -77,6 +77,12 @@ private CsvMapper configureCsvMapper() {
7777 return csvMapper ;
7878 }
7979
80+ /*
81+ * Takes the input stream and converts it into a stream of JacksonHandle by setting the schema
82+ * and wrapping the JsonNode into JacksonHandle.
83+ * @param input the input stream passed in.
84+ * @return a stream of JacksonHandle.
85+ */
8086 @ Override
8187 public Stream <JacksonHandle > split (InputStream input ) throws Exception {
8288
@@ -86,6 +92,12 @@ public Stream<JacksonHandle> split(InputStream input) throws Exception {
8692 return configureInput (configureObjReader ().readValues (input ));
8793 }
8894
95+ /*
96+ * Takes the input stream and converts it into a stream of JacksonHandle by setting the schema
97+ * and wrapping the JsonNode into JacksonHandle.
98+ * @param input the Reader stream passed in.
99+ * @return a stream of JacksonHandle.
100+ */
89101 public Stream <JacksonHandle > split (Reader input ) throws Exception {
90102
91103 if (input == null ) {
Original file line number Diff line number Diff line change @@ -74,7 +74,7 @@ public interface WriteBatcher extends Batcher {
7474 WriteBatcher withDefaultMetadata (DocumentMetadataHandle handle );
7575
7676 /**
77- * Writes a document to the database for each row in the csv and keeps track of the number of documents written .
77+ * Writes a document stream to the database.
7878 * @param operations is the DocumentWriteOperation stream passed in.
7979 */
8080 void addAll (Stream <? extends DocumentWriteOperation > operations );
You can’t perform that action at this time.
0 commit comments