-
Notifications
You must be signed in to change notification settings - Fork 161
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
majun87
committed
Dec 15, 2020
1 parent
e08d567
commit 778a84d
Showing
5 changed files
with
392 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
122 changes: 122 additions & 0 deletions
122
...eue-archive-api/src/main/java/org/joyqueue/server/archive/store/query/QueryCondition.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,122 @@ | ||
| /** | ||
| * Copyright 2019 The JoyQueue Authors. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
| package org.joyqueue.server.archive.store.query; | ||
|
|
||
| import org.joyqueue.server.archive.store.model.Query; | ||
| import org.joyqueue.server.archive.store.utils.ArchiveSerializer; | ||
|
|
||
| /** | ||
| * Created by chengzhiliang on 2018/12/4. | ||
| */ | ||
| public class QueryCondition implements Query { | ||
|
|
||
| @Override | ||
| public <T> T getQueryCondition() { | ||
| return (T)this; | ||
| } | ||
|
|
||
| private RowKey startRowKey; // 查询开始键 | ||
| private RowKey stopRowKey; // 查询结束键 | ||
| private int count; | ||
|
|
||
| private RowKey rowKey; // 指定RowKey查询 | ||
|
|
||
| private byte[] startRowKeyByteArr; | ||
|
|
||
| public int getCount() { | ||
| return count; | ||
| } | ||
|
|
||
| public void setCount(int count) { | ||
| this.count = count; | ||
| } | ||
|
|
||
| public RowKey getStartRowKey() { | ||
| return startRowKey; | ||
| } | ||
|
|
||
| public void setStartRowKey(RowKey startRowKey) { | ||
| this.startRowKey = startRowKey; | ||
| } | ||
|
|
||
| public RowKey getStopRowKey() { | ||
| return stopRowKey; | ||
| } | ||
|
|
||
| public void setStopRowKey(RowKey stopRowKey) { | ||
| this.stopRowKey = stopRowKey; | ||
| } | ||
|
|
||
| public RowKey getRowKey() { | ||
| return rowKey; | ||
| } | ||
|
|
||
| public void setRowKey(RowKey rowKey) { | ||
| this.rowKey = rowKey; | ||
| } | ||
|
|
||
| public byte[] getStartRowKeyByteArr() { | ||
| return startRowKeyByteArr; | ||
| } | ||
|
|
||
| public void setStartRowKeyByteArr(String startRowKeyByteArr) { | ||
| byte[] bytes = ArchiveSerializer.hexStrToByteArray(startRowKeyByteArr); | ||
| this.startRowKeyByteArr = bytes; | ||
| } | ||
|
|
||
| /** | ||
| * 查询RowKey | ||
| */ | ||
| public static class RowKey { | ||
| private String topic; | ||
| private long time; | ||
| private String businessId; | ||
| private String messageId; | ||
|
|
||
| public String getTopic() { | ||
| return topic; | ||
| } | ||
|
|
||
| public void setTopic(String topic) { | ||
| this.topic = topic; | ||
| } | ||
|
|
||
| public long getTime() { | ||
| return time; | ||
| } | ||
|
|
||
| public void setTime(long time) { | ||
| this.time = time; | ||
| } | ||
|
|
||
| public String getBusinessId() { | ||
| return businessId; | ||
| } | ||
|
|
||
| public void setBusinessId(String businessId) { | ||
| this.businessId = businessId; | ||
| } | ||
|
|
||
| public String getMessageId() { | ||
| return messageId; | ||
| } | ||
|
|
||
| public void setMessageId(String messageId) { | ||
| this.messageId = messageId; | ||
| } | ||
|
|
||
| } | ||
| } |
Oops, something went wrong.