This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new 05497be28df Docs sync done from apache/pulsar (#660525e)
05497be28df is described below
commit 05497be28df5eb1bca933bdbcba2dbd084a61b7c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Feb 22 01:37:53 2023 +0000
Docs sync done from apache/pulsar (#660525e)
---
static/reference/next/pulsar-admin/functions.md | 6 ++++++
static/swagger/master/swagger.json | 13 ++++++-------
static/swagger/master/swaggerfunctions.json | 6 ++++++
static/swagger/master/v2/swagger.json | 13 ++++++-------
static/swagger/master/v3/swaggerfunctions.json | 6 ++++++
5 files changed, 30 insertions(+), 14 deletions(-)
diff --git a/static/reference/next/pulsar-admin/functions.md
b/static/reference/next/pulsar-admin/functions.md
index eb106cdd4c4..1e9598bcc82 100644
--- a/static/reference/next/pulsar-admin/functions.md
+++ b/static/reference/next/pulsar-admin/functions.md
@@ -31,6 +31,7 @@ $ pulsar-admin functions localrun options
| `--forward-source-message-property` | Forwarding input message's properties
to output topic when processing (use false to disable it)|true|Java|
| `--metrics-port-start` | The starting port range for metrics
server|null|Java, Python, Go|
| `--secrets` | The map of secretName to an object that encapsulates how the
secret is fetched by the underlying secrets provider|null|Java, Python|
+| `--output-type-class-name` | The class name of output type class|null|Java,
Python, Go|
| `--ram` | The ram in bytes that need to be allocated per function
instance(applicable only to process/docker runtime)|null|Java(Process &
K8s),Python(K8s),Go(K8s)|
| `--function-config-file` | The path to a YAML config file that specifies the
configuration of a Pulsar Function|null|Java, Python, Go|
| `--subs-name` | Pulsar source subscription name if user wants a specific
subscription-name for input-topic consumer|null|Java, Python, Go|
@@ -60,6 +61,7 @@ $ pulsar-admin functions localrun options
| `--client-auth-plugin` | Client authentication plugin using which
function-process can connect to broker|null|Java, Python|
| `--fqfn` | The Fully Qualified Function Name (FQFN) for the
function|null|Java, Python|
| `--retain-key-ordering` | Function consumes and processes messages in key
order|null|Java|
+| `--input-type-class-name` | The class name of input type class|null|Java,
Python, Go|
| `--sliding-interval-count` | The number of messages after which the window
slides|null|Java|
| `--custom-runtime-options` | A string that encodes options to customize the
runtime, see docs for configured runtime for details|null|Java|
| `--custom-serde-inputs` | The map of input topics to SerDe class names (as a
JSON string)|null|Java, Python|
@@ -103,6 +105,7 @@ $ pulsar-admin functions create options
| `--window-length-count` | The number of messages per window|null|Java|
| `--forward-source-message-property` | Forwarding input message's properties
to output topic when processing (use false to disable it)|true|Java|
| `--secrets` | The map of secretName to an object that encapsulates how the
secret is fetched by the underlying secrets provider|null|Java, Python|
+| `--output-type-class-name` | The class name of output type class|null|Java,
Python, Go|
| `--ram` | The ram in bytes that need to be allocated per function
instance(applicable only to process/docker runtime)|null|Java(Process &
K8s),Python(K8s),Go(K8s)|
| `--function-config-file` | The path to a YAML config file that specifies the
configuration of a Pulsar Function|null|Java, Python, Go|
| `--subs-name` | Pulsar source subscription name if user wants a specific
subscription-name for input-topic consumer|null|Java, Python, Go|
@@ -125,6 +128,7 @@ $ pulsar-admin functions create options
| `-st, --schema-type` | The builtin schema type or custom schema class name
to be used for messages output by the function||Java|
| `--fqfn` | The Fully Qualified Function Name (FQFN) for the
function|null|Java, Python|
| `--retain-key-ordering` | Function consumes and processes messages in key
order|null|Java|
+| `--input-type-class-name` | The class name of input type class|null|Java,
Python, Go|
| `--sliding-interval-count` | The number of messages after which the window
slides|null|Java|
| `--custom-runtime-options` | A string that encodes options to customize the
runtime, see docs for configured runtime for details|null|Java|
| `--custom-serde-inputs` | The map of input topics to SerDe class names (as a
JSON string)|null|Java, Python|
@@ -182,6 +186,7 @@ $ pulsar-admin functions update options
| `--window-length-count` | The number of messages per window|null|Java|
| `--forward-source-message-property` | Forwarding input message's properties
to output topic when processing (use false to disable it)|true|Java|
| `--secrets` | The map of secretName to an object that encapsulates how the
secret is fetched by the underlying secrets provider|null|Java, Python|
+| `--output-type-class-name` | The class name of output type class|null|Java,
Python, Go|
| `--ram` | The ram in bytes that need to be allocated per function
instance(applicable only to process/docker runtime)|null|Java(Process &
K8s),Python(K8s),Go(K8s)|
| `--function-config-file` | The path to a YAML config file that specifies the
configuration of a Pulsar Function|null|Java, Python, Go|
| `--subs-name` | Pulsar source subscription name if user wants a specific
subscription-name for input-topic consumer|null|Java, Python, Go|
@@ -205,6 +210,7 @@ $ pulsar-admin functions update options
| `-st, --schema-type` | The builtin schema type or custom schema class name
to be used for messages output by the function||Java|
| `--fqfn` | The Fully Qualified Function Name (FQFN) for the
function|null|Java, Python|
| `--retain-key-ordering` | Function consumes and processes messages in key
order|null|Java|
+| `--input-type-class-name` | The class name of input type class|null|Java,
Python, Go|
| `--sliding-interval-count` | The number of messages after which the window
slides|null|Java|
| `--custom-runtime-options` | A string that encodes options to customize the
runtime, see docs for configured runtime for details|null|Java|
| `--custom-serde-inputs` | The map of input topics to SerDe class names (as a
JSON string)|null|Java, Python|
diff --git a/static/swagger/master/swagger.json
b/static/swagger/master/swagger.json
index 04b1d440a2d..99b44a0aa99 100644
--- a/static/swagger/master/swagger.json
+++ b/static/swagger/master/swagger.json
@@ -1325,23 +1325,22 @@
"format": "int64",
"type": "integer"
},
- "isOffloaded": {
- "type": "boolean"
- },
"ledgerId": {
"format": "int64",
"type": "integer"
},
- "offloadedContextUuid": {
+ "metadata": {
"type": "string"
},
+ "offloaded": {
+ "type": "boolean"
+ },
"size": {
"format": "int64",
"type": "integer"
},
- "timestamp": {
- "format": "int64",
- "type": "integer"
+ "underReplicated": {
+ "type": "boolean"
}
},
"type": "object"
diff --git a/static/swagger/master/swaggerfunctions.json
b/static/swagger/master/swaggerfunctions.json
index 8db5e521816..802a1152c0b 100644
--- a/static/swagger/master/swaggerfunctions.json
+++ b/static/swagger/master/swaggerfunctions.json
@@ -295,6 +295,9 @@
},
"type": "object"
},
+ "inputTypeClassName": {
+ "type": "string"
+ },
"inputs": {
"items": {
"type": "string"
@@ -330,6 +333,9 @@
"outputSerdeClassName": {
"type": "string"
},
+ "outputTypeClassName": {
+ "type": "string"
+ },
"parallelism": {
"format": "int32",
"type": "integer"
diff --git a/static/swagger/master/v2/swagger.json
b/static/swagger/master/v2/swagger.json
index 04b1d440a2d..99b44a0aa99 100644
--- a/static/swagger/master/v2/swagger.json
+++ b/static/swagger/master/v2/swagger.json
@@ -1325,23 +1325,22 @@
"format": "int64",
"type": "integer"
},
- "isOffloaded": {
- "type": "boolean"
- },
"ledgerId": {
"format": "int64",
"type": "integer"
},
- "offloadedContextUuid": {
+ "metadata": {
"type": "string"
},
+ "offloaded": {
+ "type": "boolean"
+ },
"size": {
"format": "int64",
"type": "integer"
},
- "timestamp": {
- "format": "int64",
- "type": "integer"
+ "underReplicated": {
+ "type": "boolean"
}
},
"type": "object"
diff --git a/static/swagger/master/v3/swaggerfunctions.json
b/static/swagger/master/v3/swaggerfunctions.json
index 8db5e521816..802a1152c0b 100644
--- a/static/swagger/master/v3/swaggerfunctions.json
+++ b/static/swagger/master/v3/swaggerfunctions.json
@@ -295,6 +295,9 @@
},
"type": "object"
},
+ "inputTypeClassName": {
+ "type": "string"
+ },
"inputs": {
"items": {
"type": "string"
@@ -330,6 +333,9 @@
"outputSerdeClassName": {
"type": "string"
},
+ "outputTypeClassName": {
+ "type": "string"
+ },
"parallelism": {
"format": "int32",
"type": "integer"
