Author: kturner
Date: Thu Oct 4 02:05:35 2012
New Revision: 1393877
URL: http://svn.apache.org/viewvc?rev=1393877&view=rev
Log:
ACCUMULO-706 fixed multi table batch writer creation
Modified:
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/ConnectorImpl.java
Modified:
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/ConnectorImpl.java
URL:
http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/ConnectorImpl.java?rev=1393877&r1=1393876&r2=1393877&view=diff
==============================================================================
---
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/ConnectorImpl.java
(original)
+++
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/ConnectorImpl.java
Thu Oct 4 02:05:35 2012
@@ -139,6 +139,11 @@ public class ConnectorImpl extends Conne
}
@Override
+ public MultiTableBatchWriter createMultiTableBatchWriter(BatchWriterConfig
config) {
+ return new MultiTableBatchWriterImpl(instance, credentials, config);
+ }
+
+ @Override
public Scanner createScanner(String tableName, Authorizations
authorizations) throws TableNotFoundException {
ArgumentChecker.notNull(tableName, authorizations);
return new ScannerImpl(instance, credentials, getTableId(tableName),
authorizations);