Skip to content

Commit 155524d

Browse files
llingllinggit
authored andcommitted
fixup JavaDoc issue for splitters #1246
1 parent 9a84f6e commit 155524d

File tree

4 files changed

+19
-16
lines changed

4 files changed

+19
-16
lines changed

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/JSONSplitter.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public long getCount() {
9696
* Takes an InputStream of a JSON file and split it into a steam of handles.
9797
* @param input is the incoming InputStream of a JSON file.
9898
* @return a stream of handles to write to database
99-
* @throws IOException
99+
* @throws IOException if the input cannot be split
100100
*/
101101
@Override
102102
public Stream<T> split(InputStream input) throws IOException {
@@ -112,7 +112,7 @@ public Stream<T> split(InputStream input) throws IOException {
112112
* Takes an InputStream of a JSON file and split it into a steam of DocumentWriteOperation to write to database.
113113
* @param input is the incoming input stream of a JSON file
114114
* @return a stream of DocumentWriteOperation to write to database
115-
* @throws Exception
115+
* @throws Exception if the input cannot be split
116116
*/
117117
@Override
118118
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) throws Exception {
@@ -126,7 +126,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) th
126126
* @param inputName is the name of input file, including name and extension. It is used to generate URLs for split
127127
* files.The inputName could either be provided here or in user-defined UriMaker.
128128
* @return a stream of DocumentWriteOperation to write to database
129-
* @throws Exception
129+
* @throws Exception if the input cannot be split
130130
*/
131131
@Override
132132
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, String inputName) throws Exception {
@@ -142,7 +142,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, St
142142
* Take an input of JsonParser created from the JSON file and split it into a stream of handles to write to database.
143143
* @param input JsonParser created from the JSON file
144144
* @return a stream of handles to write to database
145-
* @throws IOException
145+
* @throws IOException if the input cannot be split
146146
*/
147147
public Stream<T> split(JsonParser input) throws IOException {
148148
if (input == null) {
@@ -229,6 +229,7 @@ public void endArray(String containerKey) {
229229
/**
230230
* Construct buffered DocumentWriteOperations from the handle which contains target content
231231
* @param uriMaker the UriMake to construct the URI for each document
232+
* @param count the count of each split
232233
* @param handle the handle contains target object or array
233234
* @return DocumentWriteOperations to write to database
234235
*/

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/LineSplitter.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public long getCount() {
6969
* Provide GZIPInputStream to the splitter when splitting gzip files.
7070
* @param input is the incoming input stream.
7171
* @return a stream of StringHandle.
72-
* @throws IOException
72+
* @throws IOException if the input cannot be split
7373
*/
7474
@Override
7575
public Stream<StringHandle> split(InputStream input) throws IOException {
@@ -82,7 +82,7 @@ public Stream<StringHandle> split(InputStream input) throws IOException {
8282
* Provide GZIPInputStream to the splitter when splitting gzip files.
8383
* @param input is the incoming input stream.
8484
* @return a stream of DocumentWriteOperation.
85-
* @throws Exception
85+
* @throws Exception if the input cannot be split
8686
*/
8787
@Override
8888
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) throws Exception {
@@ -97,7 +97,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) th
9797
* @param splitFilename is the name of the input file, including name and extension. It is used to generate URLs for
9898
* split files. The inputName could either be provided here or in user-defined UriMaker.
9999
* @return a stream of DocumentWriteOperation.
100-
* @throws Exception
100+
* @throws Exception if the input cannot be split
101101
*/
102102
@Override
103103
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, String splitFilename) throws Exception {
@@ -143,7 +143,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, St
143143
* @param input is the incoming input stream.
144144
* @param charset is the encoding scheme the document uses.
145145
* @return a stream of StringHandle.
146-
* @throws IOException
146+
* @throws IOException if the input cannot be split
147147
*/
148148
public Stream<StringHandle> split(InputStream input, Charset charset) throws IOException {
149149
if (input == null) {
@@ -160,7 +160,7 @@ public Stream<StringHandle> split(InputStream input, Charset charset) throws IOE
160160
* line-delimited JSON file, line-delimited XML file or gzip-compressed line-delimited JSON file.
161161
* @param input is the incoming Reader.
162162
* @return a stream of StringHandle.
163-
* @throws IOException
163+
* @throws IOException if the input cannot be split
164164
*/
165165
public Stream<StringHandle> split(Reader input) throws IOException {
166166
if (input == null) {

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/XMLSplitter.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -97,8 +97,8 @@ public void setVisitor(XMLSplitter.Visitor<T> visitor) {
9797
* Takes an input stream of an XML file and split it into a steam of handles.
9898
* @param input is the incoming input stream of an XML file
9999
* @return a stream of handles to write to database
100-
* @throws IOException
101-
* @throws XMLStreamException
100+
* @throws IOException if the input cannot be split
101+
* @throws XMLStreamException if there is an error processing the underlying XML source
102102
*/
103103
@Override
104104
public Stream<T> split(InputStream input) throws IOException, XMLStreamException {
@@ -114,7 +114,7 @@ public Stream<T> split(InputStream input) throws IOException, XMLStreamException
114114
* Takes an input stream of an XML file and split it into a steam of DocumentWriteOperation.
115115
* @param input is the incoming input stream.
116116
* @return a stream of DocumentWriteOperation to write to database
117-
* @throws Exception
117+
* @throws Exception if the input cannot be split
118118
*/
119119
@Override
120120
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) throws Exception {
@@ -127,7 +127,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) th
127127
* @param inputName is the name of input file, including name and extension. It is used to generate URLs for split
128128
* files.The inputName could either be provided here or in user-defined UriMaker.
129129
* @return a stream of DocumentWriteOperation to write to database
130-
* @throws Exception
130+
* @throws Exception if the input cannot be split
131131
*/
132132
@Override
133133
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, String inputName) throws Exception {
@@ -148,7 +148,7 @@ public long getCount() {
148148
* Take an input of XMLStreamReader of the XML file and split it into a stream of handles to write to database.
149149
* @param input an XMLStreamReader of the XML file
150150
* @return a stream of handles to write to database
151-
* @throws IOException
151+
* @throws IOException if the input cannot be split
152152
*/
153153
public Stream<T> split(XMLStreamReader input) throws IOException {
154154

@@ -242,6 +242,8 @@ public void endElement(String nsUri, String localName) {
242242

243243
/**
244244
* Construct buffered DocumentWriteOperations from XMLStreamReader
245+
* @param uriMaker the UriMake to construct the URI for each document
246+
* @param count the count of each split
245247
* @param handle the handle contains target elements as content
246248
* @return DocumentWriteOperations to write to database
247249
*/

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/ZipSplitter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ public Stream<BytesHandle> split(ZipInputStream input) throws IOException {
159159
* The ZIP file could contain XML, JSON, TXT and BINARY files.
160160
* @param input is the incoming input stream.
161161
* @return a stream of DocumentWriteOperation
162-
* @throws Exception
162+
* @throws Exception if the input cannot be split
163163
*/
164164
@Override
165165
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) throws Exception {
@@ -174,7 +174,7 @@ public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) th
174174
* @param inputName is the input file name, including name and extension. It is used to generate URLs for split
175175
* files.The inputName could either be provided here or in user-defined UriMaker.
176176
* @return a stream of DocumentWriteOperation
177-
* @throws Exception
177+
* @throws Exception if the input cannot be split
178178
*/
179179
@Override
180180
public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, String inputName) throws Exception {

0 commit comments

Comments
 (0)