You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by zi...@apache.org on 2022/08/09 07:50:51 UTC

[inlong] branch master updated (ff81364de -> a498a3564)

This is an automated email from the ASF dual-hosted git repository.

zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from ff81364de [INLONG-5408][SDK] Fix the NullPointerException when calling the getManagerIpList (#5415)
     add a498a3564 [INLONG-5095][SortSDK] Support consumes data stream from a specified time (#5357)

No new revisions were added by this update.

Summary of changes:
 .../inlong/sdk/sort/api/InLongTopicFetcher.java    |  3 +
 .../apache/inlong/sdk/sort/api/Interceptor.java    | 33 +++++------
 .../sort/impl/interceptor/MsgTimeInterceptor.java  | 61 ++++++++++++++++++++
 .../sort/impl/kafka/InLongKafkaFetcherImpl.java    |  5 ++
 .../sort/impl/pulsar/InLongPulsarFetcherImpl.java  |  6 +-
 .../sdk/sort/impl/tube/InLongTubeFetcherImpl.java  |  4 ++
 .../org/apache/inlong/sdk/sort/util/TimeUtil.java  | 66 ++++++++++++++++++++++
 .../sdk/sort/impl/InLongTopicManagerImplTest.java  |  2 +
 .../sort/impl/decode/MessageDeserializerTest.java  |  1 +
 .../impl/kafka/InLongKafkaFetcherImplTest.java     |  3 +
 .../impl/pulsar/InLongPulsarFetcherImplTest.java   |  2 +
 .../sort/impl/tube/InLongTubeFetcherImplTest.java  |  3 +
 12 files changed, 170 insertions(+), 19 deletions(-)
 copy inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskRequest.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/Interceptor.java (68%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/interceptor/MsgTimeInterceptor.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/util/TimeUtil.java