Package | Description |
---|---|
com.marklogic.client |
The package provides the core classes, interfaces and exceptions for working with the database.
|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports long-running write, read,
delete, or transform jobs.
|
com.marklogic.client.example.cookbook.datamovement |
Class and Description |
---|
DataMovementManager
DataMovementManager is the starting point for getting new instances of
QueryBatcher, WriteBatcher and RowBatcher, configured with a DatabaseClient and
ForestConfiguration.
|
Class and Description |
---|
ApplyTransformListener
Modifies documents in-place in the database by applying a
server-side transform . |
ApplyTransformListener.ApplyResult
Either
ApplyTransformListener.ApplyResult.REPLACE each document with the result of the transform, or run
the transform with each document as input, but ApplyTransformListener.ApplyResult.IGNORE the result. |
Batch
A group of items (generally documents or uris) and context representing a
completed action in a datamovement job.
|
Batcher
The base class (shared methods) for
QueryBatcher and WriteBatcher . |
BatchEvent
A completed action in a datamovement job.
|
BatchFailureListener
A generic interface for listeners which process failures on batches.
|
BatchListener
Runs processEvent on each batch as it is ready during a QueryBatcher or
WriteBatcher job.
|
DataMovementManager
DataMovementManager is the starting point for getting new instances of
QueryBatcher, WriteBatcher and RowBatcher, configured with a DatabaseClient and
ForestConfiguration.
|
DeleteListener
Sends a Java API bulk
delete
request for all the documents from each batch. |
ExportListener
Reads document contents (and optionally metadata) for each batch, then sends
each document to any listeners registered with
onDocumentReady for further processing or writing to any target supported
by Java. |
ExportToWriterListener
An extension of ExportListener which facilitates writing all documents to a
single Writer output stream.
|
ExportToWriterListener.OutputListener
The listener interface required by onGenerateOutput.
|
ExtractRowsViaTemplateListener
This QueryBatchListener takes in one or more uris for templates as defined by
Marklogic TDE (Template Driven Extraction) and applies them to each batch of
documents.
|
FailureListener
A generic base interface for listeners implemented by QueryFailureListener
for processing a Throwable that caused a failure.
|
FilteredForestConfiguration
A utility class for wrapping a ForestConfiguration retrieved from
DataMovementManager.readForestConfig() . |
Forest
Some details about a MarkLogic forest.
|
Forest.HostType
Enum containing the list of host types a forest can have.
|
ForestConfiguration
A reflection of the forest configuration associated with the specified
database (or the default database for the specified port) in the MarkLogic
cluster.
|
HostAvailabilityListener
HostAvailabilityListener is automatically registered with all QueryBatcher
and WriteBatcher instances to monitor for failover scenarios.
|
JacksonCSVSplitter
The JacksonCSVSplitter class uses the Jackson CSV parser without attempting to abstract it capabilities.
|
JacksonCSVSplitter.UriMaker
UriMaker which generates URI for each split file
|
JobReport
A Job report is used to report status on a
WriteBatcher or a QueryBatcher
job at any point of time after it is started and provide a
snapshot of the job's status at that time. |
JobTicket
JobTicket is used to uniquely identify a job.
|
JobTicket.JobType |
JSONSplitter
The JSONSplitter is used to split large JSON file into separate payloads for writing to the database.
|
JSONSplitter.UriMaker
UriMaker which generates URI for each split file
|
JSONSplitter.Visitor
The Visitor class is used to accumulate and inspect state during the depth-first traversal of the JSON tree
and make the decision of how to split the JSON file.
|
LineSplitter.UriMaker
UriMaker which generates URI for each split file
|
NodeOperation
Different operations to traverse the tree
DESCENT tells the application to go down the tree
SKIP tells the application to skip current branch
PROCESS tells the application to process current branch
|
NoResponseListener
NoResponseListener is a default listener like HostAvailabilityListener that
is automatically registered with the QueryBatcher and WriteBatcher instances.
|
PathSplitter
The PathSplitter utility class splits the Stream of paths into a Stream of AbstractWriteHandles or
DocumentWriteOperations suitable for writing in batches.
|
ProgressListener
Reports on progress as batches are processed by sending an instance of the nested ProgressUpdate interface to
instances of java.util.function.Consumer.
|
ProgressListener.ProgressUpdate
Captures data of interest for a progress update.
|
QueryBatch
A group of uris retrieved from the Iterator or matches to the
QueryDefinition for this QueryBatcher job.
|
QueryBatcher
To facilitate long-running read, update, and delete use cases, coordinates
threads to process batches of uris matching a query or coming
from an Iterator.
|
QueryBatcherListener
Runs processEvent on the QueryBatcher and it is a generic listener which can
be registered and run when you deal at the Batcher level.
|
QueryBatchException
An exception which occurred when attempting to retrieve a batch of matches
to a query.
|
QueryBatchListener
Runs processEvent on each batch as it is ready during a QueryBatcher
job.
|
QueryEvent
The context for a QueryBatch passed to QueryBatchListener or an exception
passed to QueryFailureListener, indicating the state at the time this event
occurred.
|
QueryFailureListener
A listener which can process an exception which occurred when attempting to
retrieve a batch of matches to a query.
|
RowBatcher
Coordinates threads to export all of the rows from a view in batches.
|
RowBatchFailureListener
Provides a callback (typically as a lambda) to process an exception
when trying to retrieve a batch of rows for a view.
|
RowBatchFailureListener.BatchFailureDisposition
Specifies how the RowBatcher should respond to the failure
to retrieve a batch of rows.
|
RowBatchFailureListener.RowBatchFailureEvent
An exception which occurred when attempting to retrieve a batch of rows
for a view.
|
RowBatchSuccessListener
Provides a callback (typically as a lambda) to process a batch of rows
retrieved for a view.
|
Splitter
Splitter splits an input stream into a Java stream of write handles.
|
Splitter.UriMaker
UriMaker generates URI for each split file.
|
TypedRow |
UnarySplitter.UriMaker
UriMaker which generates URI for each split file
|
UrisToWriterListener
Facilitates writing uris to a file when necessary because setting
merge timestamp
and
withConsistentSnapshot is
not an option, but you need to run DeleteListener or
ApplyTransformListener. |
UrisToWriterListener.OutputListener |
WriteBatch
A batch of documents written successfully.
|
WriteBatcher
To facilitate long-running write jobs, batches documents added by many
external threads and coordinates internal threads to send the batches
round-robin to all appropriate hosts in the cluster.
|
WriteBatchListener
Runs processEvent on each batch as it is ready during a WriteBatcher
job.
|
WriteEvent
Each WriteBatch is composed of many WriteEvents, each of which represents all the information about a single document which was written to the server.
|
WriteFailureListener
The listener interface for handling exceptions occurring withing WriteBatcher.
|
XMLSplitter
The XMLSplitter is used to split large XML file into separate payloads for writing to the database.
|
XMLSplitter.StartElementReader
The StartElementReader is used in visitor to check if the current element is the one to split.
|
XMLSplitter.UriMaker
UriMaker which generates URI for each split file
|
XMLSplitter.Visitor
The Visitor class is used to check if the current element is the target to split.
|
ZipSplitter.UriMaker
UriMaker which generates URI for each split file
|
Class and Description |
---|
Batch
A group of items (generally documents or uris) and context representing a
completed action in a datamovement job.
|
BatchFailureListener
A generic interface for listeners which process failures on batches.
|
BatchListener
Runs processEvent on each batch as it is ready during a QueryBatcher or
WriteBatcher job.
|
DataMovementManager
DataMovementManager is the starting point for getting new instances of
QueryBatcher, WriteBatcher and RowBatcher, configured with a DatabaseClient and
ForestConfiguration.
|
FailureListener
A generic base interface for listeners implemented by QueryFailureListener
for processing a Throwable that caused a failure.
|
QueryBatch
A group of uris retrieved from the Iterator or matches to the
QueryDefinition for this QueryBatcher job.
|
QueryBatchException
An exception which occurred when attempting to retrieve a batch of matches
to a query.
|
QueryBatchListener
Runs processEvent on each batch as it is ready during a QueryBatcher
job.
|
QueryFailureListener
A listener which can process an exception which occurred when attempting to
retrieve a batch of matches to a query.
|
WriteBatch
A batch of documents written successfully.
|
WriteBatcher
To facilitate long-running write jobs, batches documents added by many
external threads and coordinates internal threads to send the batches
round-robin to all appropriate hosts in the cluster.
|
WriteBatchListener
Runs processEvent on each batch as it is ready during a WriteBatcher
job.
|
WriteFailureListener
The listener interface for handling exceptions occurring withing WriteBatcher.
|
Copyright © 2013-2021 MarkLogic Corporation.