Skip navigation links
A B C D E F G H I K L M N O P R S T U V W 

A

Aborted(String) - Static method in class org.apache.kudu.client.Status
 
Aborted(String, int) - Static method in class org.apache.kudu.client.Status
 
abortTask(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
AbstractKuduScannerBuilder<S extends AbstractKuduScannerBuilder<? super S,T>,T> - Class in org.apache.kudu.client
Abstract class to extend in order to create builders for scanners.
addBinary(int, byte[]) - Method in class org.apache.kudu.client.PartialRow
Add binary data with the specified value.
addBinary(int, ByteBuffer) - Method in class org.apache.kudu.client.PartialRow
Add binary data with the specified value, from the current ByteBuffer's position to its limit.
addBinary(String, byte[]) - Method in class org.apache.kudu.client.PartialRow
Add binary data with the specified value.
addBinary(String, ByteBuffer) - Method in class org.apache.kudu.client.PartialRow
Add binary data with the specified value, from the current ByteBuffer's position to its limit.
addBoolean(int, boolean) - Method in class org.apache.kudu.client.PartialRow
Add a boolean for the specified column.
addBoolean(String, boolean) - Method in class org.apache.kudu.client.PartialRow
Add a boolean for the specified column.
addByte(int, byte) - Method in class org.apache.kudu.client.PartialRow
Add a byte for the specified column.
addByte(String, byte) - Method in class org.apache.kudu.client.PartialRow
Add a byte for the specified column.
addColumn(ColumnSchema) - Method in class org.apache.kudu.client.AlterTableOptions
Add a new column.
addColumn(String, Type, Object) - Method in class org.apache.kudu.client.AlterTableOptions
Add a new column that's not nullable.
addColumnRangePredicate(ColumnRangePredicate) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
addColumnRangePredicatesRaw(byte[]) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
addCredentialsToJob(KuduClient, Job) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Export the credentials from a KuduClient and store them in the given MapReduce Job so that KuduClients created from within tasks of that job can authenticate to Kudu.
addDecimal(int, BigDecimal) - Method in class org.apache.kudu.client.PartialRow
Add a Decimal for the specified column.
addDecimal(String, BigDecimal) - Method in class org.apache.kudu.client.PartialRow
Add a Decimal for the specified column.
addDependencyJars(Job) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Add the Kudu dependency jars as well as jars for any of the configured job classes to the job configuration, so that JobClient will ship them to the cluster and add them to the DistributedCache.
addDependencyJars(Configuration, Class<?>...) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Add the jars containing the given classes to the job's configuration such that JobClient will ship them to the cluster and add them to the DistributedCache.
addDouble(int, double) - Method in class org.apache.kudu.client.PartialRow
Add an double for the specified column.
addDouble(String, double) - Method in class org.apache.kudu.client.PartialRow
Add an double for the specified column.
addFloat(int, float) - Method in class org.apache.kudu.client.PartialRow
Add an float for the specified column.
addFloat(String, float) - Method in class org.apache.kudu.client.PartialRow
Add an float for the specified column.
addHashPartitions(List<String>, int) - Method in class org.apache.kudu.client.CreateTableOptions
Add a set of hash partitions to the table.
addHashPartitions(List<String>, int, int) - Method in class org.apache.kudu.client.CreateTableOptions
Add a set of hash partitions to the table.
addInt(int, int) - Method in class org.apache.kudu.client.PartialRow
Add an int for the specified column.
addInt(String, int) - Method in class org.apache.kudu.client.PartialRow
Add an int for the specified column.
addKuduDependencyJars(Configuration) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Add Kudu and its dependencies (only) to the job configuration.
addLong(int, long) - Method in class org.apache.kudu.client.PartialRow
Add an long for the specified column.
addLong(String, long) - Method in class org.apache.kudu.client.PartialRow
Add an long for the specified column.
addNullableColumn(String, Type) - Method in class org.apache.kudu.client.AlterTableOptions
Add a new column that's nullable and has no default value.
addNullableColumn(String, Type, Object) - Method in class org.apache.kudu.client.AlterTableOptions
Add a new column that's nullable.
addPredicate(KuduPredicate) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Adds a predicate to the scan.
addRangePartition(PartialRow, PartialRow) - Method in class org.apache.kudu.client.AlterTableOptions
Add a range partition to the table with an inclusive lower bound and an exclusive upper bound.
addRangePartition(PartialRow, PartialRow, RangePartitionBound, RangePartitionBound) - Method in class org.apache.kudu.client.AlterTableOptions
Add a range partition to the table with a lower bound and upper bound.
addRangePartition(PartialRow, PartialRow) - Method in class org.apache.kudu.client.CreateTableOptions
Add a range partition partition to the table with an inclusive lower bound and an exclusive upper bound.
addRangePartition(PartialRow, PartialRow, RangePartitionBound, RangePartitionBound) - Method in class org.apache.kudu.client.CreateTableOptions
Add a range partition partition to the table with a lower bound and upper bound.
addShort(int, short) - Method in class org.apache.kudu.client.PartialRow
Add a short for the specified column.
addShort(String, short) - Method in class org.apache.kudu.client.PartialRow
Add a short for the specified column.
addSplitRow(PartialRow) - Method in class org.apache.kudu.client.CreateTableOptions
Add a range partition split.
addString(int, String) - Method in class org.apache.kudu.client.PartialRow
Add a String for the specified column.
addString(String, String) - Method in class org.apache.kudu.client.PartialRow
Add a String for the specified column.
addStringUtf8(int, byte[]) - Method in class org.apache.kudu.client.PartialRow
Add a String for the specified value, encoded as UTF8.
addStringUtf8(String, byte[]) - Method in class org.apache.kudu.client.PartialRow
Add a String for the specified value, encoded as UTF8.
addTimestamp(int, Timestamp) - Method in class org.apache.kudu.client.PartialRow
Add a Timestamp for the specified column.
addTimestamp(String, Timestamp) - Method in class org.apache.kudu.client.PartialRow
Add a Timestamp for the specified column.
ADMIN_OPERATION_TIMEOUT_MS_KEY - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
AlreadyPresent(String) - Static method in class org.apache.kudu.client.Status
 
AlreadyPresent(String, int) - Static method in class org.apache.kudu.client.Status
 
alterTable(String, AlterTableOptions) - Method in class org.apache.kudu.client.AsyncKuduClient
Alter a table on the cluster as specified by the builder.
alterTable(String, AlterTableOptions) - Method in class org.apache.kudu.client.KuduClient
Alter a table on the cluster as specified by the builder.
AlterTableOptions - Class in org.apache.kudu.client
This builder must be used to alter a table.
AlterTableOptions() - Constructor for class org.apache.kudu.client.AlterTableOptions
 
AlterTableResponse - Class in org.apache.kudu.client
 
apply(Operation) - Method in class org.apache.kudu.client.AsyncKuduSession
Apply the given operation.
apply(Operation) - Method in class org.apache.kudu.client.KuduSession
Apply a given Operation to Kudu as part of this session.
asyncGetTabletsLocations(long) - Method in class org.apache.kudu.client.KuduTable
Deprecated.
use the KuduScanToken API
asyncGetTabletsLocations(byte[], byte[], long) - Method in class org.apache.kudu.client.KuduTable
Deprecated.
use the KuduScanToken API
AsyncKuduClient - Class in org.apache.kudu.client
A fully asynchronous and thread-safe client for Kudu.
AsyncKuduClient.AsyncKuduClientBuilder - Class in org.apache.kudu.client
Builder class to use in order to connect to Kudu.
AsyncKuduClientBuilder(String) - Constructor for class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Creates a new builder for a client that will connect to the specified masters.
AsyncKuduClientBuilder(List<String>) - Constructor for class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Creates a new builder for a client that will connect to the specified masters.
AsyncKuduScanner - Class in org.apache.kudu.client
Creates a scanner to read data from Kudu.
AsyncKuduScanner.AsyncKuduScannerBuilder - Class in org.apache.kudu.client
A Builder class to build AsyncKuduScanner.
AsyncKuduScanner.ReadMode - Enum in org.apache.kudu.client
The possible read modes for scanners.
AsyncKuduSession - Class in org.apache.kudu.client
An AsyncKuduSession belongs to a specific AsyncKuduClient, and represents a context in which all write data access should take place.
AvroKuduOperationsProducer - Class in org.apache.kudu.flume.sink
An Avro serializer that generates one operation per event by deserializing the event body as an Avro record and mapping its fields to columns in a Kudu table.
AvroKuduOperationsProducer() - Constructor for class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 

B

BAD_COLUMN_VALUE_POLICY_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
BATCH_SIZE - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Maximum number of events that the sink should take from the channel per transaction.
batchSizeBytes(int) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets the maximum number of bytes returned by the scanner, on each batch.
BigLinkedListCommon - Class in org.apache.kudu.mapreduce.tools
Static constants, helper methods, and utility classes for BigLinkedList implementations.
BloomFilter - Class in org.apache.kudu.util
An space-efficient filter which offers an approximate containment check.
bossCount(int) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Set the maximum number of boss threads.
bossCount(int) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Set the maximum number of boss threads.
build() - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
 
build() - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Creates a new client that connects to the masters.
build() - Method in class org.apache.kudu.client.AsyncKuduScanner.AsyncKuduScannerBuilder
Builds an AsyncKuduScanner using the passed configurations.
build() - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Creates a new client that connects to the masters.
build() - Method in class org.apache.kudu.client.KuduScanner.KuduScannerBuilder
Builds a KuduScanner using the passed configurations.
build() - Method in class org.apache.kudu.client.KuduScanToken.KuduScanTokenBuilder
 
build() - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Builds a ColumnSchema using the passed parameters.
build() - Method in class org.apache.kudu.ColumnTypeAttributes.ColumnTypeAttributesBuilder
Builds a ColumnTypeAttributes using the passed parameters.
byCount(int) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter, default hashing is Murmur2 and false positive rate is 0.01.
byCountAndFPRate(int, double) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter, default hashing is Murmur2.
byCountAndFPRate(int, double, BloomFilter.HashFunction) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter.
bySize(int) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter, default hashing is Murmur2 and false positive rate is 0.01.
bySizeAndFPRate(int, double) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter, default hashing is Murmur2.
bySizeAndFPRate(int, double, BloomFilter.HashFunction) - Static method in class org.apache.kudu.util.BloomFilter
Generate bloom filter.

C

cacheBlocks(boolean) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets the block caching policy for the scanner.
changeCompressionAlgorithm(String, ColumnSchema.CompressionAlgorithm) - Method in class org.apache.kudu.client.AlterTableOptions
Change the compression used for a column.
changeDefault(String, Object) - Method in class org.apache.kudu.client.AlterTableOptions
Change the default value for a column.
changeDesiredBlockSize(String, int) - Method in class org.apache.kudu.client.AlterTableOptions
Change the block size of a column's storage.
changeEncoding(String, ColumnSchema.Encoding) - Method in class org.apache.kudu.client.AlterTableOptions
Change the encoding used for a column.
checkOutputSpecs(JobContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
close() - Method in class org.apache.kudu.client.AsyncKuduClient
Invokes AsyncKuduClient.shutdown() and waits.
close() - Method in class org.apache.kudu.client.AsyncKuduScanner
Closes this scanner (don't forget to call this when you're done with it!).
close() - Method in class org.apache.kudu.client.AsyncKuduSession
Flushes the buffered operations and marks this session as closed.
close() - Method in class org.apache.kudu.client.KuduClient
Analogous to KuduClient.shutdown().
close() - Method in class org.apache.kudu.client.KuduScanner
Closes this scanner (don't forget to call this when you're done with it!).
close() - Method in class org.apache.kudu.client.KuduSession
Blocking call that flushes the buffers (see KuduSession.flush() and closes the sessions.
close() - Method in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
close() - Method in interface org.apache.kudu.flume.sink.KuduOperationsProducer
Cleans up any state.
close() - Method in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
close() - Method in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
close() - Method in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
collectErrors(List<OperationResponse>) - Static method in class org.apache.kudu.client.OperationResponse
Utility method that collects all the row errors from the given list of responses.
COLUMN_CLIENT - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
identifier of the mapred task that generated this row.
COLUMN_CLIENT_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_KEY_ONE - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
Row key, two times 8 bytes.
COLUMN_KEY_ONE_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_KEY_TWO - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_KEY_TWO_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_PREV_ONE - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
Link to the id of the prev node in the linked list, two times 8 bytes.
COLUMN_PREV_ONE_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_PREV_TWO - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_PREV_TWO_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_ROW_ID - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
the id of the row within the same client.
COLUMN_ROW_ID_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
COLUMN_UPDATE_COUNT - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
The number of times this row was updated.
COLUMN_UPDATE_COUNT_IDX - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
ColumnRangePredicate - Class in org.apache.kudu.client
Deprecated.
use the KuduPredicate class instead.
ColumnRangePredicate(ColumnSchema) - Constructor for class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Create the predicate on the specified column
ColumnSchema - Class in org.apache.kudu
Represents a Kudu Table column.
ColumnSchema.ColumnSchemaBuilder - Class in org.apache.kudu
Builder for ColumnSchema.
ColumnSchema.CompressionAlgorithm - Enum in org.apache.kudu
Specifies the compression algorithm of data for a column on disk.
ColumnSchema.Encoding - Enum in org.apache.kudu
Specifies the encoding of data for a column on disk.
ColumnSchemaBuilder(String, Type) - Constructor for class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Constructor for the required parameters.
ColumnTypeAttributes - Class in org.apache.kudu
Represents a Kudu Table column's type attributes.
ColumnTypeAttributes.ColumnTypeAttributesBuilder - Class in org.apache.kudu
Builder for ColumnTypeAttributes.
ColumnTypeAttributesBuilder() - Constructor for class org.apache.kudu.ColumnTypeAttributes.ColumnTypeAttributesBuilder
 
CommandLineParser - Class in org.apache.kudu.mapreduce
Utility class that manages common configurations to all MR jobs.
CommandLineParser(Configuration) - Constructor for class org.apache.kudu.mapreduce.CommandLineParser
Constructor that uses a Configuration that has already been through GenericOptionsParser's command line parsing.
commitTask(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
compareTo(KuduScanToken) - Method in class org.apache.kudu.client.KuduScanToken
 
compressionAlgorithm(ColumnSchema.CompressionAlgorithm) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Set the compression algorithm for this column.
ConfigurationError(String) - Static method in class org.apache.kudu.client.Status
 
ConfigurationError(String, int) - Static method in class org.apache.kudu.client.Status
 
configure(Context) - Method in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
configure(Context) - Method in class org.apache.kudu.flume.sink.KuduSink
 
configure(Context) - Method in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
configure(Context) - Method in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
configure(Context) - Method in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
Corruption(String) - Static method in class org.apache.kudu.client.Status
 
Corruption(String, int) - Static method in class org.apache.kudu.client.Status
 
countPendingErrors() - Method in class org.apache.kudu.client.AsyncKuduSession
 
countPendingErrors() - Method in class org.apache.kudu.client.KuduSession
 
countPendingErrors() - Method in interface org.apache.kudu.client.SessionConfiguration
Return the number of errors which are pending.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableInputFormat
 
createSubmittableJob(Configuration, String[]) - Static method in class org.apache.kudu.mapreduce.tools.ExportCsv
Sets up the actual job.
createSubmittableJob(Configuration, String[]) - Static method in class org.apache.kudu.mapreduce.tools.ImportCsv
Sets up the actual job.
createSubmittableJob(Configuration, String[]) - Static method in class org.apache.kudu.mapreduce.tools.ImportParquet
Sets up the actual job.
createTable(String, Schema, CreateTableOptions) - Method in class org.apache.kudu.client.AsyncKuduClient
Create a table on the cluster with the specified name, schema, and table configurations.
createTable(String, Schema, CreateTableOptions) - Method in class org.apache.kudu.client.KuduClient
Create a table on the cluster with the specified name, schema, and table configurations.
CreateTableOptions - Class in org.apache.kudu.client
This is a builder class for all the options that can be provided while creating a table.
CreateTableOptions() - Constructor for class org.apache.kudu.client.CreateTableOptions
 
CsvParser - Class in org.apache.kudu.mapreduce.tools
Column-separated values parser that gives access to the different columns inside each line of data.
CsvParser(String, String) - Constructor for class org.apache.kudu.mapreduce.tools.CsvParser
 
currentTablet() - Method in class org.apache.kudu.client.KuduScanner
Returns the RemoteTablet currently being scanned, if any.

D

DEFAULT_BAD_COLUMN_VALUE_POLICY - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
DEFAULT_ENCODING - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
DEFAULT_HEADS_TABLE_NAME - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
DEFAULT_MISSING_COLUMN_POLICY - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
DEFAULT_OPERATION - Static variable in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
DEFAULT_OPERATION - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
DEFAULT_OPERATION_TIMEOUT_MS - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
DEFAULT_SKIP_BAD_COLUMN_VALUE - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
DEFAULT_SKIP_MISSING_COLUMN - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
DEFAULT_SOCKET_READ_TIMEOUT_MS - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
DEFAULT_TABLE_NAME - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
DEFAULT_UNMATCHED_ROW_POLICY - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
DEFAULT_WARN_UNMATCHED_ROWS - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
defaultAdminOperationTimeoutMs(long) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Sets the default timeout used for administrative operations (e.g.
defaultAdminOperationTimeoutMs(long) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Sets the default timeout used for administrative operations (e.g.
defaultOperationTimeoutMs(long) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Sets the default timeout used for user operations (using sessions and scanners).
defaultOperationTimeoutMs(long) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Sets the default timeout used for user operations (using sessions and scanners).
defaultSocketReadTimeoutMs(long) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Sets the default timeout to use when waiting on data from a socket.
defaultSocketReadTimeoutMs(long) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Sets the default timeout to use when waiting on data from a socket.
defaultValue(Object) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Sets the default value that will be read from the column.
Delete - Class in org.apache.kudu.client
Class of Operation for whole row removals.
deleteTable(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Delete a table on the cluster with the specified name.
deleteTable(String) - Method in class org.apache.kudu.client.KuduClient
Delete a table on the cluster with the specified name.
DeleteTableResponse - Class in org.apache.kudu.client
 
deserialize(Schema, byte[]) - Static method in class org.apache.kudu.client.KuduPredicate
Serializes a list of KuduPredicate into a byte array.
deserializeIntoScanner(byte[], KuduClient) - Static method in class org.apache.kudu.client.KuduScanToken
Deserializes a KuduScanToken into a KuduScanner.
desiredBlockSize(int) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Set the desired block size for this column.
disableStatistics() - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Disable this client's collection of statistics.
disableStatistics() - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Disable this client's collection of statistics.
dropColumn(String) - Method in class org.apache.kudu.client.AlterTableOptions
Drop a column.
dropRangePartition(PartialRow, PartialRow) - Method in class org.apache.kudu.client.AlterTableOptions
Drop the range partition from the table with the specified inclusive lower bound and exclusive upper bound.
dropRangePartition(PartialRow, PartialRow, RangePartitionBound, RangePartitionBound) - Method in class org.apache.kudu.client.AlterTableOptions
Drop the range partition from the table with the specified lower bound and upper bound.

E

empty() - Static method in class org.apache.kudu.client.RowResultIterator
 
EMPTY_ARRAY - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
encodePrimaryKey() - Method in class org.apache.kudu.client.PartialRow
Returns the encoded primary key of the row.
encoding(ColumnSchema.Encoding) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Set the block encoding for this column.
ENCODING_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
EndOfFile(String) - Static method in class org.apache.kudu.client.Status
 
EndOfFile(String, int) - Static method in class org.apache.kudu.client.Status
 
equals(Object) - Method in class org.apache.kudu.client.KuduPredicate
 
equals(Object) - Method in class org.apache.kudu.ColumnSchema
 
equals(Object) - Method in class org.apache.kudu.ColumnTypeAttributes
 
exclusiveUpperBound(PartialRow) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Add an upper bound (exclusive) primary key for the scan.
exclusiveUpperBoundRaw(byte[]) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
exportAuthenticationCredentials() - Method in class org.apache.kudu.client.AsyncKuduClient
Export serialized authentication data that may be passed to a different client instance and imported to provide that client the ability to connect to the cluster.
exportAuthenticationCredentials() - Method in class org.apache.kudu.client.KuduClient
Export serialized authentication data that may be passed to a different client instance and imported to provide that client the ability to connect to the cluster.
ExportCsv - Class in org.apache.kudu.mapreduce.tools
Map-only job that reads Kudu rows and writes them into a CSV file.
ExportCsv() - Constructor for class org.apache.kudu.mapreduce.tools.ExportCsv
 
ExternalConsistencyMode - Enum in org.apache.kudu.client
The possible external consistency modes on which Kudu operates.

F

flush() - Method in class org.apache.kudu.client.AsyncKuduSession
Flush buffered writes.
flush() - Method in class org.apache.kudu.client.KuduSession
Blocking call that force flushes this session's buffers.
fromPB(Schema, Common.ColumnPredicatePB) - Static method in class org.apache.kudu.client.KuduPredicate
Convert a column predicate protobuf message into a predicate.

G

getAdminOperationTimeoutMs() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get the configured timeout for admin operations.
getAsyncClient() - Method in class org.apache.kudu.client.KuduTable
Get the async client that created this instance.
getAsyncClient() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get an async client connected to the configured Master(s).
getBatchSizeBytes() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns the maximum number of bytes returned by the scanner, on each batch.
getBatchSizeBytes() - Method in class org.apache.kudu.client.KuduScanner
Returns the maximum number of bytes returned by the scanner, on each batch.
getBinary(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's binary data.
getBinary(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's binary data.
getBinary(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's binary data.
getBinary(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's binary data.
getBinaryCopy(String) - Method in class org.apache.kudu.client.PartialRow
Get a copy of the specified column's binary data.
getBinaryCopy(int) - Method in class org.apache.kudu.client.PartialRow
Get a copy of the specified column's binary data.
getBinaryCopy(String) - Method in class org.apache.kudu.client.RowResult
Get a copy of the specified column's binary data.
getBinaryCopy(int) - Method in class org.apache.kudu.client.RowResult
Get a copy of the specified column's binary data.
getBitSet() - Method in class org.apache.kudu.util.BloomFilter
Get the internal bit set in bytes.
getBoolean(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's boolean
getBoolean(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's boolean
getBoolean(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's boolean
getBoolean(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's boolean
getByte(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's byte
getByte(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's byte
getByte(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's byte
getByte(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's byte
getCacheBlocks() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns if this scanner was configured to cache data blocks or not.
getCacheBlocks() - Method in class org.apache.kudu.client.KuduScanner
Returns if this scanner was configured to cache data blocks or not.
getClient() - Method in class org.apache.kudu.flume.sink.KuduSink
 
getClient() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get a client connected to the configured Master(s).
getClientStatistic(Statistics.Statistic) - Method in class org.apache.kudu.client.Statistics
Get the statistic count of the whole client.
getColumn() - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Get the column used by this predicate
getColumn(String) - Method in class org.apache.kudu.Schema
Get the column associated with the specified name
getColumnByIndex(int) - Method in class org.apache.kudu.Schema
Get the column at the specified index in the original list
getColumnCount() - Method in class org.apache.kudu.Schema
Get the count of columns in this schema
getColumnIndex(String) - Method in class org.apache.kudu.Schema
Get the index for the provided column name.
getColumnIndex(int) - Method in class org.apache.kudu.Schema
Get the column index of the column with the provided ID.
getColumnOffset(int) - Method in class org.apache.kudu.Schema
Get the index at which this column can be found in the backing byte array
getColumnProjection() - Method in class org.apache.kudu.client.RowResult
Get the schema used for this scanner's column projection.
getColumns() - Method in class org.apache.kudu.Schema
Get the list of columns used to create this schema
getColumnType(String) - Method in class org.apache.kudu.client.RowResult
Get the type of a column in this result.
getColumnType(int) - Method in class org.apache.kudu.client.RowResult
Get the type of a column in this result.
getCompressionAlgorithm() - Method in class org.apache.kudu.ColumnSchema
Return the compression algorithm of this column, or null if it is not known.
getConf() - Method in class org.apache.kudu.mapreduce.KuduTableInputFormat
 
getConf() - Method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
getCreateTableOptions(Schema, int, int, int) - Static method in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
getDataType() - Method in enum org.apache.kudu.Type
getDataType(ColumnTypeAttributes) - Method in enum org.apache.kudu.Type
Get the data type from the common's pb
getDecimal(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's BigDecimal
getDecimal(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's Decimal.
getDecimal(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's Decimal.
getDecimal(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's Decimal.
getDefaultAdminOperationTimeoutMs() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the timeout used for admin operations.
getDefaultAdminOperationTimeoutMs() - Method in class org.apache.kudu.client.KuduClient
Get the timeout used for admin operations.
getDefaultOperationTimeoutMs() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the timeout used for operations on sessions and scanners.
getDefaultOperationTimeoutMs() - Method in class org.apache.kudu.client.KuduClient
Get the timeout used for operations on sessions and scanners.
getDefaultSocketReadTimeoutMs() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the timeout used when waiting to read data from a socket.
getDefaultValue() - Method in class org.apache.kudu.ColumnSchema
The Java object representation of the default value that's read
getDeferred() - Method in exception org.apache.kudu.client.PleaseThrottleException
Returns a deferred one can wait on before retrying the failed RPC.
getDesiredBlockSize() - Method in class org.apache.kudu.ColumnSchema
Gets the desired block size for this column.
getDouble(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's double
getDouble(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's double
getDouble(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's double
getDouble(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's double
getEncoding() - Method in class org.apache.kudu.ColumnSchema
Return the encoding of this column, or null if it is not known.
getEndKey() - Method in class org.apache.kudu.client.LocatedTablet
Deprecated.
getErrorStatus() - Method in class org.apache.kudu.client.RowError
Get the status code and message of the row error.
getFailedRpc() - Method in interface org.apache.kudu.client.HasFailedRpcException
Returns the RPC that caused this exception.
getFailedRpc() - Method in exception org.apache.kudu.client.PleaseThrottleException
The RPC that was made to fail with this exception.
getFloat(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's float
getFloat(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's float
getFloat(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's float
getFloat(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's float
getFlushMode() - Method in class org.apache.kudu.client.AsyncKuduSession
 
getFlushMode() - Method in class org.apache.kudu.client.KuduSession
 
getFlushMode() - Method in interface org.apache.kudu.client.SessionConfiguration
Get the current flush mode.
getFormattedRangePartitions(long) - Method in class org.apache.kudu.client.KuduTable
Retrieves a formatted representation of this table's range partitions.
getHashFunctionName() - Method in class org.apache.kudu.util.BloomFilter
Get the name of hashing used when updating or checking containment.
getHeadsTableSchema() - Static method in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
getHelpSnippet() - Static method in class org.apache.kudu.mapreduce.CommandLineParser
This method returns a single multi-line string that contains the help snippet to append to the tail of a usage() or help() type of method.
getHiveMetastoreConfig() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the Hive Metastore configuration of the most recently connected-to leader master, or null if the Hive Metastore integration is not enabled.
getHiveMetastoreConfig() - Method in class org.apache.kudu.client.KuduClient
Returns the Hive Metastore configuration of the cluster.
getInt(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's integer
getInt(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's integer
getInt(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's integer
getInt(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's integer
getInternalPbType() - Method in enum org.apache.kudu.ColumnSchema.CompressionAlgorithm
 
getInternalPbType() - Method in enum org.apache.kudu.ColumnSchema.Encoding
 
getKuduTable(String) - Static method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
getLastPropagatedTimestamp() - Method in class org.apache.kudu.client.AsyncKuduClient
Returns the last timestamp received from a server.
getLastPropagatedTimestamp() - Method in class org.apache.kudu.client.KuduClient
Returns the last timestamp received from a server.
getLeaderReplica() - Method in class org.apache.kudu.client.LocatedTablet
Return the current leader, or null if there is none.
getLimit() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns the maximum number of rows that this scanner was configured to return.
getLimit() - Method in class org.apache.kudu.client.KuduScanner
Returns the maximum number of rows that this scanner was configured to return.
getLong(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's long If this is a UNIXTIME_MICROS column, the long value corresponds to a number of microseconds since midnight, January 1, 1970 UTC.
getLong(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's long If this is a UNIXTIME_MICROS column, the long value corresponds to a number of microseconds since midnight, January 1, 1970 UTC.
getLong(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's long If this is a UNIXTIME_MICROS column, the long value corresponds to a number of microseconds since midnight, January 1, 1970 UTC.
getLong(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's long If this is a UNIXTIME_MICROS column, the long value corresponds to a number of microseconds since midnight, January 1, 1970 UTC.
getLowerBound() - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Get the lower bound in its raw representation
getMasterAddresses() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get the configured master's config.
getMasterAddressesAsString() - Method in class org.apache.kudu.client.AsyncKuduClient
 
getMasterAddressesAsString() - Method in class org.apache.kudu.client.KuduClient
 
getMasterTableLocationsPB(KuduRpc<?>) - Method in class org.apache.kudu.client.AsyncKuduClient
Update the master config: send RPCs to all config members, use the returned data to fill a Master.GetTabletLocationsResponsePB object.
getMessage() - Method in class org.apache.kudu.client.RowError
Deprecated.
Please use getErrorStatus() instead. Will be removed in a future version.
getName() - Method in class org.apache.kudu.client.KuduTable
Get this table's name.
getName() - Method in class org.apache.kudu.ColumnSchema
Get the column's name
getName() - Method in enum org.apache.kudu.Type
Get the string representation of this type
getNHashes() - Method in class org.apache.kudu.util.BloomFilter
Get the number of hashing times when updating or checking containment.
getNumReplicas() - Method in class org.apache.kudu.client.KuduTable
Get this table's replication factor.
getNumReplicas() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get the number of replicas to use when configuring a new table.
getNumRows() - Method in class org.apache.kudu.client.RowResultIterator
Get the number of rows in this iterator.
getOperation() - Method in class org.apache.kudu.client.RowError
Get the Operation that failed.
getOperations(Event) - Method in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
getOperations(Event) - Method in interface org.apache.kudu.flume.sink.KuduOperationsProducer
Returns the operations that should be written to Kudu as a result of this event.
getOperations(Event) - Method in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
getOperations(Event) - Method in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
getOperations(Event) - Method in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
getOperationTimeoutMs() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get the configured timeout for operations on sessions and scanners.
getOutputCommitter(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
getPartition() - Method in class org.apache.kudu.client.LocatedTablet
 
getPartitionSchema() - Method in class org.apache.kudu.client.KuduTable
Gets the table's partition schema.
getPendingErrors() - Method in class org.apache.kudu.client.AsyncKuduSession
 
getPendingErrors() - Method in class org.apache.kudu.client.KuduSession
 
getPendingErrors() - Method in interface org.apache.kudu.client.SessionConfiguration
Return any errors from previous calls.
getPosixCode() - Method in class org.apache.kudu.client.Status
Get the posix code associated with the error.
getPrecision() - Method in class org.apache.kudu.ColumnTypeAttributes
Return the precision;
getPrimaryKeyColumnCount() - Method in class org.apache.kudu.Schema
Get the count of columns that are part of the primary key.
getPrimaryKeyColumns() - Method in class org.apache.kudu.Schema
Get the primary key columns.
getProjectionSchema() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns the projection schema of this scanner.
getProjectionSchema() - Method in class org.apache.kudu.client.KuduScanner
Returns the projection schema of this scanner.
getRangePartitions(long) - Method in class org.apache.kudu.client.KuduTable
Retrieves this table's range partitions.
getReadMode() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns the ReadMode for this scanner.
getReadMode() - Method in class org.apache.kudu.client.KuduScanner
Returns the ReadMode for this scanner.
getRecordWriter(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
getReplicas() - Method in class org.apache.kudu.client.LocatedTablet
 
getRole() - Method in class org.apache.kudu.client.LocatedTablet.Replica
 
getRow() - Method in class org.apache.kudu.client.Operation
Get the underlying row to modify.
getRowError() - Method in class org.apache.kudu.client.OperationResponse
Returns a row error.
getRowErrors() - Method in class org.apache.kudu.client.RowErrorsAndOverflowStatus
Get the collected row errors.
getRowKeyProjection() - Method in class org.apache.kudu.Schema
Get a schema that only contains the columns which are part of the key
getRowSize() - Method in class org.apache.kudu.Schema
Get the size a row built using this schema would be
getRpcHost() - Method in class org.apache.kudu.client.LocatedTablet.Replica
 
getRpcPort() - Method in class org.apache.kudu.client.LocatedTablet.Replica
 
getScale() - Method in class org.apache.kudu.ColumnTypeAttributes
Return the scale;
getScanRequestTimeout() - Method in class org.apache.kudu.client.AsyncKuduScanner
Returns the scan request timeout for this scanner.
getScanRequestTimeout() - Method in class org.apache.kudu.client.KuduScanner
Returns the current value of the scanner's scan request timeout.
getSchema() - Method in class org.apache.kudu.client.KuduTable
Get this table's schema, as of the moment this instance was created.
getSchema() - Method in class org.apache.kudu.client.RowResult
Get the schema associated with this result.
getShort(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's short
getShort(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's short
getShort(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's short
getShort(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's short
getSize() - Method in enum org.apache.kudu.Type
getSize(ColumnTypeAttributes) - Method in enum org.apache.kudu.Type
The size of this type on the wire
getSocketReadTimeoutMs() - Method in class org.apache.kudu.mapreduce.CommandLineParser
Get the configured timeout for socket reads.
getSplits(JobContext) - Method in class org.apache.kudu.mapreduce.KuduTableInputFormat
 
getStartKey() - Method in class org.apache.kudu.client.LocatedTablet
Deprecated.
getStatistics() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the statistics object of this client.
getStatistics() - Method in class org.apache.kudu.client.KuduClient
Get the statistics object of this client.
getStatus() - Method in exception org.apache.kudu.client.KuduException
Get the Status object for this exception.
getStatus() - Method in class org.apache.kudu.client.RowError
Deprecated.
Please use getErrorStatus() instead. Will be removed in a future version.
getString(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's string.
getString(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's string.
getString(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's string.
getString(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's string.
getTableFromContext(TaskInputOutputContext) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Use this method when setting up a task to get access to the KuduTable in order to create Inserts, Updates, and Deletes.
getTableId() - Method in class org.apache.kudu.client.AlterTableResponse
 
getTableId() - Method in class org.apache.kudu.client.KuduTable
Get this table's unique identifier.
getTableName(String) - Method in class org.apache.kudu.client.Statistics
Get table name of the given tablet id.
getTableSchema() - Static method in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
getTableSet() - Method in class org.apache.kudu.client.Statistics
Get the set of tables which have been written into by this client, which have statistics information.
getTablesList() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the list of all the tables.
getTablesList(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Get a list of table names.
getTablesList() - Method in class org.apache.kudu.client.KuduClient
Get the list of all the tables.
getTablesList(String) - Method in class org.apache.kudu.client.KuduClient
Get a list of table names.
getTablesList() - Method in class org.apache.kudu.client.ListTablesResponse
Get the list of tables as specified in the request.
getTableStatistic(String, Statistics.Statistic) - Method in class org.apache.kudu.client.Statistics
Get the statistic count of this table.
getTablet() - Method in class org.apache.kudu.client.KuduScanToken
Returns the tablet which the scanner created from this token will access.
getTabletId() - Method in class org.apache.kudu.client.LocatedTablet
 
getTabletServersCount() - Method in class org.apache.kudu.client.ListTabletServersResponse
Get the count of tablet servers as reported by the master.
getTabletServersList() - Method in class org.apache.kudu.client.ListTabletServersResponse
Get the list of tablet servers, as represented by their hostname.
getTabletSet() - Method in class org.apache.kudu.client.Statistics
Get the set of tablets which have been written into by this client, which have statistics information.
getTabletsLocations(long) - Method in class org.apache.kudu.client.KuduTable
Deprecated.
use the KuduScanToken API
getTabletsLocations(byte[], byte[], long) - Method in class org.apache.kudu.client.KuduTable
Deprecated.
use the KuduScanToken API
getTabletStatistic(String, Statistics.Statistic) - Method in class org.apache.kudu.client.Statistics
Get the statistic count of this tablet.
getTimeoutMillis() - Method in class org.apache.kudu.client.AsyncKuduSession
 
getTimeoutMillis() - Method in class org.apache.kudu.client.KuduSession
 
getTimeoutMillis() - Method in interface org.apache.kudu.client.SessionConfiguration
Get the current timeout.
getTimestamp(String) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's Timestamp.
getTimestamp(int) - Method in class org.apache.kudu.client.PartialRow
Get the specified column's Timestamp.
getTimestamp(String) - Method in class org.apache.kudu.client.RowResult
Get the specified column's Timestamp.
getTimestamp(int) - Method in class org.apache.kudu.client.RowResult
Get the specified column's Timestamp.
getTsUUID() - Method in class org.apache.kudu.client.RowError
Get the identifier of the tablet server that sent the error.
getType() - Method in class org.apache.kudu.ColumnSchema
Get the column's Type
getTypeAttributes() - Method in class org.apache.kudu.ColumnSchema
Return the column type attributes for the column, or null if it is not known.
getTypeForDataType(Common.DataType) - Static method in enum org.apache.kudu.Type
Convert the pb DataType to a Type
getTypeForName(String) - Static method in enum org.apache.kudu.Type
 
getTypeSize() - Method in class org.apache.kudu.ColumnSchema
The size of this type in bytes on the wire.
getUpperBound() - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Get the upper bound in its raw representation
getVarLengthColumnCount() - Method in class org.apache.kudu.Schema
Get the count of columns with variable length (BINARY/STRING) in this schema.
getWriteTimestampRaw() - Method in class org.apache.kudu.client.OperationResponse
Gives the write timestamp that was returned by the Tablet Server.

H

hasColumnIds() - Method in class org.apache.kudu.Schema
Tells whether this schema includes IDs for columns.
HasFailedRpcException - Interface in org.apache.kudu.client
Interface implemented by KuduExceptions that can tell you which RPC failed.
hashCode() - Method in class org.apache.kudu.client.KuduPredicate
 
hashCode() - Method in class org.apache.kudu.ColumnSchema
 
hashCode() - Method in class org.apache.kudu.ColumnTypeAttributes
 
hasLastPropagatedTimestamp() - Method in class org.apache.kudu.client.AsyncKuduClient
Checks if the client received any timestamps from a server.
hasLastPropagatedTimestamp() - Method in class org.apache.kudu.client.KuduClient
Checks if the client received any timestamps from a server.
hasMoreRows() - Method in class org.apache.kudu.client.AsyncKuduScanner
Tells if the last rpc returned that there might be more rows to scan.
hasMoreRows() - Method in class org.apache.kudu.client.KuduScanner
Tells if the last rpc returned that there might be more rows to scan.
hasNext() - Method in class org.apache.kudu.client.RowResultIterator
 
hasNullableColumns() - Method in class org.apache.kudu.Schema
Tells if there's at least one nullable column
hasPendingOperations() - Method in class org.apache.kudu.client.AsyncKuduSession
 
hasPendingOperations() - Method in class org.apache.kudu.client.KuduSession
 
hasPendingOperations() - Method in interface org.apache.kudu.client.SessionConfiguration
Check if there are operations that haven't been completely applied.
hasPrecision() - Method in class org.apache.kudu.ColumnTypeAttributes
Returns true if the precision is set;
hasRowError() - Method in class org.apache.kudu.client.OperationResponse
Tells if this operation response contains a row error.
hasScale() - Method in class org.apache.kudu.ColumnTypeAttributes
Returns true if the scale is set;
HEADS_TABLE_NAME_KEY - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 

I

IGNORE_DUPLICATE_ROWS - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Whether to ignore duplicate primary key errors caused by inserts.
IllegalState(String) - Static method in class org.apache.kudu.client.Status
 
IllegalState(String, int) - Static method in class org.apache.kudu.client.Status
 
importAuthenticationCredentials(byte[]) - Method in class org.apache.kudu.client.AsyncKuduClient
Import data allowing this client to authenticate to the cluster.
importAuthenticationCredentials(byte[]) - Method in class org.apache.kudu.client.KuduClient
Import data allowing this client to authenticate to the cluster.
importCredentialsFromCurrentSubject(KuduClient) - Static method in class org.apache.kudu.mapreduce.KuduTableMapReduceUtil
Import credentials from the current thread's JAAS Subject into the provided KuduClient.
ImportCsv - Class in org.apache.kudu.mapreduce.tools
Map-only job that reads CSV files and inserts them into a single Kudu table.
ImportCsv() - Constructor for class org.apache.kudu.mapreduce.tools.ImportCsv
 
ImportParquet - Class in org.apache.kudu.mapreduce.tools
Map-only job that reads Apache Parquet files and inserts them into a single Kudu table.
ImportParquet() - Constructor for class org.apache.kudu.mapreduce.tools.ImportParquet
 
Incomplete(String) - Static method in class org.apache.kudu.client.Status
 
Incomplete(String, int) - Static method in class org.apache.kudu.client.Status
 
initialize(KuduTable) - Method in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
initialize(KuduTable) - Method in interface org.apache.kudu.flume.sink.KuduOperationsProducer
Initializes the operations producer.
initialize(KuduTable) - Method in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
initialize(KuduTable) - Method in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
initialize(KuduTable) - Method in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
Insert - Class in org.apache.kudu.client
Represents a single row insert.
intoScanner(KuduClient) - Method in class org.apache.kudu.client.KuduScanToken
Creates a KuduScanner from this scan token.
InvalidArgument(String) - Static method in class org.apache.kudu.client.Status
 
InvalidArgument(String, int) - Static method in class org.apache.kudu.client.Status
 
IOError(String) - Static method in class org.apache.kudu.client.Status
 
IOError(String, int) - Static method in class org.apache.kudu.client.Status
 
isAborted() - Method in class org.apache.kudu.client.Status
 
isAlreadyPresent() - Method in class org.apache.kudu.client.Status
 
isAlterTableDone(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Check whether a previously issued alterTable() is done.
isAlterTableDone(String) - Method in class org.apache.kudu.client.KuduClient
Waits for all of the tablets in a table to be altered, or until the default admin operation timeout is reached.
IsAlterTableDoneResponse - Class in org.apache.kudu.client
Response to a isAlterTableDone command to use to know if an alter table is currently running on the specified table.
isClosed() - Method in class org.apache.kudu.client.AsyncKuduScanner
 
isClosed() - Method in class org.apache.kudu.client.AsyncKuduSession
 
isClosed() - Method in class org.apache.kudu.client.KuduScanner
 
isClosed() - Method in class org.apache.kudu.client.KuduSession
 
isClosed() - Method in interface org.apache.kudu.client.SessionConfiguration
Returns true if this session has already been closed.
isConfigurationError() - Method in class org.apache.kudu.client.Status
 
isCorruption() - Method in class org.apache.kudu.client.Status
 
isCreateTableDone(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Check whether a previously issued createTable() is done.
isCreateTableDone(String) - Method in class org.apache.kudu.client.KuduClient
Waits for all of the tablets in a table to be created, or until the default admin operation timeout is reached.
IsCreateTableDoneResponse - Class in org.apache.kudu.client
Response to an isCreateTableDone command.
isDone() - Method in class org.apache.kudu.client.IsAlterTableDoneResponse
Tells if the table is done being altered or not.
isDone() - Method in class org.apache.kudu.client.IsCreateTableDoneResponse
Returns whether the table is done being created.
isEndOfFile() - Method in class org.apache.kudu.client.Status
 
isIgnoreAllDuplicateRows() - Method in class org.apache.kudu.client.AsyncKuduSession
 
isIgnoreAllDuplicateRows() - Method in class org.apache.kudu.client.KuduSession
 
isIgnoreAllDuplicateRows() - Method in interface org.apache.kudu.client.SessionConfiguration
Tells if the session is currently ignoring row errors when the whole list returned by a tablet server is of the AlreadyPresent type.
isIllegalState() - Method in class org.apache.kudu.client.Status
 
isIncomplete() - Method in class org.apache.kudu.client.Status
 
isInvalidArgument() - Method in class org.apache.kudu.client.Status
 
isIOError() - Method in class org.apache.kudu.client.Status
 
isKey() - Method in class org.apache.kudu.ColumnSchema
Answers if the column part of the key
isNetworkError() - Method in class org.apache.kudu.client.Status
 
isNotAuthorized() - Method in class org.apache.kudu.client.Status
 
isNotFound() - Method in class org.apache.kudu.client.Status
 
isNotSupported() - Method in class org.apache.kudu.client.Status
 
isNull(String) - Method in class org.apache.kudu.client.PartialRow
Get if the specified column is NULL
isNull(int) - Method in class org.apache.kudu.client.PartialRow
Get if the specified column is NULL
isNull(String) - Method in class org.apache.kudu.client.RowResult
Get if the specified column is NULL
isNull(int) - Method in class org.apache.kudu.client.RowResult
Get if the specified column is NULL
isNullable() - Method in class org.apache.kudu.ColumnSchema
Answers if the column can be set to null
isOverflowed() - Method in class org.apache.kudu.client.RowErrorsAndOverflowStatus
Check if the error collector had an overflow and had to discard row errors.
isRemoteError() - Method in class org.apache.kudu.client.Status
 
isRuntimeError() - Method in class org.apache.kudu.client.Status
 
isServiceUnavailable() - Method in class org.apache.kudu.client.Status
 
isSet(String) - Method in class org.apache.kudu.client.PartialRow
Get if the specified column has been set
isSet(int) - Method in class org.apache.kudu.client.PartialRow
Get if the specified column has been set
isStatisticsEnabled() - Method in class org.apache.kudu.client.AsyncKuduClient
Check if statistics collection is enabled for this client.
isStatisticsEnabled() - Method in class org.apache.kudu.client.KuduClient
Check if statistics collection is enabled for this client.
isTimedOut() - Method in class org.apache.kudu.client.Status
 
isUninitialized() - Method in class org.apache.kudu.client.Status
 
iterator() - Method in class org.apache.kudu.client.RowResultIterator
 

K

keepAlive() - Method in class org.apache.kudu.client.AsyncKuduScanner
Keep the current remote scanner alive.
keepAlive() - Method in class org.apache.kudu.client.KuduScanner
Keep the current remote scanner alive.
KERBEROS_KEYTAB - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Path to the keytab file used for authentication
KERBEROS_PRINCIPAL - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Kerberos principal used for authentication
key(boolean) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Sets if the column is part of the row key.
KEY_COLUMN_DEFAULT - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
KEY_COLUMN_PROP - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
KuduClient - Class in org.apache.kudu.client
A synchronous and thread-safe client for Kudu.
KuduClient.KuduClientBuilder - Class in org.apache.kudu.client
Builder class to use in order to connect to Kudu.
KuduClientBuilder(String) - Constructor for class org.apache.kudu.client.KuduClient.KuduClientBuilder
Creates a new builder for a client that will connect to the specified masters.
KuduClientBuilder(List<String>) - Constructor for class org.apache.kudu.client.KuduClient.KuduClientBuilder
Creates a new builder for a client that will connect to the specified masters.
KuduException - Exception in org.apache.kudu.client
The parent class of all exceptions sent by the Kudu client.
KuduException.OriginalException - Class in org.apache.kudu.client
When exceptions are thrown by the asynchronous Kudu client, the stack trace is typically deep within the internals of the Kudu client and/or Netty.
KuduOperationsProducer - Interface in org.apache.kudu.flume.sink
Interface for an operations producer that produces Kudu Operations from Flume events.
KuduPredicate - Class in org.apache.kudu.client
A predicate which can be used to filter rows based on the value of a column.
KuduPredicate.ComparisonOp - Enum in org.apache.kudu.client
The comparison operator of a predicate.
KuduScanner - Class in org.apache.kudu.client
Synchronous version of AsyncKuduScanner.
KuduScanner.KuduScannerBuilder - Class in org.apache.kudu.client
A Builder class to build KuduScanner.
KuduScanToken - Class in org.apache.kudu.client
A scan token describes a partial scan of a Kudu table limited to a single contiguous physical location.
KuduScanToken.KuduScanTokenBuilder - Class in org.apache.kudu.client
Builds a sequence of scan tokens.
KuduSession - Class in org.apache.kudu.client
Synchronous version of AsyncKuduSession.
KuduSink - Class in org.apache.kudu.flume.sink
A Flume sink that reads events from a channel and writes them to a Kudu table.
KuduSink() - Constructor for class org.apache.kudu.flume.sink.KuduSink
 
KuduSink(KuduClient) - Constructor for class org.apache.kudu.flume.sink.KuduSink
 
KuduSinkConfigurationConstants - Class in org.apache.kudu.flume.sink
 
KuduSinkConfigurationConstants() - Constructor for class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
 
KuduTable - Class in org.apache.kudu.client
A KuduTable represents a table on a particular cluster.
KuduTableInputFormat - Class in org.apache.kudu.mapreduce
This input format generates one split per tablet and the only location for each split is that tablet's leader.
KuduTableInputFormat() - Constructor for class org.apache.kudu.mapreduce.KuduTableInputFormat
 
KuduTableMapReduceUtil - Class in org.apache.kudu.mapreduce
Utility class to setup MR jobs that use Kudu as an input and/or output.
KuduTableOutputCommitter - Class in org.apache.kudu.mapreduce
Small committer class that does not do anything.
KuduTableOutputCommitter() - Constructor for class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
KuduTableOutputFormat - Class in org.apache.kudu.mapreduce
Use KuduTableMapReduceUtil.TableOutputFormatConfigurator to correctly setup this output format, then KuduTableMapReduceUtil.getTableFromContext(org.apache.hadoop.mapreduce.TaskInputOutputContext) to get a KuduTable.
KuduTableOutputFormat() - Constructor for class org.apache.kudu.mapreduce.KuduTableOutputFormat
 

L

limit(long) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets a limit on the number of rows that will be returned by the scanner.
ListTablesResponse - Class in org.apache.kudu.client
 
listTabletServers() - Method in class org.apache.kudu.client.AsyncKuduClient
Get the list of running tablet servers.
listTabletServers() - Method in class org.apache.kudu.client.KuduClient
Get the list of running tablet servers.
ListTabletServersResponse - Class in org.apache.kudu.client
 
LocatedTablet - Class in org.apache.kudu.client
Information about the locations of tablets in a Kudu table.
LocatedTablet(RemoteTablet) - Constructor for class org.apache.kudu.client.LocatedTablet
 
LocatedTablet.Replica - Class in org.apache.kudu.client
One of the replicas of the tablet.
LOG - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
LOG - Static variable in class org.apache.kudu.client.AsyncKuduSession
 
lowerBound(PartialRow) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Add a lower bound (inclusive) primary key for the scan.
lowerBoundRaw(byte[]) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder

M

main(String[]) - Static method in class org.apache.kudu.mapreduce.tools.ExportCsv
 
main(String[]) - Static method in class org.apache.kudu.mapreduce.tools.ImportCsv
 
main(String[]) - Static method in class org.apache.kudu.mapreduce.tools.ImportParquet
 
MASTER_ADDRESSES - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Comma-separated list of "host:port" Kudu master addresses.
MASTER_ADDRESSES_DEFAULT - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
MASTER_ADDRESSES_KEY - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
mayContain(byte[]) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(boolean) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(byte) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(short) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(int) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(long) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(float) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(double) - Method in class org.apache.kudu.util.BloomFilter
 
mayContain(String) - Method in class org.apache.kudu.util.BloomFilter
 
MISSING_COLUMN_POLICY_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 

N

needsTaskCommit(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
NetworkError(String) - Static method in class org.apache.kudu.client.Status
 
NetworkError(String, int) - Static method in class org.apache.kudu.client.Status
 
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, boolean) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new KuduPredicate on a boolean column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, long) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on an integer or timestamp column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, BigDecimal) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a Decimal column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, Timestamp) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a timestamp column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, float) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a float column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, double) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a double column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, String) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a string column.
newComparisonPredicate(ColumnSchema, KuduPredicate.ComparisonOp, byte[]) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new comparison predicate on a binary column.
newDelete() - Method in class org.apache.kudu.client.KuduTable
Get a new delete configured with this table's schema.
newInListPredicate(ColumnSchema, List<T>) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new IN list predicate.
newInsert() - Method in class org.apache.kudu.client.KuduTable
Get a new insert configured with this table's schema.
newIsNotNullPredicate(ColumnSchema) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new IS NOT NULL predicate.
newIsNullPredicate(ColumnSchema) - Static method in class org.apache.kudu.client.KuduPredicate
Creates a new IS NULL predicate.
newPartialRow() - Method in class org.apache.kudu.Schema
Creates a new partial row for the schema.
newScannerBuilder(KuduTable) - Method in class org.apache.kudu.client.AsyncKuduClient
Creates a new AsyncKuduScanner.AsyncKuduScannerBuilder for a particular table.
newScannerBuilder(KuduTable) - Method in class org.apache.kudu.client.KuduClient
Creates a new KuduScanner.KuduScannerBuilder for a particular table.
newScanTokenBuilder(KuduTable) - Method in class org.apache.kudu.client.KuduClient
Creates a new KuduScanToken.KuduScanTokenBuilder for a particular table.
newSession() - Method in class org.apache.kudu.client.AsyncKuduClient
Create a new session for interacting with the cluster.
newSession() - Method in class org.apache.kudu.client.KuduClient
Create a new session for interacting with the cluster.
newUpdate() - Method in class org.apache.kudu.client.KuduTable
Get a new update configured with this table's schema.
newUpsert() - Method in class org.apache.kudu.client.KuduTable
Get a new upsert configured with this table's schema.
next() - Method in class org.apache.kudu.client.RowResultIterator
 
nextRows() - Method in class org.apache.kudu.client.AsyncKuduScanner
Scans a number of rows.
nextRows() - Method in class org.apache.kudu.client.KuduScanner
Scans a number of rows.
nioExecutors(Executor, Executor) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Set the executors which will be used for the embedded Netty boss and workers.
nioExecutors(Executor, Executor) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Set the executors which will be used for the embedded Netty boss and workers.
NO_TIMESTAMP - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
NO_TIMESTAMP - Static variable in class org.apache.kudu.client.KuduClient
 
NotAuthorized(String) - Static method in class org.apache.kudu.client.Status
 
NotAuthorized(String, int) - Static method in class org.apache.kudu.client.Status
 
NotFound(String) - Static method in class org.apache.kudu.client.Status
 
NotFound(String, int) - Static method in class org.apache.kudu.client.Status
 
NotSupported(String) - Static method in class org.apache.kudu.client.Status
 
NotSupported(String, int) - Static method in class org.apache.kudu.client.Status
 
nullable(boolean) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Marks the column as allowing null values.
NUM_REPLICAS_DEFAULT - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
NUM_REPLICAS_KEY - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 

O

OK() - Static method in class org.apache.kudu.client.Status
 
ok() - Method in class org.apache.kudu.client.Status
 
openTable(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Open the table with the given name.
openTable(String) - Method in class org.apache.kudu.client.KuduClient
Open the table with the given name.
Operation - Class in org.apache.kudu.client
Base class for the RPCs that related to WriteRequestPB.
OPERATION_DEFAULT - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
OPERATION_PROP - Static variable in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
OPERATION_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
OPERATION_PROP - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
OPERATION_TIMEOUT_MS_DEFAULT - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
OPERATION_TIMEOUT_MS_KEY - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
OperationResponse - Class in org.apache.kudu.client
 
org.apache.kudu - package org.apache.kudu
 
org.apache.kudu.backup - package org.apache.kudu.backup
 
org.apache.kudu.client - package org.apache.kudu.client
 
org.apache.kudu.flume.sink - package org.apache.kudu.flume.sink
 
org.apache.kudu.mapreduce - package org.apache.kudu.mapreduce
 
org.apache.kudu.mapreduce.tools - package org.apache.kudu.mapreduce.tools
 
org.apache.kudu.security - package org.apache.kudu.security
 
org.apache.kudu.tools - package org.apache.kudu.tools
 
org.apache.kudu.util - package org.apache.kudu.util
 

P

parse(byte[], int) - Method in class org.apache.kudu.mapreduce.tools.CsvParser
Creates a ParsedLine of a line of data.
PartialRow - Class in org.apache.kudu.client
Class used to represent parts of a row along with its schema.
PartialRow(Schema) - Constructor for class org.apache.kudu.client.PartialRow
This is not a stable API, prefer using Schema.newPartialRow() to create a new partial row.
partitionKey() - Method in class org.apache.kudu.client.Operation
 
PATTERN_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
PAYLOAD_COLUMN_DEFAULT - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
PAYLOAD_COLUMN_DEFAULT - Static variable in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
PAYLOAD_COLUMN_PROP - Static variable in class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
PAYLOAD_COLUMN_PROP - Static variable in class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
pbVersion() - Method in enum org.apache.kudu.client.AsyncKuduScanner.ReadMode
 
pbVersion() - Method in enum org.apache.kudu.client.ExternalConsistencyMode
 
PleaseThrottleException - Exception in org.apache.kudu.client
This exception notifies the application to throttle its use of Kudu.
precision(int) - Method in class org.apache.kudu.ColumnTypeAttributes.ColumnTypeAttributesBuilder
Set the precision.
prefetching(boolean) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Enables prefetching of rows for the scanner, i.e.
process() - Method in class org.apache.kudu.flume.sink.KuduSink
 
PRODUCER - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
The fully qualified class name of the KuduOperationsProducer class that the sink should use.
PRODUCER_PREFIX - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Prefix for configuration parameters that are passed to the KuduOperationsProducer.
PROXY_USER - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
The effective user if different from the kerberos principal
put(byte[]) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a byte[].
put(boolean) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a boolean.
put(byte) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a byte.
put(short) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a short.
put(int) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a int.
put(long) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a long.
put(float) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a float.
put(double) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a double.
put(String) - Method in class org.apache.kudu.util.BloomFilter
Update bloom filter with a String.

R

RangePartitionBound - Enum in org.apache.kudu.client
Specifies whether a range partition bound is inclusive or exclusive.
readMode(AsyncKuduScanner.ReadMode) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets the read mode, the default is to read the latest values.
RegexpKuduOperationsProducer - Class in org.apache.kudu.flume.sink
A regular expression operations producer that generates one or more Kudu Insert or Upsert operations per Flume Event by parsing the event body using a regular expression.
RegexpKuduOperationsProducer() - Constructor for class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
RemoteError(String) - Static method in class org.apache.kudu.client.Status
 
RemoteError(String, int) - Static method in class org.apache.kudu.client.Status
 
remove() - Method in class org.apache.kudu.client.RowResultIterator
 
removeDefault(String) - Method in class org.apache.kudu.client.AlterTableOptions
Remove the default value for a column.
renameColumn(String, String) - Method in class org.apache.kudu.client.AlterTableOptions
Change the name of a column.
renameTable(String) - Method in class org.apache.kudu.client.AlterTableOptions
Change a table's name.
replicaSelection(ReplicaSelection) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets the replica selection mechanism for this scanner.
ReplicaSelection - Enum in org.apache.kudu.client
Policy with which to choose amongst multiple replicas.
RowError - Class in org.apache.kudu.client
Wrapper class for a single row error.
RowErrorsAndOverflowStatus - Class in org.apache.kudu.client
Container class used as a response when retrieving pending row errors.
RowResult - Class in org.apache.kudu.client
RowResult represents one row from a scanner.
RowResultIterator - Class in org.apache.kudu.client
Class that contains the rows sent by a tablet server, exhausting this iterator only means that all the rows from the last server response were read.
rowToString() - Method in class org.apache.kudu.client.RowResult
Return the actual data from this row in a stringified key=value form.
run(String[]) - Method in class org.apache.kudu.mapreduce.tools.ExportCsv
 
run(String[]) - Method in class org.apache.kudu.mapreduce.tools.ImportCsv
 
run(String[]) - Method in class org.apache.kudu.mapreduce.tools.ImportParquet
 
RuntimeError(String) - Static method in class org.apache.kudu.client.Status
 
RuntimeError(String, int) - Static method in class org.apache.kudu.client.Status
 

S

scale(int) - Method in class org.apache.kudu.ColumnTypeAttributes.ColumnTypeAttributesBuilder
Set the scale.
scanRequestTimeout(long) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets how long each scan request to a server can last.
Schema - Class in org.apache.kudu
Represents table's schema which is essentially a list of columns.
Schema(List<ColumnSchema>) - Constructor for class org.apache.kudu.Schema
Constructs a schema using the specified columns and does some internal accounting
Schema(List<ColumnSchema>, List<Integer>) - Constructor for class org.apache.kudu.Schema
Constructs a schema using the specified columns and IDs.
SCHEMA_LITERAL_HEADER - Static variable in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
SCHEMA_PROP - Static variable in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
SCHEMA_URL_HEADER - Static variable in class org.apache.kudu.flume.sink.AvroKuduOperationsProducer
 
serialize(List<KuduPredicate>) - Static method in class org.apache.kudu.client.KuduPredicate
Serializes a list of KuduPredicate into a byte array.
serialize() - Method in class org.apache.kudu.client.KuduScanToken
Serializes this KuduScanToken into a byte array.
ServiceUnavailable(String) - Static method in class org.apache.kudu.client.Status
 
ServiceUnavailable(String, int) - Static method in class org.apache.kudu.client.Status
 
SessionConfiguration - Interface in org.apache.kudu.client
Interface that defines the methods used to configure a session.
SessionConfiguration.FlushMode - Enum in org.apache.kudu.client
 
setConf(Configuration) - Method in class org.apache.kudu.mapreduce.KuduTableInputFormat
 
setConf(Configuration) - Method in class org.apache.kudu.mapreduce.KuduTableOutputFormat
 
setExternalConsistencyMode(ExternalConsistencyMode) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setExternalConsistencyMode(ExternalConsistencyMode) - Method in class org.apache.kudu.client.KuduSession
 
setExternalConsistencyMode(ExternalConsistencyMode) - Method in interface org.apache.kudu.client.SessionConfiguration
Set the new external consistency mode for this session.
setFaultTolerant(boolean) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Make scans resumable at another tablet server if current server fails if isFaultTolerant is true.
setFlushInterval(int) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setFlushInterval(int) - Method in class org.apache.kudu.client.KuduSession
 
setFlushInterval(int) - Method in interface org.apache.kudu.client.SessionConfiguration
Set the flush interval, which will be used for the next scheduling decision.
setFlushMode(SessionConfiguration.FlushMode) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setFlushMode(SessionConfiguration.FlushMode) - Method in class org.apache.kudu.client.KuduSession
 
setFlushMode(SessionConfiguration.FlushMode) - Method in interface org.apache.kudu.client.SessionConfiguration
Set the new flush mode for this session.
setIgnoreAllDuplicateRows(boolean) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setIgnoreAllDuplicateRows(boolean) - Method in class org.apache.kudu.client.KuduSession
 
setIgnoreAllDuplicateRows(boolean) - Method in interface org.apache.kudu.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.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a boolean for the lower bound
setLowerBound(byte) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a byte for the lower bound
setLowerBound(short) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a short for the lower bound
setLowerBound(int) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set an int for the lower bound
setLowerBound(long) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a long for the lower bound If 'lowerBound' is a timestamp see PartialRow.addLong(String, long) for the format.
setLowerBound(String) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a string for the lower bound
setLowerBound(byte[]) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a binary value for the lower bound
setLowerBound(float) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a float for the lower bound
setLowerBound(double) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a double for the lower bound
setLowerBound(BigDecimal) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a BigDecimal for the lower bound
setMutationBufferLowWatermark(float) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setMutationBufferLowWatermark(float) - Method in class org.apache.kudu.client.KuduSession
 
setMutationBufferLowWatermark(float) - Method in interface org.apache.kudu.client.SessionConfiguration
Set the low watermark for this session.
setMutationBufferSpace(int) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setMutationBufferSpace(int) - Method in class org.apache.kudu.client.KuduSession
 
setMutationBufferSpace(int) - Method in interface org.apache.kudu.client.SessionConfiguration
Set the number of operations that can be buffered.
setNull(int) - Method in class org.apache.kudu.client.PartialRow
Set the specified column to null
setNull(String) - Method in class org.apache.kudu.client.PartialRow
Set the specified column to null
setNumReplicas(int) - Method in class org.apache.kudu.client.CreateTableOptions
Sets the number of replicas that each tablet will have.
setProjectedColumnIndexes(List<Integer>) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Set which columns will be read by the Scanner.
setProjectedColumnNames(List<String>) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Set which columns will be read by the Scanner.
setRangePartitionColumns(List<String>) - Method in class org.apache.kudu.client.CreateTableOptions
Set the columns on which the table will be range-partitioned.
setTimeout(long) - Method in class org.apache.kudu.client.KuduScanToken.KuduScanTokenBuilder
Sets a timeout value to use when building the list of scan tokens.
setTimeoutMillis(long) - Method in class org.apache.kudu.client.AsyncKuduSession
 
setTimeoutMillis(long) - Method in class org.apache.kudu.client.KuduSession
 
setTimeoutMillis(long) - Method in interface org.apache.kudu.client.SessionConfiguration
Sets the timeout for the next applied operations.
setupJob(JobContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
setUpperBound(boolean) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a boolean for the upper bound
setUpperBound(byte) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a byte for the upper bound
setUpperBound(short) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a short for the upper bound
setUpperBound(int) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set an int for the upper bound
setUpperBound(long) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a long for the upper bound If 'upperBound' is a timestamp see PartialRow.addLong(String, long) for the format.
setUpperBound(String) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a string for the upper bound
setUpperBound(byte[]) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a binary value for the upper bound
setUpperBound(float) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a float for the upper bound
setUpperBound(double) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a double for the upper bound
setUpperBound(BigDecimal) - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Set a BigDecimal for the upper bound
setupTask(TaskAttemptContext) - Method in class org.apache.kudu.mapreduce.KuduTableOutputCommitter
 
setWait(boolean) - Method in class org.apache.kudu.client.AlterTableOptions
Whether to wait for the table to be fully altered before this alter operation is considered to be finished.
setWait(boolean) - Method in class org.apache.kudu.client.CreateTableOptions
Whether to wait for the table to be fully created before this create operation is considered to be finished.
shutdown() - Method in class org.apache.kudu.client.AsyncKuduClient
Performs a graceful shutdown of this instance.
shutdown() - Method in class org.apache.kudu.client.KuduClient
Performs a graceful shutdown of this instance.
SimpleKeyedKuduOperationsProducer - Class in org.apache.kudu.flume.sink
A simple serializer that generates one Insert or Upsert per Event by writing the event body into a BINARY column.
SimpleKeyedKuduOperationsProducer() - Constructor for class org.apache.kudu.flume.sink.SimpleKeyedKuduOperationsProducer
 
SimpleKuduOperationsProducer - Class in org.apache.kudu.flume.sink
A simple serializer that generates one Insert per Event by writing the event body into a BINARY column.
SimpleKuduOperationsProducer() - Constructor for class org.apache.kudu.flume.sink.SimpleKuduOperationsProducer
 
SKIP_BAD_COLUMN_VALUE_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
SKIP_MISSING_COLUMN_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
SLEEP_TIME - Static variable in class org.apache.kudu.client.AsyncKuduClient
 
snapshotTimestampMicros(long) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets the timestamp the scan must be executed at, in microseconds since the Unix epoch.
snapshotTimestampRaw(long) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder
Sets a previously encoded HT timestamp as a snapshot timestamp, for tests.
SOCKET_READ_TIMEOUT_MS_DEFAULT - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
SOCKET_READ_TIMEOUT_MS_KEY - Static variable in class org.apache.kudu.mapreduce.CommandLineParser
 
start() - Method in class org.apache.kudu.flume.sink.KuduSink
 
Statistics - Class in org.apache.kudu.client
A Statistics belongs to a specific AsyncKuduClient.
Statistics() - Constructor for class org.apache.kudu.client.Statistics
 
Statistics.Statistic - Enum in org.apache.kudu.client
The statistic enum to pass when querying.
Status - Class in org.apache.kudu.client
Representation of an error code and message.
stop() - Method in class org.apache.kudu.flume.sink.KuduSink
 
stringifyRowKey() - Method in class org.apache.kudu.client.PartialRow
Transforms the row key into a string representation where each column is in the format: "type col_name=value".
stringifySerializedToken(byte[], KuduClient) - Static method in class org.apache.kudu.client.KuduScanToken
Formats the serialized token for debug printing.
syncClient() - Method in class org.apache.kudu.client.AsyncKuduClient
Returns a synchronous KuduClient which wraps this asynchronous client.

T

TABLE_NAME - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
The name of the table in Kudu to write to.
TABLE_NAME_KEY - Static variable in class org.apache.kudu.mapreduce.tools.BigLinkedListCommon
 
tableExists(String) - Method in class org.apache.kudu.client.AsyncKuduClient
Test if a table exists.
tableExists(String) - Method in class org.apache.kudu.client.KuduClient
Test if a table exists.
TableReducer<KeyinT,ValueinT,KeyoutT> - Class in org.apache.kudu.mapreduce
 
TableReducer() - Constructor for class org.apache.kudu.mapreduce.TableReducer
 
TimedOut(String) - Static method in class org.apache.kudu.client.Status
 
TimedOut(String, int) - Static method in class org.apache.kudu.client.Status
 
TIMEOUT_MILLIS - Static variable in class org.apache.kudu.flume.sink.KuduSinkConfigurationConstants
Timeout period for Kudu operations, in milliseconds.
toByteArray(List<ColumnRangePredicate>) - Static method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Converts a list of predicates into an opaque byte array.
toKuduPredicate() - Method in class org.apache.kudu.client.ColumnRangePredicate
Deprecated.
Convert this column range predicate into a KuduPredicate.
toPB() - Method in class org.apache.kudu.client.KuduPredicate
Convert the predicate to the protobuf representation.
toString() - Method in class org.apache.kudu.client.AsyncKuduScanner
 
toString() - Method in class org.apache.kudu.client.KuduPredicate
 
toString() - Method in class org.apache.kudu.client.LocatedTablet.Replica
 
toString() - Method in class org.apache.kudu.client.LocatedTablet
 
toString() - Method in class org.apache.kudu.client.PartialRow
toString() - Method in class org.apache.kudu.client.RowError
 
toString() - Method in class org.apache.kudu.client.RowResult
 
toString() - Method in class org.apache.kudu.client.RowResultIterator
 
toString() - Method in class org.apache.kudu.client.Statistics
 
toString() - Method in class org.apache.kudu.client.Status
Get a human-readable version of the Status message fit for logging or display.
toString() - Method in class org.apache.kudu.ColumnSchema
 
toString() - Method in class org.apache.kudu.ColumnTypeAttributes
 
toString() - Method in enum org.apache.kudu.Type
 
toString() - Method in class org.apache.kudu.util.BloomFilter
 
toStringForType(Type) - Method in class org.apache.kudu.ColumnTypeAttributes
Return a string representation appropriate for `type`.
toStringLongFormat() - Method in class org.apache.kudu.client.RowResult
 
Type - Enum in org.apache.kudu
Describes all the types available to build table schemas.
typeAttributes(ColumnTypeAttributes) - Method in class org.apache.kudu.ColumnSchema.ColumnSchemaBuilder
Set the column type attributes for this column.

U

Uninitialized(String) - Static method in class org.apache.kudu.client.Status
 
Uninitialized(String, int) - Static method in class org.apache.kudu.client.Status
 
UNMATCHED_ROW_POLICY_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
 
Update - Class in org.apache.kudu.client
Operation to update columns on an existing row.
updateLastPropagatedTimestamp(long) - Method in class org.apache.kudu.client.AsyncKuduClient
Updates the last timestamp received from a server.
updateLastPropagatedTimestamp(long) - Method in class org.apache.kudu.client.KuduClient
Updates the last timestamp received from a server.
Upsert - Class in org.apache.kudu.client
Represents a single row upsert.

V

valueOf(String) - Static method in enum org.apache.kudu.client.AsyncKuduScanner.ReadMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.ExternalConsistencyMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.KuduPredicate.ComparisonOp
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.RangePartitionBound
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.ReplicaSelection
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.SessionConfiguration.FlushMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.client.Statistics.Statistic
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.ColumnSchema.CompressionAlgorithm
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.ColumnSchema.Encoding
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kudu.Type
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.kudu.client.AsyncKuduScanner.ReadMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.ExternalConsistencyMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.KuduPredicate.ComparisonOp
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.RangePartitionBound
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.ReplicaSelection
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.SessionConfiguration.FlushMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.client.Statistics.Statistic
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.ColumnSchema.CompressionAlgorithm
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.ColumnSchema.Encoding
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kudu.Type
Returns an array containing the constants of this enum type, in the order they are declared.

W

WARN_UNMATCHED_ROWS_PROP - Static variable in class org.apache.kudu.flume.sink.RegexpKuduOperationsProducer
Deprecated.
workerCount(int) - Method in class org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder
Set the maximum number of worker threads.
workerCount(int) - Method in class org.apache.kudu.client.KuduClient.KuduClientBuilder
Set the maximum number of worker threads.
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links

Copyright © 2018 The Apache Software Foundation. All rights reserved.