Package io.stargate.sdk.doc

Class StargateDocumentDataLoader<DOC>

java.lang.Object

io.stargate.sdk.doc.StargateDocumentDataLoader<DOC>

Type Parameters:

DOC - working document

All Implemented Interfaces:

Closeable, AutoCloseable

public class StargateDocumentDataLoader<DOC>
extends Object
implements Closeable

Allow to load beans.

Constructor Summary

Constructors

Constructor	Description
StargateDocumentDataLoader()	Default Constructor.
StargateDocumentDataLoader(int poolSize)	Set up thread in parallel.

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<Void>	submitCreateDoc(CollectionClient ccc, DOC doc)	Push thread in the queue for the document to be loaded.
CompletableFuture<Void>	submitCreateDoc(CollectionClient ccc, String doc)	Push thread in the queue for the document to be loaded.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StargateDocumentDataLoader

public StargateDocumentDataLoader()

Default Constructor.

StargateDocumentDataLoader

public StargateDocumentDataLoader(int poolSize)

Set up thread in parallel.

Parameters:

poolSize - poolse

Method Details

submitCreateDoc

public CompletableFuture<Void> submitCreateDoc(CollectionClient ccc,
 DOC doc)

Push thread in the queue for the document to be loaded.

Parameters:

ccc - collection client parent

doc - document to be saved

Returns:

noothing to return

submitCreateDoc

public CompletableFuture<Void> submitCreateDoc(CollectionClient ccc,
 String doc)

Push thread in the queue for the document to be loaded.

Parameters:

ccc - collection client parent

doc - document to be saved

Returns:

noothing to return

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable