TableAPI New Query

This commit is contained in:
dz0
2022-01-14 10:38:50 +08:00
committed by LINxiansheng
parent c6185fe3ea
commit 01724ead75
21 changed files with 967 additions and 105 deletions

View File

@ -214,6 +214,12 @@ void ObTableEntityFactory<T>::free_all()
}
}
enum class ObQueryOperationType : int {
QUERY_START = 0,
QUERY_NEXT = 1,
QUERY_MAX
};
/// Table Operation Type
struct ObTableOperationType
{
@ -389,7 +395,6 @@ class ObNoRetry : public ObIRetryPolicy
{};
/// consistency levels
/// @see https://www.atatech.org/articles/102030
enum class ObTableConsistencyLevel
{
STRONG = 0,
@ -571,7 +576,6 @@ public:
int set_row_offset_per_column_family(int32_t offset);
/// Apply the specified server-side filter when performing the Query.
/// @param filter - a file string using the hbase filter language
/// @see the filter language at https://issues.apache.org/jira/browse/HBASE-4176
int set_filter(const ObString &filter);
const ObIArray<ObString> &get_columns() const { return select_column_qualifier_; }
@ -795,6 +799,20 @@ public:
ObTableQueryResult affected_entity_;
};
class ObTableQuerySyncResult: public ObTableQueryResult
{
OB_UNIS_VERSION(1);
public:
ObTableQuerySyncResult()
: is_end_(false),
query_session_id_(0)
{}
virtual ~ObTableQuerySyncResult() {}
public:
bool is_end_;
uint64_t query_session_id_; // from server gen
};
} // end namespace table
} // end namespace oceanbase