pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r..@apache.org
Subject [pulsar] branch master updated: Fix pulsar admin functions description information (#4846)
Date Tue, 06 Aug 2019 13:45:37 GMT
This is an automated email from the ASF dual-hosted git repository.

rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 19e129d  Fix pulsar admin functions description information (#4846)
19e129d is described below

commit 19e129d0c8dfd37569d6ccf844abeb33f6a49a97
Author: 冉小龙 <rxl@apache.org>
AuthorDate: Tue Aug 6 21:45:30 2019 +0800

    Fix pulsar admin functions description information (#4846)
    
    * Fix pulsar admin functions description information
    
    Signed-off-by: xiaolong.ran <ranxiaolong716@gmail.com>
    
    * fix comments
    
    Signed-off-by: xiaolong.ran <ranxiaolong716@gmail.com>
---
 .../org/apache/pulsar/admin/cli/CmdFunctions.java  | 84 +++++++++++-----------
 1 file changed, 42 insertions(+), 42 deletions(-)

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 93471b2..0a0fa05 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
@@ -107,10 +107,10 @@ public class CmdFunctions extends CmdBase {
      */
     @Getter
     abstract class NamespaceCommand extends BaseCommand {
-        @Parameter(names = "--tenant", description = "The function's tenant")
+        @Parameter(names = "--tenant", description = "The tenant of a Pulsar Function")
         protected String tenant;
 
-        @Parameter(names = "--namespace", description = "The function's namespace")
+        @Parameter(names = "--namespace", description = "The namespace of a Pulsar Function")
         protected String namespace;
 
         @Override
@@ -132,13 +132,13 @@ public class CmdFunctions extends CmdBase {
         @Parameter(names = "--fqfn", description = "The Fully Qualified Function Name (FQFN)
for the function")
         protected String fqfn;
 
-        @Parameter(names = "--tenant", description = "The function's tenant")
+        @Parameter(names = "--tenant", description = "The tenant of a Pulsar Function")
         protected String tenant;
 
-        @Parameter(names = "--namespace", description = "The function's namespace")
+        @Parameter(names = "--namespace", description = "The namespace of a Pulsar Function")
         protected String namespace;
 
-        @Parameter(names = "--name", description = "The function's name")
+        @Parameter(names = "--name", description = "The name of a Pulsar Function")
         protected String functionName;
 
         @Override
@@ -184,18 +184,18 @@ public class CmdFunctions extends CmdBase {
     abstract class FunctionDetailsCommand extends BaseCommand {
         @Parameter(names = "--fqfn", description = "The Fully Qualified Function Name (FQFN)
for the function")
         protected String fqfn;
-        @Parameter(names = "--tenant", description = "The function's tenant")
+        @Parameter(names = "--tenant", description = "The tenant of a Pulsar Function")
         protected String tenant;
-        @Parameter(names = "--namespace", description = "The function's namespace")
+        @Parameter(names = "--namespace", description = "The namespace of a Pulsar Function")
         protected String namespace;
-        @Parameter(names = "--name", description = "The function's name")
+        @Parameter(names = "--name", description = "The name of a Pulsar Function")
         protected String functionName;
         // for backwards compatibility purposes
-        @Parameter(names = "--className", description = "The function's class name", hidden
= true)
+        @Parameter(names = "--className", description = "The class name of a Pulsar Function",
hidden = true)
         protected String DEPRECATED_className;
-        @Parameter(names = "--classname", description = "The function's class name")
+        @Parameter(names = "--classname", description = "The class name of a Pulsar Function")
         protected String className;
-        @Parameter(names = "--jar", description = "Path to the jar file for the function
(if the function is written in Java). It also supports url-path [http/https/file (file protocol
assumes that file already exists on worker host)] from which worker can download the package.",
listConverter = StringConverter.class)
+        @Parameter(names = "--jar", description = "Path to the JAR file for the function
(if the function is written in Java). It also supports URL path [http/https/file (file protocol
assumes that file already exists on worker host)] from which worker can download the package.",
listConverter = StringConverter.class)
         protected String jarFile;
         @Parameter(
                 names = "--py",
@@ -207,7 +207,7 @@ public class CmdFunctions extends CmdBase {
                 description = "Path to the main Go executable binary for the function (if
the function is written in Go)")
         protected String goFile;
         @Parameter(names = {"-i",
-                "--inputs"}, description = "The function's input topic or topics (multiple
topics can be specified as a comma-separated list)")
+                "--inputs"}, description = "The input topic or topics (multiple topics can
be specified as a comma-separated list) of a Pulsar Function")
         protected String inputs;
         // for backwards compatibility purposes
         @Parameter(names = "--topicsPattern", description = "TopicsPattern to consume from
list of topics under a namespace that match the pattern. [--input] and [--topic-pattern] are
mutually exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (supported
for java fun only)", hidden = true)
@@ -215,12 +215,12 @@ public class CmdFunctions extends CmdBase {
         @Parameter(names = "--topics-pattern", description = "The topic pattern to consume
from list of topics under a namespace that match the pattern. [--input] and [--topic-pattern]
are mutually exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (supported
for java fun only)")
         protected String topicsPattern;
 
-        @Parameter(names = {"-o", "--output"}, description = "The function's output topic
(If none is specified, no output is written)")
+        @Parameter(names = {"-o", "--output"}, description = "The output topic of a Pulsar
Function (If none is specified, no output is written)")
         protected String output;
         // for backwards compatibility purposes
-        @Parameter(names = "--logTopic", description = "The topic to which the function's
logs are produced", hidden = true)
+        @Parameter(names = "--logTopic", description = "The topic to which the logs of a
Pulsar Function are produced", hidden = true)
         protected String DEPRECATED_logTopic;
-        @Parameter(names = "--log-topic", description = "The topic to which the function's
logs are produced")
+        @Parameter(names = "--log-topic", description = "The topic to which the logs of a
Pulsar Function are produced")
         protected String logTopic;
 
         @Parameter(names = {"-st", "--schema-type"}, description = "The builtin schema type
or custom schema class name to be used for messages output by the function")
@@ -239,9 +239,9 @@ public class CmdFunctions extends CmdBase {
         @Parameter(names = "--output-serde-classname", description = "The SerDe class to
be used for messages output by the function")
         protected String outputSerdeClassName;
         // for backwards compatibility purposes
-        @Parameter(names = "--functionConfigFile", description = "The path to a YAML config
file specifying the function's configuration", hidden = true)
+        @Parameter(names = "--functionConfigFile", description = "The path to a YAML config
file that specifies the configuration of a Pulsar Function", hidden = true)
         protected String DEPRECATED_fnConfigFile;
-        @Parameter(names = "--function-config-file", description = "The path to a YAML config
file specifying the function's configuration")
+        @Parameter(names = "--function-config-file", description = "The path to a YAML config
file that specifies the configuration of a Pulsar Function")
         protected String fnConfigFile;
         // for backwards compatibility purposes
         @Parameter(names = "--processingGuarantees", description = "The processing guarantees
(aka delivery semantics) applied to the function", hidden = true)
@@ -259,7 +259,7 @@ public class CmdFunctions extends CmdBase {
         protected Boolean retainOrdering;
         @Parameter(names = "--subs-name", description = "Pulsar source subscription name
if user wants a specific subscription-name for input-topic consumer")
         protected String subsName;
-        @Parameter(names = "--parallelism", description = "The function's parallelism factor
(i.e. the number of function instances to run)")
+        @Parameter(names = "--parallelism", description = "The parallelism factor of a Pulsar
Function (i.e. the number of function instances to run)")
         protected Integer parallelism;
         @Parameter(names = "--cpu", description = "The cpu in cores that need to be allocated
per function instance(applicable only to docker runtime)")
         protected Double cpu;
@@ -288,9 +288,9 @@ public class CmdFunctions extends CmdBase {
         @Parameter(names = "--sliding-interval-duration-ms", description = "The time duration
after which the window slides")
         protected Long slidingIntervalDurationMs;
         // for backwards compatibility purposes
-        @Parameter(names = "--autoAck", description = "Whether or not the framework will
automatically acknowledge messages", hidden = true)
+        @Parameter(names = "--autoAck", description = "Whether or not the framework acknowledges
messages automatically", hidden = true)
         protected Boolean DEPRECATED_autoAck = null;
-        @Parameter(names = "--auto-ack", description = "Whether or not the framework will
automatically acknowledge messages", arity = 1)
+        @Parameter(names = "--auto-ack", description = "Whether or not the framework acknowledges
messages automatically", arity = 1)
         protected Boolean autoAck;
         // for backwards compatibility purposes
         @Parameter(names = "--timeoutMs", description = "The message timeout in milliseconds",
hidden = true)
@@ -299,7 +299,7 @@ public class CmdFunctions extends CmdBase {
         protected Long timeoutMs;
         @Parameter(names = "--max-message-retries", description = "How many times should
we try to process a message before giving up")
         protected Integer maxMessageRetries;
-        @Parameter(names = "--dead-letter-topic", description = "The topic where all messages
which could not be processed successfully are sent")
+        @Parameter(names = "--dead-letter-topic", description = "The topic where messages
that are not processed successfully are sent to")
         protected String deadLetterTopic;
         protected FunctionConfig functionConfig;
         protected String userCodeFile;
@@ -543,19 +543,19 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "Run the Pulsar Function locally (rather than deploying
it to the Pulsar cluster)")
+    @Parameters(commandDescription = "Run a Pulsar Function locally, rather than deploy to
a Pulsar cluster)")
     class LocalRunner extends FunctionDetailsCommand {
 
-        // TODO: this should become bookkeeper url and it should be fetched from pulsar client.
+        // TODO: this should become BookKeeper URL and it should be fetched from Pulsar client.
         // for backwards compatibility purposes
-        @Parameter(names = "--stateStorageServiceUrl", description = "The URL for the state
storage service (by default Apache BookKeeper)", hidden = true)
+        @Parameter(names = "--stateStorageServiceUrl", description = "The URL for the state
storage service (the default is Apache BookKeeper)", hidden = true)
         protected String DEPRECATED_stateStorageServiceUrl;
-        @Parameter(names = "--state-storage-service-url", description = "The URL for the
state storage service (by default Apache BookKeeper)")
+        @Parameter(names = "--state-storage-service-url", description = "The URL for the
state storage service (the default is Apache BookKeeper)")
         protected String stateStorageServiceUrl;
         // for backwards compatibility purposes
-        @Parameter(names = "--brokerServiceUrl", description = "The URL for the Pulsar broker",
hidden = true)
+        @Parameter(names = "--brokerServiceUrl", description = "The URL for Pulsar broker",
hidden = true)
         protected String DEPRECATED_brokerServiceUrl;
-        @Parameter(names = "--broker-service-url", description = "The URL for the Pulsar
broker")
+        @Parameter(names = "--broker-service-url", description = "The URL for Pulsar broker")
         protected String brokerServiceUrl;
         // for backwards compatibility purposes
         @Parameter(names = "--clientAuthPlugin", description = "Client authentication plugin
using which function-process can connect to broker", hidden = true)
@@ -628,7 +628,7 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "Create a Pulsar Function in cluster mode (i.e. deploy
it on a Pulsar cluster)")
+    @Parameters(commandDescription = "Create a Pulsar Function in cluster mode (deploy it
on a Pulsar cluster)")
     class CreateFunction extends FunctionDetailsCommand {
         @Override
         void runCmd() throws Exception {
@@ -655,7 +655,7 @@ public class CmdFunctions extends CmdBase {
     @Parameters(commandDescription = "Check the current status of a Pulsar Function")
     class GetFunctionStatus extends FunctionCommand {
 
-        @Parameter(names = "--instance-id", description = "The function instanceId (Get-status
of all instances if instance-id is not provided")
+        @Parameter(names = "--instance-id", description = "The function instanceId (Get-status
of all instances if instance-id is not provided)")
         protected String instanceId;
 
         @Override
@@ -671,7 +671,7 @@ public class CmdFunctions extends CmdBase {
     @Parameters(commandDescription = "Get the current stats of a Pulsar Function")
     class GetFunctionStats extends FunctionCommand {
 
-        @Parameter(names = "--instance-id", description = "The function instanceId (Get-stats
of all instances if instance-id is not provided")
+        @Parameter(names = "--instance-id", description = "The function instanceId (Get-stats
of all instances if instance-id is not provided)")
         protected String instanceId;
 
         @Override
@@ -688,7 +688,7 @@ public class CmdFunctions extends CmdBase {
     @Parameters(commandDescription = "Restart function instance")
     class RestartFunction extends FunctionCommand {
 
-        @Parameter(names = "--instance-id", description = "The function instanceId (restart
all instances if instance-id is not provided")
+        @Parameter(names = "--instance-id", description = "The function instanceId (restart
all instances if instance-id is not provided)")
         protected String instanceId;
 
         @Override
@@ -709,7 +709,7 @@ public class CmdFunctions extends CmdBase {
     @Parameters(commandDescription = "Stops function instance")
     class StopFunction extends FunctionCommand {
 
-        @Parameter(names = "--instance-id", description = "The function instanceId (stop
all instances if instance-id is not provided")
+        @Parameter(names = "--instance-id", description = "The function instanceId (stop
all instances if instance-id is not provided)")
         protected String instanceId;
 
         @Override
@@ -730,7 +730,7 @@ public class CmdFunctions extends CmdBase {
     @Parameters(commandDescription = "Starts a stopped function instance")
     class StartFunction extends FunctionCommand {
 
-        @Parameter(names = "--instance-id", description = "The function instanceId (start
all instances if instance-id is not provided")
+        @Parameter(names = "--instance-id", description = "The function instanceId (start
all instances if instance-id is not provided)")
         protected String instanceId;
 
         @Override
@@ -748,7 +748,7 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "Delete a Pulsar Function that's running on a Pulsar
cluster")
+    @Parameters(commandDescription = "Delete a Pulsar Function that is running on a Pulsar
cluster")
     class DeleteFunction extends FunctionCommand {
         @Override
         void runCmd() throws Exception {
@@ -757,7 +757,7 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "Update a Pulsar Function that's been deployed to a
Pulsar cluster")
+    @Parameters(commandDescription = "Update a Pulsar Function that has been deployed to
a Pulsar cluster")
     class UpdateFunction extends FunctionDetailsCommand {
 
         @Parameter(names = "--update-auth-data", description = "Whether or not to update
the auth data")
@@ -794,7 +794,7 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "List all of the Pulsar Functions running under a specific
tenant and namespace")
+    @Parameters(commandDescription = "List all Pulsar Functions running under a specific
tenant and namespace")
     class ListFunctions extends NamespaceCommand {
         @Override
         void runCmd() throws Exception {
@@ -849,7 +849,7 @@ public class CmdFunctions extends CmdBase {
         }
     }
 
-    @Parameters(commandDescription = "Triggers the specified Pulsar Function with a supplied
value")
+    @Parameters(commandDescription = "Trigger the specified Pulsar Function with a supplied
value")
     class TriggerFunction extends FunctionCommand {
         // for backward compatibility purposes
         @Parameter(names = "--triggerValue", description = "The value with which you want
to trigger the function", hidden = true)
@@ -857,9 +857,9 @@ public class CmdFunctions extends CmdBase {
         @Parameter(names = "--trigger-value", description = "The value with which you want
to trigger the function")
         protected String triggerValue;
         // for backward compatibility purposes
-        @Parameter(names = "--triggerFile", description = "The path to the file that contains
the data with which you'd like to trigger the function", hidden = true)
+        @Parameter(names = "--triggerFile", description = "The path to the file that contains
the data with which you want to trigger the function", hidden = true)
         protected String DEPRECATED_triggerFile;
-        @Parameter(names = "--trigger-file", description = "The path to the file that contains
the data with which you'd like to trigger the function")
+        @Parameter(names = "--trigger-file", description = "The path to the file that contains
the data with which you want to trigger the function")
         protected String triggerFile;
         @Parameter(names = "--topic", description = "The specific topic name that the function
consumes from that you want to inject the data to")
         protected String topic;
@@ -921,17 +921,17 @@ public class CmdFunctions extends CmdBase {
         // for backward compatibility purposes
         @Parameter(
                 names = "--destinationFile",
-                description = "The file where downloaded contents need to be stored",
+                description = "The file to store downloaded content",
                 listConverter = StringConverter.class, hidden = true)
         protected String DEPRECATED_destinationFile;
         @Parameter(
                 names = "--destination-file",
-                description = "The file where downloaded contents need to be stored",
+                description = "The file to store downloaded content",
                 listConverter = StringConverter.class)
         protected String destinationFile;
         @Parameter(
                 names = "--path",
-                description = "Path where the contents are to be stored",
+                description = "Path to store the content",
                 listConverter = StringConverter.class, required = false, hidden = true)
         protected String path;
 


Mime
View raw message