Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports long-running write, read,
delete, or transform jobs.
|
com.marklogic.client.document |
The package provides classes for creating, retrieving, updating, and deleting
documents in the database for the REST server.
|
Modifier and Type | Method and Description |
---|---|
DocumentWriteOperation |
JSONSplitter.Visitor.makeDocumentWriteOperation(JSONSplitter.UriMaker uriMaker,
long count,
T handle)
Construct buffered DocumentWriteOperations from the handle which contains target content
|
DocumentWriteOperation |
XMLSplitter.Visitor.makeDocumentWriteOperation(XMLSplitter.UriMaker uriMaker,
long count,
T handle)
Construct buffered DocumentWriteOperations from XMLStreamReader
|
Modifier and Type | Method and Description |
---|---|
java.util.stream.Stream<DocumentWriteOperation> |
PathSplitter.splitDocumentWriteOperations(java.util.stream.Stream<java.nio.file.Path> paths)
Take a stream of Paths and convert the content into a stream of DocumentWriteOperation
|
java.util.stream.Stream<DocumentWriteOperation> |
JSONSplitter.splitWriteOperations(java.io.InputStream input)
Takes an InputStream of a JSON file and split it into a steam of DocumentWriteOperation to write to database.
|
java.util.stream.Stream<DocumentWriteOperation> |
JacksonCSVSplitter.splitWriteOperations(java.io.InputStream input)
Takes the input stream and converts it into a stream of DocumentWriteOperation by setting the schema
and wrapping the JsonNode into DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
LineSplitter.splitWriteOperations(java.io.InputStream input)
Takes the input stream and converts it into a stream of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
Splitter.splitWriteOperations(java.io.InputStream input)
Converts the incoming input stream to a stream of DocumentWriteOperation objects.
|
java.util.stream.Stream<DocumentWriteOperation> |
UnarySplitter.splitWriteOperations(java.io.InputStream input)
Takes a input stream of a file and convert the entire file to a stream of DocumentWriteOperation
|
java.util.stream.Stream<DocumentWriteOperation> |
XMLSplitter.splitWriteOperations(java.io.InputStream input)
Takes an input stream of an XML file and split it into a steam of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
ZipSplitter.splitWriteOperations(java.io.InputStream input)
Takes a input stream of a ZIP file and convert it to a stream of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
JSONSplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes an InputStream of a JSON file and file name and split it into a steam of DocumentWriteOperation
to write to database.
|
java.util.stream.Stream<DocumentWriteOperation> |
JacksonCSVSplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes the input stream and the input name, then converts the input into a stream of DocumentWriteOperation
by setting the schema and wrapping the JsonNode into DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
LineSplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes the input stream and input file name and converts it into a stream of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
Splitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Converts the incoming input stream to a stream of DocumentWriteOperation objects.
|
java.util.stream.Stream<DocumentWriteOperation> |
UnarySplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes a input stream and the name of a file, then convert the entire file to a stream of DocumentWriteOperation
|
java.util.stream.Stream<DocumentWriteOperation> |
XMLSplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes an input stream of an XML file and input file name, split it into a steam of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
ZipSplitter.splitWriteOperations(java.io.InputStream input,
java.lang.String splitFilename)
Takes a input stream and name of a ZIP file and convert it to a stream of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
JSONSplitter.splitWriteOperations(com.fasterxml.jackson.core.JsonParser input,
java.lang.String splitFilename)
Take an input of JsonParser created from the JSON file and split it into a stream of DocumentWriteOperations
to write to database.
|
java.util.stream.Stream<DocumentWriteOperation> |
JacksonCSVSplitter.splitWriteOperations(java.io.Reader input)
Takes the input Reader and converts it into a stream of DocumentWriteOperation by setting the schema
and wrapping the JsonNode into DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
JacksonCSVSplitter.splitWriteOperations(java.io.Reader input,
java.lang.String splitFilename)
Takes the input Reader and the input name, then converts the input Reader into a stream of DocumentWriteOperation
by setting the schema and wrapping the JsonNode into DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
XMLSplitter.splitWriteOperations(javax.xml.stream.XMLStreamReader input,
java.lang.String splitFilename)
Take an input of XMLStreamReader of the XML file and split it into a stream of DocumentWriteOperations
to write to database.
|
java.util.stream.Stream<DocumentWriteOperation> |
ZipSplitter.splitWriteOperations(java.util.zip.ZipInputStream input)
Takes a ZipInputStream of a ZIP file and convert it to a stream of DocumentWriteOperation.
|
java.util.stream.Stream<DocumentWriteOperation> |
ZipSplitter.splitWriteOperations(java.util.zip.ZipInputStream input,
java.lang.String splitFilename)
Takes a ZipInputStream and name of a ZIP file and convert it to a stream of DocumentWriteOperation.
|
Modifier and Type | Method and Description |
---|---|
WriteBatcher |
WriteBatcher.add(DocumentWriteOperation writeOperation)
Add a document, by passing in a
DocumentWriteOperation ,
to be batched and then written to the server when a batch is full
or WriteBatcher.flushAsync() or WriteBatcher.flushAndWait() is called. |
Modifier and Type | Method and Description |
---|---|
void |
WriteBatcher.addAll(java.util.stream.Stream<? extends DocumentWriteOperation> operations)
Writes a document stream to the database.
|
Modifier and Type | Method and Description |
---|---|
static java.util.stream.Stream<DocumentWriteOperation> |
DocumentWriteOperation.from(java.util.stream.Stream<? extends AbstractWriteHandle> content,
DocumentWriteOperation.DocumentUriMaker uriMaker)
The from method prepares each content object for writing as a document including generating a URI by inserting a UUID.
|
Copyright © 2013-2021 MarkLogic Corporation.