- AbstractKuduScannerBuilder<S extends AbstractKuduScannerBuilder<? super S,T>,T> - Class in org.kududb.client
-
Abstract class to extend in order to create builders for scanners.
- addBinary(int, byte[]) - Method in class org.kududb.client.PartialRow
-
Add binary data with the specified value.
- addBinary(String, byte[]) - Method in class org.kududb.client.PartialRow
-
Add binary data with the specified value.
- addBoolean(int, boolean) - Method in class org.kududb.client.PartialRow
-
Add a boolean for the specified column.
- addBoolean(String, boolean) - Method in class org.kududb.client.PartialRow
-
Add a boolean for the specified column.
- addByte(int, byte) - Method in class org.kududb.client.PartialRow
-
Add a byte for the specified column.
- addByte(String, byte) - Method in class org.kududb.client.PartialRow
-
Add a byte for the specified column.
- addColumn(String, Type, Object) - Method in class org.kududb.client.AlterTableBuilder
-
Add a new column that's not nullable
- addColumnRangePredicate(ColumnRangePredicate) - Method in class org.kududb.client.AbstractKuduScannerBuilder
-
Adds a predicate for a column.
- addColumnRangePredicatesRaw(byte[]) - Method in class org.kududb.client.AbstractKuduScannerBuilder
-
- addDouble(int, double) - Method in class org.kududb.client.PartialRow
-
Add an double for the specified column.
- addDouble(String, double) - Method in class org.kududb.client.PartialRow
-
Add an double for the specified column.
- addFloat(int, float) - Method in class org.kududb.client.PartialRow
-
Add an float for the specified column.
- addFloat(String, float) - Method in class org.kududb.client.PartialRow
-
Add an float for the specified column.
- addHashPartitions(List<String>, int) - Method in class org.kududb.client.CreateTableBuilder
-
Add a set of hash partitions to the table.
- addHashPartitions(List<String>, int, int) - Method in class org.kududb.client.CreateTableBuilder
-
Add a set of hash partitions to the table.
- addInt(int, int) - Method in class org.kududb.client.PartialRow
-
Add an int for the specified column.
- addInt(String, int) - Method in class org.kududb.client.PartialRow
-
Add an int for the specified column.
- addLong(int, long) - Method in class org.kududb.client.PartialRow
-
Add an long for the specified column.
- addLong(String, long) - Method in class org.kududb.client.PartialRow
-
Add an long for the specified column.
- addNullableColumn(String, Type) - Method in class org.kududb.client.AlterTableBuilder
-
Add a new column that's nullable, thus has no default value
- addShort(int, short) - Method in class org.kududb.client.PartialRow
-
Add a short for the specified column.
- addShort(String, short) - Method in class org.kududb.client.PartialRow
-
Add a short for the specified column.
- addSplitRow(PartialRow) - Method in class org.kududb.client.CreateTableBuilder
-
Add a split point for the table.
- addString(int, String) - Method in class org.kududb.client.PartialRow
-
Add a String for the specified column.
- addString(String, String) - Method in class org.kududb.client.PartialRow
-
Add a String for the specified column.
- addStringUtf8(int, byte[]) - Method in class org.kududb.client.PartialRow
-
Add a String for the specified value, encoded as UTF8.
- addStringUtf8(String, byte[]) - Method in class org.kududb.client.PartialRow
-
Add a String for the specified value, encoded as UTF8.
- alterTable(String, AlterTableBuilder) - Method in class org.kududb.client.AsyncKuduClient
-
Alter a table on the cluster as specified by the builder.
- alterTable(String, AlterTableBuilder) - Method in class org.kududb.client.KuduClient
-
Alter a table on the cluster as specified by the builder.
- AlterTableBuilder - Class in org.kududb.client
-
This builder must be used to alter a table.
- AlterTableBuilder() - Constructor for class org.kududb.client.AlterTableBuilder
-
- AlterTableResponse - Class in org.kududb.client
-
- apply(Operation) - Method in class org.kududb.client.AsyncKuduSession
-
Apply the given operation.
- apply(Operation) - Method in class org.kududb.client.KuduSession
-
Blocking call with a different behavior based on the flush mode.
- AsyncKuduClient - Class in org.kududb.client
-
A fully asynchronous and thread-safe client for Kudu.
- AsyncKuduScanner - Class in org.kududb.client
-
Creates a scanner to read data from Kudu.
- AsyncKuduScanner.ReadMode - Enum in org.kududb.client
-
The possible read modes for scanners.
- AsyncKuduSession - Class in org.kududb.client
-
A AsyncKuduSession belongs to a specific AsyncKuduClient, and represents a context in
which all read/write data access should take place.
- getAsyncClient() - Method in class org.kududb.client.KuduTable
-
Get the async client that created this instance.
- getBinary(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's binary data.
- getBinary(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's binary data.
- getBinaryCopy(String) - Method in class org.kududb.client.RowResult
-
Get a copy of the specified column's binary data.
- getBinaryCopy(int) - Method in class org.kududb.client.RowResult
-
Get a copy of the specified column's binary data.
- getBoolean(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's boolean
- getBoolean(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's boolean
- getByte(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's byte
- getByte(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's byte
- getCacheBlocks() - Method in class org.kududb.client.AsyncKuduScanner
-
Returns if this scanner was configured to cache data blocks or not.
- getColumn() - Method in class org.kududb.client.ColumnRangePredicate
-
Get the column used by this predicate
- getColumn(String) - Method in class org.kududb.Schema
-
Get the column associated with the specified name
- getColumnByIndex(int) - Method in class org.kududb.Schema
-
Get the column at the specified index in the original list
- getColumnCount() - Method in class org.kududb.Schema
-
Get the count of columns in this schema
- getColumnIndex(String) - Method in class org.kududb.Schema
-
Get the index for the provided column name.
- getColumnIndex(int) - Method in class org.kududb.Schema
-
Get the column index of the column with the provided ID.
- getColumnOffset(int) - Method in class org.kududb.Schema
-
Get the index at which this column can be found in the backing byte array
- getColumnProjection() - Method in class org.kududb.client.RowResult
-
Get the schema used for this scanner's column projection.
- getColumns() - Method in class org.kududb.Schema
-
Get the list of columns used to create this schema
- getColumnType(String) - Method in class org.kududb.client.RowResult
-
Get the type of a column in this result.
- getColumnType(int) - Method in class org.kududb.client.RowResult
-
Get the type of a column in this result.
- getDataType() - Method in enum org.kududb.Type
-
Get the data type from the common's pb
- getDefaultAdminOperationTimeoutMs() - Method in class org.kududb.client.AsyncKuduClient
-
Get the timeout used for admin operations.
- getDefaultAdminOperationTimeoutMs() - Method in class org.kududb.client.KuduClient
-
Get the timeout used for admin operations.
- getDefaultOperationTimeoutMs() - Method in class org.kududb.client.AsyncKuduClient
-
Get the timeout used for operations on sessions and scanners.
- getDefaultOperationTimeoutMs() - Method in class org.kududb.client.KuduClient
-
Get the timeout used for operations on sessions and scanners.
- getDefaultSocketReadTimeoutMs() - Method in class org.kududb.client.AsyncKuduClient
-
Get the timeout used when waiting to read data from a socket.
- getDefaultValue() - Method in class org.kududb.ColumnSchema
-
The Java object representation of the default value that's read
- getDeferred() - Method in exception org.kududb.client.PleaseThrottleException
-
Returns a deferred one can wait on before retrying the failed RPC.
- getDesiredBlockSize() - Method in class org.kududb.ColumnSchema
-
Gets the desired block size for this column.
- getDouble(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's double
- getDouble(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's double
- getEncoding() - Method in class org.kududb.ColumnSchema
-
Return the encoding of this column, or null if it is not known.
- getEndKey() - Method in class org.kududb.client.LocatedTablet
-
Deprecated.
- getFailedRpc() - Method in interface org.kududb.client.HasFailedRpcException
-
Returns the RPC that caused this exception.
- getFailedRpc() - Method in exception org.kududb.client.PleaseThrottleException
-
The RPC that was made to fail with this exception.
- getFloat(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's float
- getFloat(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's float
- getFlushMode() - Method in class org.kududb.client.AsyncKuduSession
-
- getFlushMode() - Method in class org.kududb.client.KuduSession
-
- getFlushMode() - Method in interface org.kududb.client.SessionConfiguration
-
Get the current flush mode.
- getInt(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's integer
- getInt(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's integer
- getLastPropagatedTimestamp() - Method in class org.kududb.client.AsyncKuduClient
-
- getLeaderReplica() - Method in class org.kududb.client.LocatedTablet
-
Return the current leader, or null if there is none.
- getLimit() - Method in class org.kududb.client.AsyncKuduScanner
-
Returns the maximum number of rows that this scanner was configured to return.
- getLong(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's long
If this is a TIMESTAMP column, the long value corresponds to a number of microseconds
since midnight, January 1, 1970 UTC.
- getLong(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's long
If this is a TIMESTAMP column, the long value corresponds to a number of microseconds
since midnight, January 1, 1970 UTC.
- getLowerBound() - Method in class org.kududb.client.ColumnRangePredicate
-
Get the lower bound in its raw representation
- getMaxNumBytes() - Method in class org.kududb.client.AsyncKuduScanner
-
Returns the maximum number of bytes returned at once by the scanner.
- getMessage() - Method in class org.kududb.client.RowError
-
Get the error message the tablet server sent.
- getName() - Method in class org.kududb.client.KuduTable
-
Get this table's name.
- getName() - Method in class org.kududb.ColumnSchema
-
Get the column's name
- getName() - Method in enum org.kududb.Type
-
Get the string representation of this type
- getNumRows() - Method in class org.kududb.client.RowResultIterator
-
Get the number of rows in this iterator.
- getOperation() - Method in class org.kududb.client.RowError
-
Get the Operation that failed.
- getPartition() - Method in class org.kududb.client.LocatedTablet
-
- getPartitionSchema() - Method in class org.kududb.client.KuduTable
-
Gets the table's partition schema.
- getPrimaryKeyColumnCount() - Method in class org.kududb.Schema
-
Get the count of columns that are part of the primary key.
- getPrimaryKeyColumns() - Method in class org.kududb.Schema
-
Get the primary key columns.
- getReadMode() - Method in class org.kududb.client.AsyncKuduScanner
-
Returns the ReadMode for this scanner.
- getReplicas() - Method in class org.kududb.client.LocatedTablet
-
- getResponse() - Method in exception org.kududb.client.InvalidResponseException
-
Returns the possibly null
response received from the server.
- getRole() - Method in class org.kududb.client.LocatedTablet.Replica
-
- getRow() - Method in class org.kududb.client.Operation
-
Get the underlying row to modify.
- getRowError() - Method in class org.kududb.client.OperationResponse
-
Returns a row error.
- getRowKeyProjection() - Method in class org.kududb.Schema
-
Get a schema that only contains the columns which are part of the key
- getRowSize() - Method in class org.kududb.Schema
-
Get the size a row built using this schema would be
- getRpcHost() - Method in class org.kududb.client.LocatedTablet.Replica
-
- getRpcPort() - Method in class org.kududb.client.LocatedTablet.Replica
-
- getSchema() - Method in class org.kududb.client.KuduTable
-
Get this table's schema, as of the moment this instance was created.
- getSchema() - Method in class org.kududb.client.RowResult
-
Get the schema associated with this result.
- getShort(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's short
- getShort(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's short
- getSize() - Method in enum org.kududb.Type
-
The size of this type on the wire
- getStartKey() - Method in class org.kududb.client.LocatedTablet
-
Deprecated.
- getStatus() - Method in class org.kududb.client.RowError
-
Get the string-representation of the error code that the tablet server returned.
- getString(String) - Method in class org.kududb.client.RowResult
-
Get the specified column's string.
- getString(int) - Method in class org.kududb.client.RowResult
-
Get the specified column's string.
- getTableId() - Method in class org.kududb.client.KuduTable
-
Get this table's unique identifier.
- getTablesList() - Method in class org.kududb.client.AsyncKuduClient
-
Get the list of all the tables.
- getTablesList(String) - Method in class org.kududb.client.AsyncKuduClient
-
Get a list of table names.
- getTablesList() - Method in class org.kududb.client.KuduClient
-
Get the list of all the tables.
- getTablesList(String) - Method in class org.kududb.client.KuduClient
-
Get a list of table names.
- getTablesList() - Method in class org.kududb.client.ListTablesResponse
-
Get the list of tables as specified in the request.
- getTabletId() - Method in class org.kududb.client.LocatedTablet
-
- getTabletServersCount() - Method in class org.kududb.client.ListTabletServersResponse
-
Get the count of tablet servers as reported by the master.
- getTabletServersList() - Method in class org.kududb.client.ListTabletServersResponse
-
Get the list of tablet servers, as represented by their hostname.
- getTabletsLocations(long) - Method in class org.kududb.client.KuduTable
-
Get all the tablets for this table.
- getTabletsLocations(byte[], byte[], long) - Method in class org.kududb.client.KuduTable
-
Get all or some tablets for this table.
- getTimeoutMillis() - Method in class org.kududb.client.AsyncKuduSession
-
- getTimeoutMillis() - Method in class org.kududb.client.KuduSession
-
- getTimeoutMillis() - Method in interface org.kududb.client.SessionConfiguration
-
Get the current timeout.
- getTsUUID() - Method in class org.kududb.client.RowError
-
Get the identifier of the tablet server that sent the error.
- getType() - Method in class org.kududb.ColumnSchema
-
Get the column's Type
- getTypeForDataType(Common.DataType) - Static method in enum org.kududb.Type
-
Convert the pb DataType to a Type
- getUpperBound() - Method in class org.kududb.client.ColumnRangePredicate
-
Get the upper bound in its raw representation
- getVarLengthColumnCount() - Method in class org.kududb.Schema
-
Get the count of columns with variable length (BINARY/STRING) in
this schema.
- getWriteTimestamp() - Method in class org.kududb.client.OperationResponse
-
Gives the write timestamp that was returned by the Tablet Server.
- scanRequestTimeout(long) - Method in class org.kududb.client.AbstractKuduScannerBuilder
-
Sets how long each scan request to a server can last.
- Schema - Class in org.kududb
-
Represents table's schema which is essentially a list of columns.
- Schema(List<ColumnSchema>) - Constructor for class org.kududb.Schema
-
Constructs a schema using the specified columns and does some internal accounting
- Schema(List<ColumnSchema>, List<Integer>) - Constructor for class org.kududb.Schema
-
Constructs a schema using the specified columns and IDs.
- SessionConfiguration - Interface in org.kududb.client
-
Interface that defines the methods used to configure a session.
- SessionConfiguration.FlushMode - Enum in org.kududb.client
-
- setExternalConsistencyMode(ExternalConsistencyMode) - Method in class org.kududb.client.AsyncKuduSession
-
- setExternalConsistencyMode(ExternalConsistencyMode) - Method in class org.kududb.client.KuduSession
-
- setExternalConsistencyMode(ExternalConsistencyMode) - Method in interface org.kududb.client.SessionConfiguration
-
Set the new external consistency mode for this session.
- setFlushInterval(int) - Method in class org.kududb.client.AsyncKuduSession
-
- setFlushInterval(int) - Method in class org.kududb.client.KuduSession
-
- setFlushInterval(int) - Method in interface org.kududb.client.SessionConfiguration
-
Set the flush interval, which will be used for the next scheduling decision.
- setFlushMode(SessionConfiguration.FlushMode) - Method in class org.kududb.client.AsyncKuduSession
-
- setFlushMode(SessionConfiguration.FlushMode) - Method in class org.kududb.client.KuduSession
-
- setFlushMode(SessionConfiguration.FlushMode) - Method in interface org.kududb.client.SessionConfiguration
-
Set the new flush mode for this session.
- setIgnoreAllDuplicateRows(boolean) - Method in class org.kududb.client.AsyncKuduSession
-
- setIgnoreAllDuplicateRows(boolean) - Method in class org.kududb.client.KuduSession
-
- setIgnoreAllDuplicateRows(boolean) - Method in interface org.kududb.client.SessionConfiguration
-
Configures the option to ignore all the row errors if they are all of the AlreadyPresent type.
- setLowerBound(boolean) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a boolean for the lower bound
- setLowerBound(byte) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a byte for the lower bound
- setLowerBound(short) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a short for the lower bound
- setLowerBound(int) - Method in class org.kududb.client.ColumnRangePredicate
-
Set an int for the lower bound
- setLowerBound(long) - Method in class org.kududb.client.ColumnRangePredicate
-
- setLowerBound(String) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a string for the lower bound
- setLowerBound(byte[]) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a binary value for the lower bound
- setLowerBound(float) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a float for the lower bound
- setLowerBound(double) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a double for the lower bound
- setMutationBufferLowWatermark(float) - Method in class org.kududb.client.AsyncKuduSession
-
- setMutationBufferLowWatermark(float) - Method in class org.kududb.client.KuduSession
-
- setMutationBufferLowWatermark(float) - Method in interface org.kududb.client.SessionConfiguration
-
Set the low watermark for this session.
- setMutationBufferSpace(int) - Method in class org.kududb.client.AsyncKuduSession
-
- setMutationBufferSpace(int) - Method in class org.kududb.client.KuduSession
-
- setMutationBufferSpace(int) - Method in interface org.kududb.client.SessionConfiguration
-
Set the number of operations that can be buffered.
- setNull(int) - Method in class org.kududb.client.PartialRow
-
Set the specified column to null
- setNull(String) - Method in class org.kududb.client.PartialRow
-
Set the specified column to null
- setNumReplicas(int) - Method in class org.kududb.client.CreateTableBuilder
-
Sets the number of replicas that each tablet will have.
- setProjectedColumnNames(List<String>) - Method in class org.kududb.client.AbstractKuduScannerBuilder
-
Set which columns will be read by the Scanner.
- setRangePartitionColumns(List<String>) - Method in class org.kududb.client.CreateTableBuilder
-
Set the columns on which the table will be range-partitioned.
- setTimeoutMillis(long) - Method in class org.kududb.client.AsyncKuduSession
-
- setTimeoutMillis(long) - Method in class org.kududb.client.KuduSession
-
- setTimeoutMillis(long) - Method in interface org.kududb.client.SessionConfiguration
-
Sets the timeout for the next applied operations.
- setUpperBound(boolean) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a boolean for the upper bound
- setUpperBound(byte) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a byte for the upper bound
- setUpperBound(short) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a short for the upper bound
- setUpperBound(int) - Method in class org.kududb.client.ColumnRangePredicate
-
Set an int for the upper bound
- setUpperBound(long) - Method in class org.kududb.client.ColumnRangePredicate
-
- setUpperBound(String) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a string for the upper bound
- setUpperBound(byte[]) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a binary value for the upper bound
- setUpperBound(float) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a float for the upper bound
- setUpperBound(double) - Method in class org.kududb.client.ColumnRangePredicate
-
Set a double for the upper bound
- shutdown() - Method in class org.kududb.client.AsyncKuduClient
-
Performs a graceful shutdown of this instance.
- shutdown() - Method in class org.kududb.client.KuduClient
-
Performs a graceful shutdown of this instance.
- SLEEP_TIME - Static variable in class org.kududb.client.AsyncKuduClient
-
- snapshotTimestamp(long) - Method in class org.kududb.client.AbstractKuduScannerBuilder
-
Sets a previously encoded HT timestamp as a snapshot timestamp, for tests.