Package | Description |
---|---|
org.apache.kudu.client | |
org.apache.kudu.mapreduce.tools |
Modifier and Type | Method and Description |
---|---|
CreateTableOptions |
CreateTableOptions.addHashPartitions(List<String> columns,
int buckets)
Add a set of hash partitions to the table.
|
CreateTableOptions |
CreateTableOptions.addHashPartitions(List<String> columns,
int buckets,
int seed)
Add a set of hash partitions to the table.
|
CreateTableOptions |
CreateTableOptions.addRangePartition(PartialRow lower,
PartialRow upper)
Add a range partition partition to the table with an inclusive lower bound
and an exclusive upper bound.
|
CreateTableOptions |
CreateTableOptions.addRangePartition(PartialRow lower,
PartialRow upper,
RangePartitionBound lowerBoundType,
RangePartitionBound upperBoundType)
Add a range partition partition to the table with a lower bound and upper
bound.
|
CreateTableOptions |
CreateTableOptions.addSplitRow(PartialRow row)
Add a range partition split.
|
CreateTableOptions |
CreateTableOptions.setNumReplicas(int numReplicas)
Sets the number of replicas that each tablet will have.
|
CreateTableOptions |
CreateTableOptions.setRangePartitionColumns(List<String> columns)
Set the columns on which the table will be range-partitioned.
|
CreateTableOptions |
CreateTableOptions.setWait(boolean wait)
Whether to wait for the table to be fully created before this create
operation is considered to be finished.
|
Modifier and Type | Method and Description |
---|---|
KuduTable |
KuduClient.createTable(String name,
Schema schema,
CreateTableOptions builder)
Create a table on the cluster with the specified name, schema, and table configurations.
|
com.stumbleupon.async.Deferred<KuduTable> |
AsyncKuduClient.createTable(String name,
Schema schema,
CreateTableOptions builder)
Create a table on the cluster with the specified name, schema, and table configurations.
|
Modifier and Type | Method and Description |
---|---|
static CreateTableOptions |
BigLinkedListCommon.getCreateTableOptions(Schema schema,
int numReplicas,
int rangePartitions,
int hashPartitions) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.