@Deprecated public class MongoDBCellBaseLoader extends CellBaseLoader
blockingQueue, cellBaseConfiguration, data, database, field, innerFields, logger
Constructor and Description |
---|
MongoDBCellBaseLoader(BlockingQueue<List<String>> queue,
String data,
String database)
Deprecated.
|
MongoDBCellBaseLoader(BlockingQueue<List<String>> queue,
String data,
String database,
String field,
String[] innerFields,
CellBaseConfiguration cellBaseConfiguration)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Integer |
call()
Deprecated.
|
void |
close()
Deprecated.
|
void |
createIndex(String data)
Deprecated.
|
void |
init()
Deprecated.
|
int |
load(List<org.bson.Document> batch)
Deprecated.
|
protected boolean |
runCreateIndexProcess(Path indexFilePath)
Deprecated.
|
public MongoDBCellBaseLoader(BlockingQueue<List<String>> queue, String data, String database)
public MongoDBCellBaseLoader(BlockingQueue<List<String>> queue, String data, String database, String field, String[] innerFields, CellBaseConfiguration cellBaseConfiguration)
public void init() throws LoaderException
init
in class CellBaseLoader
LoaderException
public Integer call()
call
in interface Callable<Integer>
call
in class CellBaseLoader
public void createIndex(String data) throws LoaderException
createIndex
in class CellBaseLoader
LoaderException
public int load(List<org.bson.Document> batch)
public void close()
close
in class CellBaseLoader
protected boolean runCreateIndexProcess(Path indexFilePath) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2019. All rights reserved.