| Package | Description |
|---|---|
| org.cloudgraph.hbase.connect |
Contains HBase table pool and table interface access functionality.
|
| org.cloudgraph.hbase.io |
Provides infrastructure for managing HBase read and write operations across
any number of HBase tables and/or rows.
|
| org.cloudgraph.hbase.mutation |
| Modifier and Type | Method and Description |
|---|---|
Connection |
PooledConnectionFactory.create() |
Connection |
HBaseConnectionManager.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.commons.pool2.PooledObject<Connection> |
PooledConnectionFactory.wrap(Connection con) |
| Modifier and Type | Method and Description |
|---|---|
void |
HBaseConnectionManager.createTable(Connection connection,
org.apache.hadoop.hbase.TableName name,
StoreMappingContext mappingContext) |
void |
HBaseConnectionManager.deleteTable(Connection connection,
org.apache.hadoop.hbase.TableName name) |
org.apache.commons.pool2.PooledObject<Connection> |
PooledConnectionFactory.wrap(Connection con) |
| Modifier and Type | Method and Description |
|---|---|
void |
PooledConnectionFactory.activateObject(org.apache.commons.pool2.PooledObject<Connection> p) |
void |
PooledConnectionFactory.destroyObject(org.apache.commons.pool2.PooledObject<Connection> p) |
void |
PooledConnectionFactory.passivateObject(org.apache.commons.pool2.PooledObject<Connection> p) |
void |
PooledConnectionFactory.setPool(org.apache.commons.pool2.ObjectPool<Connection> pool) |
boolean |
PooledConnectionFactory.validateObject(org.apache.commons.pool2.PooledObject<Connection> p) |
| Constructor and Description |
|---|
Connection(org.apache.hadoop.hbase.client.Connection conection,
org.apache.commons.pool2.ObjectPool<Connection> pool,
org.apache.hadoop.conf.Configuration config) |
| Modifier and Type | Method and Description |
|---|---|
Connection |
DistributedGraphWriter.getConnection() |
Connection |
DistributedGraphReader.getConnection() |
Connection |
DistributedGraphOperation.getConnection()
returns the shared connection for the operation
|
| Constructor and Description |
|---|
DistributedGraphReader(commonj.sdo.Type rootType,
List<commonj.sdo.Type> types,
Connection connection,
StoreMappingContext mappingContext) |
DistributedGraphWriter(commonj.sdo.DataGraph dataGraph,
TableWriterCollector collector,
Connection connection,
StoreMappingContext mappingContext) |
| Modifier and Type | Method and Description |
|---|---|
Map<TableWriter,Map<String,Mutations>> |
MutationCollector.collectChanges(commonj.sdo.DataGraph[] dataGraphs,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
GraphMutationCollector.collectChanges(commonj.sdo.DataGraph[] dataGraphs,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
MutationCollector.collectChanges(commonj.sdo.DataGraph dataGraph,
Connection connection) |
Map<TableWriter,Map<String,Mutations>> |
GraphMutationCollector.collectChanges(commonj.sdo.DataGraph dataGraph,
Connection connection) |
Copyright © 2021. All Rights Reserved.