sijie closed pull request #1788: adding windowing function CLI option
descriptions
URL: https://github.com/apache/incubator-pulsar/pull/1788
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
index dc311bafaa..30103c7360 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -231,13 +231,13 @@ void processArguments() throws Exception {
protected Long ram;
@Parameter(names = "--disk", description = "The disk in bytes that
need to be allocated per function instance(applicable only to docker runtime)")
protected Long disk;
- @Parameter(names = "--windowLengthCount", description = "")
+ @Parameter(names = "--windowLengthCount", description = "The number of
messages per window")
protected Integer windowLengthCount;
- @Parameter(names = "--windowLengthDurationMs", description = "")
+ @Parameter(names = "--windowLengthDurationMs", description = "The time
duration of the window in milliseconds")
protected Long windowLengthDurationMs;
- @Parameter(names = "--slidingIntervalCount", description = "")
+ @Parameter(names = "--slidingIntervalCount", description = "The number
of messages after which the window slides")
protected Integer slidingIntervalCount;
- @Parameter(names = "--slidingIntervalDurationMs", description = "")
+ @Parameter(names = "--slidingIntervalDurationMs", description = "The
time duration after which the window slides")
protected Long slidingIntervalDurationMs;
@Parameter(names = "--autoAck", description = "")
protected Boolean autoAck;
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
