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.
|
com.marklogic.client.expression |
The package provides classes for building Optic
plan pipelines and expressions for execution on 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> |
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> |
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> |
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> |
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> |
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> |
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.
|
Modifier and Type | Method and Description |
---|---|
PlanDocDescriptor |
PlanBuilderBase.docDescriptor(DocumentWriteOperation writeOp)
Build a single doc descriptor that can be used
with
fromDocDescriptors . |
Copyright © 2024 MarkLogic Corporation. All Rights Reserved.