New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Adding test data sources designed for benchmarking purposes #2382
Conversation
…r high-throughput testing purposes
Can one of the admins verify this patch? |
1 similar comment
Can one of the admins verify this patch? |
Thanks @guenter-hesse for the PR! I'm on holiday and will have a look at this when I'm back. |
@guenter-hesse @mtopolnik has improved the benchmark sources since this PR was opened, I think we should replace these with that. What do you think? |
@cangencer thank you for the information. I just had a conversation with @mtopolnik on Slack in which we briefly discussed this improved concept. I will update the PR within the next few days correspondingly. |
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/StreamSourceLong.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/test/java/com/hazelcast/jet/pipeline/test/TestSourcesTest.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/StreamSourceLong.java
Outdated
Show resolved
Hide resolved
…med method to stay consistent
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
Can one of the admins verify this patch? |
3 similar comments
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@guenter-hesse looks good to me now, some very minor comments! Can merge after those are fixed once @mtopolnik reviews as well. Thanks for your contribution.
hazelcast-jet-core/src/test/java/com/hazelcast/jet/pipeline/test/TestSourcesTest.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java
Outdated
Show resolved
Hide resolved
hazelcast-jet-core/src/test/java/com/hazelcast/jet/pipeline/test/TestSourcesTest.java
Outdated
Show resolved
Hide resolved
verify |
Allow it to accept nanoTime() from the caller
…ired unit conversions
verify |
The job Click to expand the log file-------------------------- ---------SUMMARY---------- -------------------------- [ERROR] Failed to execute goal org.apache.maven.plugins:maven-checkstyle-plugin:3.1.0:checkstyle (default) on project hazelcast-jet-core: An error has occurred in Checkstyle report generation. Failed during checkstyle execution: There is 1 error reported by Checkstyle 8.29 with /home/jenkins/jenkins_slave/workspace/jet-oss-pr-builder/checkstyle/checkstyle.xml ruleset. -> [Help 1] -------------------------- ---------ERRORS----------- -------------------------- [ERROR] /home/jenkins/jenkins_slave/workspace/jet-oss-pr-builder/hazelcast-jet-core/src/main/java/com/hazelcast/jet/pipeline/test/LongStreamSourceP.java:25:8: Unused import - com.hazelcast.logging.Logger. [UnusedImports] -------------------------- |
verify |
verify |
verify |
Can one of the admins verify this patch? |
5 similar comments
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
Can one of the admins verify this patch? |
Adding this streaming source:
It is a high-throughput source with precisely controlled timing, to be used for benchmarking Jet's throughput and latency.
Fixes #2244
Checklist
@Nonnull/@Nullable
annotations@since
tags in Javadoc