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 and WriteBatcher, 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 . |
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 and WriteBatcher, 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.
|
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 |
NoResponseListener
NoResponseListener is a default listener like HostAvailabilityListener that
is automatically registered with the QueryBatcher and WriteBatcher instances.
|
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.
|
Splitter
Splitter splits an input stream into a Java stream of write handles.
|
TypedRow |
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.
|
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 and WriteBatcher, 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-2018 MarkLogic Corporation.