public class MockConnector extends Connector
Modifier and Type | Method and Description |
---|---|
BatchDeleter |
createBatchDeleter(String tableName,
Authorizations authorizations,
int numQueryThreads,
BatchWriterConfig config) |
BatchDeleter |
createBatchDeleter(String tableName,
Authorizations authorizations,
int numQueryThreads,
long maxMemory,
long maxLatency,
int maxWriteThreads)
Deprecated.
|
BatchScanner |
createBatchScanner(String tableName,
Authorizations authorizations,
int numQueryThreads)
Factory method to create a BatchScanner connected to Accumulo.
|
BatchWriter |
createBatchWriter(String tableName,
BatchWriterConfig config)
Factory method to create a BatchWriter connected to Accumulo.
|
BatchWriter |
createBatchWriter(String tableName,
long maxMemory,
long maxLatency,
int maxWriteThreads)
Deprecated.
|
ConditionalWriter |
createConditionalWriter(String tableName,
ConditionalWriterConfig config)
Factory method to create a ConditionalWriter connected to Accumulo.
|
MultiTableBatchWriter |
createMultiTableBatchWriter(BatchWriterConfig config)
Factory method to create a Multi-Table BatchWriter connected to Accumulo.
|
MultiTableBatchWriter |
createMultiTableBatchWriter(long maxMemory,
long maxLatency,
int maxWriteThreads)
Deprecated.
|
Scanner |
createScanner(String tableName,
Authorizations authorizations)
Factory method to create a Scanner connected to Accumulo.
|
Instance |
getInstance()
Accessor method for internal instance object.
|
InstanceOperations |
instanceOperations()
Retrieves an InstanceOperations object to modify instance configuration.
|
NamespaceOperations |
namespaceOperations()
Retrieves a NamespaceOperations object to perform namespace functions, such as create and delete.
|
SecurityOperations |
securityOperations()
Retrieves a SecurityOperations object to perform user security operations, such as creating users.
|
TableOperations |
tableOperations()
Retrieves a TableOperations object to perform table functions, such as create and delete.
|
String |
whoami()
Get the current user for this connector
|
public BatchScanner createBatchScanner(String tableName, Authorizations authorizations, int numQueryThreads) throws TableNotFoundException
Connector
createBatchScanner
in class Connector
tableName
- the name of the table to queryauthorizations
- A set of authorization labels that will be checked against the column visibility of each key in order to filter data. The authorizations passed in
must be a subset of the accumulo user's set of authorizations. If the accumulo user has authorizations (A1, A2) and authorizations (A2, A3) are
passed, then an exception will be thrown.numQueryThreads
- the number of concurrent threads to spawn for queryingTableNotFoundException
- when the specified table doesn't exist@Deprecated public BatchDeleter createBatchDeleter(String tableName, Authorizations authorizations, int numQueryThreads, long maxMemory, long maxLatency, int maxWriteThreads) throws TableNotFoundException
Connector
createBatchDeleter
in class Connector
tableName
- the name of the table to query and delete fromauthorizations
- A set of authorization labels that will be checked against the column visibility of each key in order to filter data. The authorizations passed in
must be a subset of the accumulo user's set of authorizations. If the accumulo user has authorizations (A1, A2) and authorizations (A2, A3) are
passed, then an exception will be thrown.numQueryThreads
- the number of concurrent threads to spawn for queryingmaxMemory
- size in bytes of the maximum memory to batch before writingmaxLatency
- size in milliseconds; set to 0 or Long.MAX_VALUE to allow the maximum time to hold a batch before writingmaxWriteThreads
- the maximum number of threads to use for writing data to the tablet serversTableNotFoundException
- when the specified table doesn't existpublic BatchDeleter createBatchDeleter(String tableName, Authorizations authorizations, int numQueryThreads, BatchWriterConfig config) throws TableNotFoundException
createBatchDeleter
in class Connector
tableName
- the name of the table to query and delete fromauthorizations
- A set of authorization labels that will be checked against the column visibility of each key in order to filter data. The authorizations passed in
must be a subset of the accumulo user's set of authorizations. If the accumulo user has authorizations (A1, A2) and authorizations (A2, A3) are
passed, then an exception will be thrown.numQueryThreads
- the number of concurrent threads to spawn for queryingconfig
- configuration used to create batch writerTableNotFoundException
@Deprecated public BatchWriter createBatchWriter(String tableName, long maxMemory, long maxLatency, int maxWriteThreads) throws TableNotFoundException
Connector
createBatchWriter
in class Connector
tableName
- the name of the table to insert data intomaxMemory
- size in bytes of the maximum memory to batch before writingmaxLatency
- time in milliseconds; set to 0 or Long.MAX_VALUE to allow the maximum time to hold a batch before writingmaxWriteThreads
- the maximum number of threads to use for writing data to the tablet serversTableNotFoundException
- when the specified table doesn't existpublic BatchWriter createBatchWriter(String tableName, BatchWriterConfig config) throws TableNotFoundException
Connector
createBatchWriter
in class Connector
tableName
- the name of the table to insert data intoconfig
- configuration used to create batch writerTableNotFoundException
@Deprecated public MultiTableBatchWriter createMultiTableBatchWriter(long maxMemory, long maxLatency, int maxWriteThreads)
Connector
createMultiTableBatchWriter
in class Connector
maxMemory
- size in bytes of the maximum memory to batch before writingmaxLatency
- size in milliseconds; set to 0 or Long.MAX_VALUE to allow the maximum time to hold a batch before writingmaxWriteThreads
- the maximum number of threads to use for writing data to the tablet serverspublic MultiTableBatchWriter createMultiTableBatchWriter(BatchWriterConfig config)
Connector
createMultiTableBatchWriter
in class Connector
config
- configuration used to create multi-table batch writerpublic Scanner createScanner(String tableName, Authorizations authorizations) throws TableNotFoundException
Connector
createScanner
in class Connector
tableName
- the name of the table to query data fromauthorizations
- A set of authorization labels that will be checked against the column visibility of each key in order to filter data. The authorizations passed in
must be a subset of the accumulo user's set of authorizations. If the accumulo user has authorizations (A1, A2) and authorizations (A2, A3) are
passed, then an exception will be thrown.TableNotFoundException
- when the specified table doesn't existpublic Instance getInstance()
Connector
getInstance
in class Connector
public String whoami()
Connector
public TableOperations tableOperations()
Connector
tableOperations
in class Connector
public SecurityOperations securityOperations()
Connector
securityOperations
in class Connector
public InstanceOperations instanceOperations()
Connector
instanceOperations
in class Connector
public NamespaceOperations namespaceOperations()
Connector
namespaceOperations
in class Connector
public ConditionalWriter createConditionalWriter(String tableName, ConditionalWriterConfig config) throws TableNotFoundException
Connector
createConditionalWriter
in class Connector
tableName
- the name of the table to query data fromconfig
- configuration used to create conditional writerTableNotFoundException
- when the specified table doesn't existCopyright © 2011–2016 The Apache Software Foundation. All rights reserved.