Package | Description |
---|---|
oracle.kv.hadoop.hive.table |
Support for executing Hive queries against data written to an Oracle NoSQL Database via the Table API.
|
oracle.kv.hadoop.table |
Support for running MapReduce jobs against data written to an Oracle NoSQL Database via the Table API.
|
oracle.kv.table |
Table support for Oracle NoSQL Database.
|
Modifier and Type | Method and Description |
---|---|
static InputFormat<PrimaryKey,Row> |
V1V2TableUtil.getInputFormat(JobConf jobConf) |
static InputFormat<PrimaryKey,Row> |
V1V2TableUtil.getInputFormat(JobConf jobConf,
TableHiveInputSplit inputSplit)
For the current Hive query, constructs and returns a YARN based
InputFormat class that will be used when processing the query.
|
Modifier and Type | Method and Description |
---|---|
PrimaryKey |
TableRecordReader.getCurrentKey()
Get the current key.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<PrimaryKey,Row> |
TableInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Returns the RecordReader for the given InputSplit.
|
Modifier and Type | Method and Description |
---|---|
PrimaryKey |
FieldValue.asPrimaryKey()
Casts to PrimaryKey.
|
PrimaryKey |
PrimaryKey.clone()
Returns a deep copy of this object.
|
PrimaryKey |
Table.createPrimaryKey()
Creates an empty
PrimaryKey for the table that can only hold
fields that are part of the primary key for the table. |
PrimaryKey |
Row.createPrimaryKey()
Creates a PrimaryKey from this Row.
|
PrimaryKey |
Table.createPrimaryKey(RecordValue value)
Creates a
PrimaryKey for the table populated with relevant
fields from the RecordValue parameter. |
PrimaryKey |
Table.createPrimaryKeyFromJson(InputStream jsonInput,
boolean exact)
Creates a
PrimaryKey based on JSON input. |
PrimaryKey |
Table.createPrimaryKeyFromJson(String jsonInput,
boolean exact)
Creates a
PrimaryKey based on JSON input. |
PrimaryKey |
TableOperation.getPrimaryKey()
Returns the PrimaryKey associated with the operation if it is a
delete operation, otherwise return null.
|
PrimaryKey |
KeyPair.getPrimaryKey()
Returns the PrimaryKey from the pair.
|
Modifier and Type | Method and Description |
---|---|
List<PrimaryKey> |
TableAPI.multiGetKeys(PrimaryKey key,
MultiRowOptions getOptions,
ReadOptions readOptions)
Return the rows associated with a partial primary key in an
atomic manner.
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(Iterator<PrimaryKey> primaryKeyIterator,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(List<Iterator<PrimaryKey>> primaryKeyIterators,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(PrimaryKey key,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys associated with a partial primary key.
|
Modifier and Type | Method and Description |
---|---|
TableOperation |
TableOperationFactory.createDelete(PrimaryKey key,
ReturnRow.Choice prevReturn,
boolean abortIfUnsuccessful)
Create a Delete operation suitable for use as an argument to the
execute method. |
TableOperation |
TableOperationFactory.createDeleteIfVersion(PrimaryKey key,
Version versionMatch,
ReturnRow.Choice prevReturn,
boolean abortIfUnsuccessful)
Create a Delete operation suitable for use as an argument to the
execute method. |
boolean |
TableAPI.delete(PrimaryKey key,
ReturnRow prevRow,
WriteOptions writeOptions)
Deletes a row from a table.
|
boolean |
TableAPI.deleteIfVersion(PrimaryKey key,
Version matchVersion,
ReturnRow prevRow,
WriteOptions writeOptions)
Deletes a row from a table but only if its version matches the one
specified in matchVersion.
|
Row |
TableAPI.get(PrimaryKey key,
ReadOptions readOptions)
Gets the
Row associated with the primary key. |
int |
TableAPI.multiDelete(PrimaryKey key,
MultiRowOptions getOptions,
WriteOptions writeOptions)
Deletes multiple rows from a table in an atomic operation.
|
List<Row> |
TableAPI.multiGet(PrimaryKey key,
MultiRowOptions getOptions,
ReadOptions readOptions)
Returns the rows associated with a partial primary key in an
atomic manner.
|
List<PrimaryKey> |
TableAPI.multiGetKeys(PrimaryKey key,
MultiRowOptions getOptions,
ReadOptions readOptions)
Return the rows associated with a partial primary key in an
atomic manner.
|
TableIterator<Row> |
TableAPI.tableIterator(PrimaryKey key,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the rows associated with a partial primary key.
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(PrimaryKey key,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys associated with a partial primary key.
|
Modifier and Type | Method and Description |
---|---|
TableIterator<Row> |
TableAPI.tableIterator(Iterator<PrimaryKey> primaryKeyIterator,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the rows matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
TableIterator<Row> |
TableAPI.tableIterator(List<Iterator<PrimaryKey>> primaryKeyIterators,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the rows matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(Iterator<PrimaryKey> primaryKeyIterator,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
TableIterator<PrimaryKey> |
TableAPI.tableKeysIterator(List<Iterator<PrimaryKey>> primaryKeyIterators,
MultiRowOptions getOptions,
TableIteratorOptions iterateOptions)
Returns an iterator over the keys matching the primary keys supplied by
iterator (or the rows in ancestor or descendant tables, or those in a
range specified by the MultiRowOptions argument).
|
Copyright (c) 2011, 2015 Oracle and/or its affiliates. All rights reserved.