Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<List<String>> |
blockingQueue |
protected CellBaseConfiguration |
cellBaseConfiguration |
protected String |
data |
protected String |
database |
protected String |
field |
protected String[] |
innerFields |
protected org.slf4j.Logger |
logger |
Constructor and Description |
---|
CellBaseLoader(BlockingQueue<List<String>> blockingQueue,
String data,
String database,
String field,
String[] innerFields,
CellBaseConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
abstract Integer |
call() |
abstract void |
close() |
abstract void |
createIndex(String data) |
abstract void |
init() |
protected final BlockingQueue<List<String>> blockingQueue
protected String data
protected String database
protected String field
protected String[] innerFields
protected CellBaseConfiguration cellBaseConfiguration
protected final org.slf4j.Logger logger
public CellBaseLoader(BlockingQueue<List<String>> blockingQueue, String data, String database, String field, String[] innerFields, CellBaseConfiguration configuration)
public abstract void init() throws LoaderException
LoaderException
public abstract void createIndex(String data) throws LoaderException
LoaderException
public abstract void close()
Copyright © 2019. All rights reserved.