Package | Description |
---|---|
com.mapr.db | |
com.mapr.db.exceptions |
Modifier and Type | Method and Description |
---|---|
void |
Admin.alterFamily(org.apache.hadoop.fs.Path tablePath,
String familyName,
FamilyDescriptor familyDesc) |
void |
Admin.alterFamily(String tablePath,
String familyName,
FamilyDescriptor familyDesc) |
void |
Admin.alterTable(TableDescriptor tableDesc)
Modify the attributes of an existing table.
|
boolean |
Table.checkAndDelete(ByteBuffer id,
org.ojai.store.QueryCondition condition) |
boolean |
Table.checkAndDelete(String id,
org.ojai.store.QueryCondition condition)
Atomically evaluates the condition on given row and if the
condition holds true for the row then it is atomically deleted.
|
boolean |
Table.checkAndMutate(ByteBuffer id,
org.ojai.store.QueryCondition condition,
org.ojai.store.DocumentMutation m) |
boolean |
Table.checkAndMutate(String id,
org.ojai.store.QueryCondition condition,
org.ojai.store.DocumentMutation m)
Atomically evaluates the condition on a given row and if the
condition holds true for the row then a mutation is applied on the row.
|
boolean |
Table.checkAndReplace(ByteBuffer id,
org.ojai.store.QueryCondition condition,
org.ojai.Document r) |
boolean |
Table.checkAndReplace(String id,
org.ojai.store.QueryCondition condition,
org.ojai.Document r)
Atomically evaluates the condition on the given row and if the
condition holds true for the row then it atomically replaces the row
with the given document.
|
void |
Table.close()
Overrides
AutoCloseable.close() to avoid declaring a checked exception. |
void |
Admin.close()
Override
AutoCloseable.close() to avoid declaring a checked exception. |
Table |
Admin.createTable(org.apache.hadoop.fs.Path tablePath)
Creates a Json table at the specified path with 'default' column family and default options.
|
static Table |
MapRDB.createTable(String tablePath)
Creates a JSON table at the specified path with a 'default' column family and default options.
|
Table |
Admin.createTable(String tablePath)
Creates a Json table at the specified path with 'default' column family and default options.
|
Table |
Admin.createTable(TableDescriptor tableDesc)
Creates a Json table using the specified TableDescriptor.
|
Table |
Admin.createTable(TableDescriptor tableDesc,
ByteBuffer[] splitPoints)
Creates a pre-split JSON table using the specified TableDescriptor and the split points
as the tablet boundaries.
|
Table |
Admin.createTable(TableDescriptor tableDesc,
String[] splitPoints)
Creates a pre-split Json table using the specified TableDescriptor and the split points
as the tablet boundaries.
|
void |
Table.delete(ByteBuffer id) |
void |
Table.delete(org.ojai.Document r) |
void |
Table.delete(org.ojai.Document r,
org.ojai.FieldPath fieldAsKey) |
void |
Table.delete(org.ojai.Document r,
String fieldAsKey) |
void |
Table.delete(String id)
Deletes a row with the given rowkey.
|
boolean |
Admin.deleteFamily(org.apache.hadoop.fs.Path tablePath,
String familyName)
Deletes a family from a Json table.
|
boolean |
Admin.deleteFamily(String tablePath,
String familyName)
Deletes a family from a Json table.
|
boolean |
Admin.deleteTable(org.apache.hadoop.fs.Path tablePath)
Deletes a Table.
|
static boolean |
MapRDB.deleteTable(String tablePath)
Deletes a Table.
|
boolean |
Admin.deleteTable(String tablePath)
Deletes a Table.
|
org.ojai.DocumentStream |
Table.find()
Returns a DocumentStream for all the rows in the table.
|
org.ojai.DocumentStream |
Table.find(org.ojai.FieldPath... paths) |
org.ojai.DocumentStream |
Table.find(org.ojai.store.QueryCondition c)
Returns a DocumentStream for all the rows in the table that match the
condition.
|
org.ojai.DocumentStream |
Table.find(org.ojai.store.QueryCondition c,
org.ojai.FieldPath... paths) |
org.ojai.DocumentStream |
Table.find(org.ojai.store.QueryCondition c,
String... paths)
Returns a document reader for all the rows in the table that match the
condition.
|
org.ojai.DocumentStream |
Table.find(String... paths)
Returns a DocumentStream for all the rows in the table.
|
org.ojai.Document |
Table.findById(ByteBuffer id) |
org.ojai.Document |
Table.findById(ByteBuffer id,
org.ojai.FieldPath... paths) |
org.ojai.Document |
Table.findById(ByteBuffer id,
org.ojai.store.QueryCondition c) |
org.ojai.Document |
Table.findById(ByteBuffer id,
org.ojai.store.QueryCondition c,
org.ojai.FieldPath... paths) |
org.ojai.Document |
Table.findById(ByteBuffer id,
org.ojai.store.QueryCondition c,
String... paths) |
org.ojai.Document |
Table.findById(ByteBuffer id,
String... paths) |
org.ojai.Document |
Table.findById(String id)
Reads the entire document for a given key.
|
org.ojai.Document |
Table.findById(String id,
org.ojai.FieldPath... paths) |
org.ojai.Document |
Table.findById(String id,
org.ojai.store.QueryCondition c)
Reads the row parts that match the condition and projects only the
field paths requested.
|
org.ojai.Document |
Table.findById(String id,
org.ojai.store.QueryCondition c,
org.ojai.FieldPath... paths) |
org.ojai.Document |
Table.findById(String id,
org.ojai.store.QueryCondition c,
String... paths) |
org.ojai.Document |
Table.findById(String id,
String... paths)
Reads the row and projects only the field paths requested.
|
org.ojai.Document |
Table.findById(org.ojai.Value id) |
void |
Table.flush()
Flushes all the buffered update operations on the client for this table.
|
static Table |
MapRDB.getTable(org.apache.hadoop.fs.Path path)
Returns an object for accessing the table having the given path name.
|
static Table |
MapRDB.getTable(String pathName)
Returns an object for accessing the table having the given path name.
|
TableDescriptor |
Admin.getTableDescriptor(org.apache.hadoop.fs.Path tablePath) |
TableDescriptor |
Admin.getTableDescriptor(String tablePath) |
TabletInfo |
Table.getTabletInfo(ByteBuffer _id) |
TabletInfo |
Table.getTabletInfo(String _id) |
TabletInfo[] |
Table.getTabletInfos() |
TabletInfo[] |
Table.getTabletInfos(org.ojai.store.QueryCondition c) |
void |
Table.increment(ByteBuffer id,
String field,
BigDecimal inc) |
void |
Table.increment(ByteBuffer id,
String field,
byte inc) |
void |
Table.increment(ByteBuffer id,
String field,
double inc) |
void |
Table.increment(ByteBuffer id,
String field,
float inc) |
void |
Table.increment(ByteBuffer id,
String field,
int inc) |
void |
Table.increment(ByteBuffer id,
String field,
long inc) |
void |
Table.increment(ByteBuffer id,
String field,
short inc) |
void |
Table.increment(String id,
String field,
BigDecimal inc) |
void |
Table.increment(String id,
String field,
byte inc)
Atomically applies an increment to a given field (in dot-separated notation)
of the given row id.
|
void |
Table.increment(String id,
String field,
double inc) |
void |
Table.increment(String id,
String field,
float inc) |
void |
Table.increment(String id,
String field,
int inc) |
void |
Table.increment(String id,
String field,
long inc) |
void |
Table.increment(String id,
String field,
short inc) |
void |
Table.insert(ByteBuffer id,
org.ojai.Document r) |
void |
Table.insert(org.ojai.Document r) |
void |
Table.insert(org.ojai.Document r,
org.ojai.FieldPath fieldAsKey) |
void |
Table.insert(org.ojai.Document r,
String fieldAsKey) |
void |
Table.insert(String id,
org.ojai.Document r)
Inserts a row with the given rowkey.
|
void |
Table.insertOrReplace(ByteBuffer id,
org.ojai.Document r) |
void |
Table.insertOrReplace(org.ojai.Document r)
Inserts a new document in the table.
|
void |
Table.insertOrReplace(org.ojai.Document r,
org.ojai.FieldPath fieldAsKey) |
void |
Table.insertOrReplace(org.ojai.Document r,
String fieldAsKey) |
void |
Table.insertOrReplace(String id,
org.ojai.Document r) |
List<org.apache.hadoop.fs.Path> |
Admin.listTables()
List all tables in user's home directory.
|
List<org.apache.hadoop.fs.Path> |
Admin.listTables(org.apache.hadoop.fs.Path folderOrPattern)
List all tables in the specified folder and/or with the matching pattern.
|
List<org.apache.hadoop.fs.Path> |
Admin.listTables(String folderOrPattern)
List all tables in the specified folder and/or with the matching pattern.
|
static Admin |
MapRDB.newAdmin()
Creates and returns an Admin instance with default configuration.
|
static Admin |
MapRDB.newAdmin(org.apache.hadoop.conf.Configuration c)
Creates and returns an Admin instance with specified configuration.
|
void |
Table.replace(ByteBuffer id,
org.ojai.Document r) |
void |
Table.replace(org.ojai.Document r) |
void |
Table.replace(org.ojai.Document r,
org.ojai.FieldPath fieldAsKey) |
void |
Table.replace(org.ojai.Document r,
String fieldAsKey) |
void |
Table.replace(String id,
org.ojai.Document r)
Replaces a document in the table.
|
boolean |
Admin.tableExists(org.apache.hadoop.fs.Path tablePath) |
static boolean |
MapRDB.tableExists(String tablePath)
Test for the existence of Table at the given path.
|
boolean |
Admin.tableExists(String tablePath) |
void |
Table.update(ByteBuffer id,
org.ojai.store.DocumentMutation m) |
void |
Table.update(String id,
org.ojai.store.DocumentMutation m)
Applies a row mutation on the row identified by the row id.
|
Modifier and Type | Class and Description |
---|---|
class |
AccessDeniedException
This class is used to wrap checked exceptions when the server returns EACCES.
|
class |
DBRetryException
This class is used to wrap a checked exception for any operation
which needs a retry (as suggested by jni/server).
|
class |
FamilyExistsException
This class is used to wrap a checked exception when the family already exists.
|
class |
FamilyNotFoundException
This class is used to wrap a checked exception for any operation on a
non-existing family.
|
class |
OpNotPermittedException
This class is used to wrap checked exceptions when the server returns EPERM.
|
class |
ReadOnlyException
This class is used to wrap a checked exception when we try to insert/update/
delete from a table that is read-only.
|
class |
TableClosedException
This class is used to wrap a checked exception for any operation on a
table that has been closed.
|
class |
TableExistsException
This class is used to wrap a checked exception when the table already exists.
|
class |
TableNotFoundException
This class is used to wrap a checked exception for any operation on a
non-existing table.
|
Modifier and Type | Method and Description |
---|---|
static DBException |
ExceptionHandler.handle(IOException e,
String op) |
Copyright © 2016 Mapr Technologies, Inc.. All rights reserved.