org.apache.kudu.spark.tools

Class BigLinkedListCommon

java.lang.Object

org.apache.kudu.spark.tools.BigLinkedListCommon

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class BigLinkedListCommon
extends Object

Static constants, helper methods, and utility classes for BigLinkedList implementations. Any definitions which must be kept in-sync between ITBLL implementations should be kept here.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COLUMN_CLIENT identifier of the mapred task that generated this row.
static int	COLUMN_CLIENT_IDX
static String	COLUMN_KEY_ONE Row key, two times 8 bytes.
static int	COLUMN_KEY_ONE_IDX
static String	COLUMN_KEY_TWO
static int	COLUMN_KEY_TWO_IDX
static String	COLUMN_PREV_ONE Link to the id of the prev node in the linked list, two times 8 bytes.
static int	COLUMN_PREV_ONE_IDX
static String	COLUMN_PREV_TWO
static int	COLUMN_PREV_TWO_IDX
static String	COLUMN_ROW_ID the id of the row within the same client.
static int	COLUMN_ROW_ID_IDX
static String	COLUMN_UPDATE_COUNT The number of times this row was updated.
static int	COLUMN_UPDATE_COUNT_IDX
static String	DEFAULT_HEADS_TABLE_NAME
static String	DEFAULT_TABLE_NAME
static String	HEADS_TABLE_NAME_KEY
static String	TABLE_NAME_KEY

Method Summary

Modifier and Type	Method and Description
static CreateTableOptions	getCreateTableOptions(Schema schema, int numReplicas, int rangePartitions, int hashPartitions)
static Schema	getHeadsTableSchema()
static Schema	getTableSchema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TABLE_NAME_KEY

public static final String TABLE_NAME_KEY

See Also:

Constant Field Values

DEFAULT_TABLE_NAME

public static final String DEFAULT_TABLE_NAME

See Also:

Constant Field Values

HEADS_TABLE_NAME_KEY

public static final String HEADS_TABLE_NAME_KEY

See Also:

Constant Field Values

DEFAULT_HEADS_TABLE_NAME

public static final String DEFAULT_HEADS_TABLE_NAME

See Also:

Constant Field Values

COLUMN_KEY_ONE

public static final String COLUMN_KEY_ONE

Row key, two times 8 bytes.

See Also:

Constant Field Values

COLUMN_KEY_ONE_IDX

public static final int COLUMN_KEY_ONE_IDX

See Also:

Constant Field Values

COLUMN_KEY_TWO

public static final String COLUMN_KEY_TWO

See Also:

Constant Field Values

COLUMN_KEY_TWO_IDX

public static final int COLUMN_KEY_TWO_IDX

See Also:

Constant Field Values

COLUMN_PREV_ONE

public static final String COLUMN_PREV_ONE

Link to the id of the prev node in the linked list, two times 8 bytes.

See Also:

Constant Field Values

COLUMN_PREV_ONE_IDX

public static final int COLUMN_PREV_ONE_IDX

See Also:

Constant Field Values

COLUMN_PREV_TWO

public static final String COLUMN_PREV_TWO

See Also:

Constant Field Values

COLUMN_PREV_TWO_IDX

public static final int COLUMN_PREV_TWO_IDX

See Also:

Constant Field Values

COLUMN_ROW_ID

public static final String COLUMN_ROW_ID

the id of the row within the same client.

See Also:

Constant Field Values

COLUMN_ROW_ID_IDX

public static final int COLUMN_ROW_ID_IDX

See Also:

Constant Field Values

COLUMN_CLIENT

public static final String COLUMN_CLIENT

identifier of the mapred task that generated this row.

See Also:

Constant Field Values

COLUMN_CLIENT_IDX

public static final int COLUMN_CLIENT_IDX

See Also:

Constant Field Values

COLUMN_UPDATE_COUNT

public static final String COLUMN_UPDATE_COUNT

The number of times this row was updated.

See Also:

Constant Field Values

COLUMN_UPDATE_COUNT_IDX

public static final int COLUMN_UPDATE_COUNT_IDX

See Also:

Constant Field Values

Method Detail

getTableSchema

public static Schema getTableSchema()

getHeadsTableSchema

public static Schema getHeadsTableSchema()

getCreateTableOptions

public static CreateTableOptions getCreateTableOptions(Schema schema,
                                                       int numReplicas,
                                                       int rangePartitions,
                                                       int hashPartitions)