Modifier and Type | Method and Description |
---|---|
void |
BatchWriter.addMutation(Mutation m)
Queues one mutation to write.
|
void |
BatchWriter.addMutations(Iterable<Mutation> iterable)
Queues several mutations to write.
|
void |
BatchWriter.close()
Flush and release any resources.
|
void |
MultiTableBatchWriter.close()
Flush and release all resources.
|
void |
BatchDeleter.delete()
Deletes the ranges specified by
BatchDeleter.setRanges(java.util.Collection . |
void |
BatchWriter.flush()
Send any buffered mutations to Accumulo immediately.
|
void |
MultiTableBatchWriter.flush()
Send mutations for all tables to accumulo.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchWriterImpl.addMutation(Mutation m) |
void |
TabletServerBatchWriter.addMutation(String table,
Iterator<Mutation> iterator) |
void |
TabletServerBatchWriter.addMutation(String table,
Mutation m) |
void |
BatchWriterImpl.addMutations(Iterable<Mutation> iterable) |
void |
MultiTableBatchWriterImpl.close() |
void |
BatchWriterImpl.close() |
void |
TabletServerBatchWriter.close() |
void |
TabletServerBatchDeleter.delete() |
void |
MultiTableBatchWriterImpl.flush() |
void |
BatchWriterImpl.flush() |
void |
TabletServerBatchWriter.flush() |
Modifier and Type | Method and Description |
---|---|
void |
MockBatchWriter.addMutation(Mutation m) |
void |
MockBatchWriter.addMutations(Iterable<Mutation> iterable) |
void |
MockMultiTableBatchWriter.close() |
void |
MockBatchWriter.close() |
void |
MockBatchDeleter.delete() |
void |
MockMultiTableBatchWriter.flush() |
void |
MockBatchWriter.flush() |
Modifier and Type | Method and Description |
---|---|
static void |
SequentialBatchWriter.main(String[] args)
Writes a specified number of entries to Accumulo using a
BatchWriter . |
static void |
RowOperations.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
String |
FileDataIngest.insertFileData(String filename,
BatchWriter bw) |
Modifier and Type | Method and Description |
---|---|
static void |
InsertWithBatchWriter.main(String[] args) |
Modifier and Type | Field and Description |
---|---|
MutationsRejectedException |
ProxyServer.BatchWriterPlusException.exception |
Modifier and Type | Method and Description |
---|---|
void |
NullBatchWriter.addMutation(Mutation m) |
void |
NullBatchWriter.addMutations(Iterable<Mutation> iterable) |
void |
NullBatchWriter.close() |
void |
NullBatchWriter.flush() |
static void |
GCLotsOfCandidatesTest.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
void |
PermissionsTest.TablePermissionsTest.run() |
Modifier and Type | Method and Description |
---|---|
void |
BulkImport.RFileBatchWriter.addMutation(Mutation m) |
void |
BulkImport.RFileBatchWriter.addMutations(Iterable<Mutation> iterable) |
void |
BulkImport.RFileBatchWriter.close() |
void |
BulkImport.RFileBatchWriter.flush() |
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.