xin.bluesky.leiothrix.server.storage

类 RangeStorage

java.lang.Object

xin.bluesky.leiothrix.server.storage.RangeStorage

public class RangeStorage
extends Object

作者:

张轲

字段概要

字段

限定符和类型	字段和说明
static String	NAME_RANGE_END_INDEX
static String	NAME_RANGE_RECORD_NUM
static String	NAME_RANGE_START_INDEX
static String	NAME_RANGES
static String	NAME_STAT
static String	NAME_STAT_EXCEPTION_STACK_TRACE
static String	NAME_STAT_FAIL_PAGE
static String	NAME_STAT_HANDLE_USING_TIME
static String	NAME_STAT_QUERY_USING_TIME
static String	NAME_STAT_RECORD_NUM
static String	NAME_STAT_RECORD_NUM_FAIL
static String	NAME_STAT_RECORD_NUM_SUCCESS
static String	NAME_STAT_TOTAL_TIME
static String	NAME_STATUS
static String	NAME_TIMEOUT_FLAG 判断range是否处理超时的标志字段

构造器概要

构造器

构造器和说明
RangeStorage()

方法概要

限定符和类型	方法和说明
static void	createRange(String taskId, String tableName, String rangeName)
static void	createRange(String taskId, String tableName, String rangeName, int recordNum)
static List<String>	getAllRangesByTableName(String taskId, String tableName)
static ExecutionStatistics	getExecutionStatistics(String taskId, String tableName, String rangeName)
static PartitionTask	getPartitionTask(String taskId, String tableName, String rangeName)
static long	getRangeLastUpdateTime(String taskId, String tableName, String rangeName)
static RangeStatus	getRangeStatus(String taskId, String tableName, String rangeName)
static void	refreshRangeLastUpdateTime(String taskId, String tableName, String rangeName)
static void	setNameRangeStartIndex(String taskId, String tableName, String rangeName, long startIndex)
static void	setRangeRecordNum(String taskId, String tableName, String rangeName, int recordNum)
static void	setRangeStatus(String taskId, String tableName, String rangeName, RangeStatus status)
static void	updatePageExecutionStatistics(String taskId, String tableName, String rangeName, ExecutionStatistics stat)

从类继承的方法 java.lang.Object

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

字段详细资料

NAME_RANGE_START_INDEX

public static final String NAME_RANGE_START_INDEX

另请参阅:

常量字段值

NAME_RANGE_END_INDEX

public static final String NAME_RANGE_END_INDEX

另请参阅:

常量字段值

NAME_STATUS

public static final String NAME_STATUS

另请参阅:

常量字段值

NAME_RANGES

public static final String NAME_RANGES

另请参阅:

常量字段值

NAME_TIMEOUT_FLAG

public static final String NAME_TIMEOUT_FLAG

判断range是否处理超时的标志字段

另请参阅:

常量字段值

NAME_RANGE_RECORD_NUM

public static final String NAME_RANGE_RECORD_NUM

另请参阅:

常量字段值

NAME_STAT

public static final String NAME_STAT

另请参阅:

常量字段值

NAME_STAT_RECORD_NUM

public static final String NAME_STAT_RECORD_NUM

另请参阅:

常量字段值

NAME_STAT_RECORD_NUM_SUCCESS

public static final String NAME_STAT_RECORD_NUM_SUCCESS

另请参阅:

常量字段值

NAME_STAT_RECORD_NUM_FAIL

public static final String NAME_STAT_RECORD_NUM_FAIL

另请参阅:

常量字段值

NAME_STAT_FAIL_PAGE

public static final String NAME_STAT_FAIL_PAGE

另请参阅:

常量字段值

NAME_STAT_EXCEPTION_STACK_TRACE

public static final String NAME_STAT_EXCEPTION_STACK_TRACE

另请参阅:

常量字段值

NAME_STAT_QUERY_USING_TIME

public static final String NAME_STAT_QUERY_USING_TIME

另请参阅:

常量字段值

NAME_STAT_HANDLE_USING_TIME

public static final String NAME_STAT_HANDLE_USING_TIME

另请参阅:

常量字段值

NAME_STAT_TOTAL_TIME

public static final String NAME_STAT_TOTAL_TIME

另请参阅:

常量字段值

构造器详细资料

RangeStorage

public RangeStorage()

方法详细资料

createRange

public static void createRange(String taskId,
                               String tableName,
                               String rangeName)

createRange

public static void createRange(String taskId,
                               String tableName,
                               String rangeName,
                               int recordNum)

getPartitionTask

public static PartitionTask getPartitionTask(String taskId,
                                             String tableName,
                                             String rangeName)

setRangeStatus

public static void setRangeStatus(String taskId,
                                  String tableName,
                                  String rangeName,
                                  RangeStatus status)

getAllRangesByTableName

public static List<String> getAllRangesByTableName(String taskId,
                                                   String tableName)

getRangeStatus

public static RangeStatus getRangeStatus(String taskId,
                                         String tableName,
                                         String rangeName)

getRangeLastUpdateTime

public static long getRangeLastUpdateTime(String taskId,
                                          String tableName,
                                          String rangeName)

refreshRangeLastUpdateTime

public static void refreshRangeLastUpdateTime(String taskId,
                                              String tableName,
                                              String rangeName)

setNameRangeStartIndex

public static void setNameRangeStartIndex(String taskId,
                                          String tableName,
                                          String rangeName,
                                          long startIndex)

setRangeRecordNum

public static void setRangeRecordNum(String taskId,
                                     String tableName,
                                     String rangeName,
                                     int recordNum)

updatePageExecutionStatistics

public static void updatePageExecutionStatistics(String taskId,
                                                 String tableName,
                                                 String rangeName,
                                                 ExecutionStatistics stat)

getExecutionStatistics

public static ExecutionStatistics getExecutionStatistics(String taskId,
                                                         String tableName,
                                                         String rangeName)