Index (Kudu 1.8.0 API)

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: Deprecated.
use AbstractKuduScannerBuilder.addPredicate(KuduPredicate)
addColumnRangePredicatesRaw(byte[]) - Method in class org.apache.kudu.client.AbstractKuduScannerBuilder: Deprecated.
use AbstractKuduScannerBuilder.addPredicate(org.apache.kudu.client.KuduPredicate)
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: Deprecated.
use AbstractKuduScannerBuilder.exclusiveUpperBound(PartialRow)
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: Deprecated.
use Type.getDataType(ColumnTypeAttributes)
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: Deprecated.
use Type.getSize(ColumnTypeAttributes)
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: Deprecated.
use AbstractKuduScannerBuilder.lowerBound(PartialRow)

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