Uses of Interface
oracle.kv.table.Row
Package
Description
This package contains the public API and Utilities for accessing
Oracle NoSQL Database data through Oracle Database External
Tables.
Support for executing Hive queries against data written to an Oracle NoSQL Database via the Table API.
Support for running MapReduce jobs against data written to an Oracle NoSQL Database via the Table API.
Provides the classes used to define a Subscription to all logical changes
(table row puts and deletes) made to a NoSQL store.
Table support for Oracle NoSQL Database.
-
Uses of Row in oracle.kv.exttab
Modifier and TypeMethodDescriptionTableFormatter.toOracleLoaderFormat
(Row row, KVStore kvstore) Converts a Row into a String which can be interpreted by the Oracle External Table definition. -
Uses of Row in oracle.kv.hadoop.hive.table
Modifier and TypeMethodDescriptionstatic InputFormat<PrimaryKey,
Row> V1V2TableUtil.getInputFormat
(JobConf jobConf, int queryBy, String whereClause, Integer shardKeyPartitionId) static InputFormat<PrimaryKey,
Row> V1V2TableUtil.getInputFormat
(JobConf jobConf, int queryBy, String whereClause, Integer shardKeyPartitionId, TableInputFormatBase.TopologyLocatorWrapper topologyLocator) static InputFormat<PrimaryKey,
Row> V1V2TableUtil.getInputFormat
(JobConf jobConf, TableHiveInputSplit inputSplit, int queryBy, String whereClause, Integer shardKeyPartitionId) static InputFormat<PrimaryKey,
Row> V1V2TableUtil.getInputFormat
(JobConf jobConf, TableHiveInputSplit inputSplit, int queryBy, String whereClause, Integer shardKeyPartitionId, TableInputFormatBase.TopologyLocatorWrapper topologyLocator) For the current Hive query, constructs and returns a YARN based InputFormat class that will be used when processing the query. -
Uses of Row in oracle.kv.hadoop.table
Modifier and TypeMethodDescriptionTableInputFormat.createRecordReader
(InputSplit split, TaskAttemptContext context) Returns the RecordReader for the given InputSplit. -
Uses of Row in oracle.kv.pubsub
-
Uses of Row in oracle.kv.table
Modifier and TypeInterfaceDescriptioninterface
PrimaryKey is a specialization of Row to represent a primary key used to access records in a table using theTableAPI
.interface
ReturnRow is used with put and delete operations to return the previous row value and version.Modifier and TypeMethodDescriptionFieldValue.asRow()
Casts to Row.Row.clone()
Returns a deep copy of this object.Table.createRow()
Creates an empty Row for the table that can hold any field value.Table.createRow
(RecordValue value) Creates a Row for the table populated with relevant fields from theRecordValue
parameter.Table.createRowFromJson
(InputStream jsonInput, boolean exact) Creates a Row based on JSON input.Table.createRowFromJson
(String jsonInput, boolean exact) Creates a Row based on JSON string input.Table.createRowWithDefaults()
Creates a Row using the default values for all fields.TableAPI.get
(PrimaryKey key, ReadOptions readOptions) Gets theRow
associated with the primary key.TableOperationResult.getPreviousRow()
For a put or delete operation, the previous value associated with the row.TableOperation.getRow()
Returns the Row associated with the operation if it is a put operation, otherwise return null.Modifier and TypeMethodDescriptionTableAPI.getAsync
(PrimaryKey key, ReadOptions readOptions) Gets theRow
associated with the primary key, returning a future to manage the asynchronous operation.TableAPI.multiGet
(PrimaryKey key, MultiRowOptions getOptions, ReadOptions readOptions) Returns the rows associated with a partial primary key in an atomic manner.TableAPI.multiGetAsync
(PrimaryKey key, MultiRowOptions getOptions, ReadOptions readOptions) Returns the rows associated with a partial primary key in an atomic manner, returning a future to manage the asynchronous operation.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).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).TableAPI.tableIterator
(IndexKey key, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns an iterator over the rows associated with an index key.TableAPI.tableIterator
(PrimaryKey key, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns an iterator over the rows associated with a partial primary key.org.reactivestreams.Publisher<Row>
TableAPI.tableIteratorAsync
(Iterator<PrimaryKey> primaryKeyIterator, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns a publisher that can be used to subscribe to the results of an asynchronous iteration 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).org.reactivestreams.Publisher<Row>
TableAPI.tableIteratorAsync
(List<Iterator<PrimaryKey>> primaryKeyIterators, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns a publisher that can be used to subscribe to the results of an asynchronous iteration 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).org.reactivestreams.Publisher<Row>
TableAPI.tableIteratorAsync
(IndexKey key, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns a publisher that can be used to subscribe to the results of an asynchronous iteration over the rows associated with an index key.org.reactivestreams.Publisher<Row>
TableAPI.tableIteratorAsync
(PrimaryKey key, MultiRowOptions getOptions, TableIteratorOptions iterateOptions) Returns a publisher that can be used to subscribe to the results of an asynchronous iteration over the rows associated with a partial primary key.Modifier and TypeMethodDescriptionTableOperationFactory.createPut
(Row row, ReturnRow.Choice prevReturn, boolean abortIfUnsuccessful) Create a Put operation suitable for use as an argument to theexecute
method.TableOperationFactory.createPutIfAbsent
(Row row, ReturnRow.Choice prevReturn, boolean abortIfUnsuccessful) Create a Put operation suitable for use as an argument to theexecute
method.TableOperationFactory.createPutIfPresent
(Row row, ReturnRow.Choice prevReturn, boolean abortIfUnsuccessful) Create a Put operation suitable for use as an argument to theexecute
method.TableOperationFactory.createPutIfVersion
(Row row, Version versionMatch, ReturnRow.Choice prevReturn, boolean abortIfUnsuccessful) Create a Put operation suitable for use as an argument to theexecute
method.static int
TableUtils.getDataSize
(Row row) Returns the size of the serialized data for the row.static int
TableUtils.getKeySize
(Row row) Returns the size of the serialized primary key for this row.TableAPI.put
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table.TableAPI.putAsync
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table, returning a future to manage the asynchronous operation.TableAPI.putIfAbsent
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table, but only if the row does not exist.TableAPI.putIfAbsentAsync
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table, but only if the row does not exist, returning a future to manage the asynchronous operation.TableAPI.putIfPresent
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table, but only if the row already exists.TableAPI.putIfPresentAsync
(Row row, ReturnRow prevRow, WriteOptions writeOptions) Puts a row into a table, but only if the row already exists, returning a future to manage the asynchronous operation.TableAPI.putIfVersion
(Row row, Version matchVersion, ReturnRow prevRow, WriteOptions writeOptions) Puts a row, but only if the version of the existing row matches the matchVersion argument.TableAPI.putIfVersionAsync
(Row row, Version matchVersion, ReturnRow prevRow, WriteOptions writeOptions) Puts a row, but only if the version of the existing row matches thematchVersion
argument, returning a future to manage the asynchronous operation.Modifier and TypeMethodDescriptionvoid
TableAPI.put
(List<EntryStream<Row>> streams, BulkWriteOptions bulkWriteOptions) Loads rows supplied by special purpose streams into the store.