This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 2d7c641 Updated site at revision 95df092
2d7c641 is described below
commit 2d7c641e61c0565b0ea0e79d4776d8c9c2b0bd5b
Author: jenkins <[email protected]>
AuthorDate: Mon Jun 24 08:47:25 2019 +0000
Updated site at revision 95df092
---
content/swagger/2.4.0-SNAPSHOT/swagger.json | 18 ++++++------
.../swagger/2.4.0-SNAPSHOT/swaggerfunctions.json | 34 +++++++++++-----------
content/swagger/2.4.0-SNAPSHOT/swaggersink.json | 13 +++++++--
content/swagger/2.4.0-SNAPSHOT/swaggersource.json | 30 +++++++++++++++++--
4 files changed, 65 insertions(+), 30 deletions(-)
diff --git a/content/swagger/2.4.0-SNAPSHOT/swagger.json
b/content/swagger/2.4.0-SNAPSHOT/swagger.json
index b527614..7e45281 100644
--- a/content/swagger/2.4.0-SNAPSHOT/swagger.json
+++ b/content/swagger/2.4.0-SNAPSHOT/swagger.json
@@ -4688,7 +4688,7 @@
"200" : {
"description" : "successful operation",
"schema" : {
- "$ref" : "#/definitions/NonPersistentTopicStats"
+ "$ref" : "#/definitions/TopicStats"
}
},
"403" : {
@@ -8528,10 +8528,10 @@
"type" : "number",
"format" : "double"
},
- "cpu" : {
+ "memory" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "memory" : {
+ "cpu" : {
"$ref" : "#/definitions/ResourceUsage"
},
"directMemory" : {
@@ -8551,13 +8551,13 @@
"type" : "number",
"format" : "double"
},
- "underLoaded" : {
- "type" : "boolean"
- },
"msgThroughputOut" : {
"type" : "number",
"format" : "double"
},
+ "underLoaded" : {
+ "type" : "boolean"
+ },
"overLoaded" : {
"type" : "boolean"
},
@@ -9500,11 +9500,11 @@
"ResourceUnit" : {
"type" : "object",
"properties" : {
- "availableResource" : {
- "$ref" : "#/definitions/ResourceDescription"
- },
"resourceId" : {
"type" : "string"
+ },
+ "availableResource" : {
+ "$ref" : "#/definitions/ResourceDescription"
}
}
},
diff --git a/content/swagger/2.4.0-SNAPSHOT/swaggerfunctions.json
b/content/swagger/2.4.0-SNAPSHOT/swaggerfunctions.json
index 3858125..9308ab4 100644
--- a/content/swagger/2.4.0-SNAPSHOT/swaggerfunctions.json
+++ b/content/swagger/2.4.0-SNAPSHOT/swaggerfunctions.json
@@ -162,7 +162,7 @@
"description" : "A JSON value presenting functions configuration
payload. An example of the expected functions can be found here. \nautoAck \n
Whether or not the framework will automatically acknowledge messages.
\nruntime \n What is the runtime of the function. Possible Values: [JAVA,
PYTHON, GO] \nresources \n The size of the system resources allowed by the
function runtime. The resources include: cpu, ram, disk. \nclassName \n The
class name of functions. \ncust [...]
"required" : false,
"schema" : {
- "type" : "string"
+ "$ref" : "#/definitions/FunctionConfig"
},
"x-examples" : {
"application/json" : "{\n \"inputs\":
persistent://public/default/input-topic,\n \"parallelism\": 4\n \"output\":
persistent://public/default/output-topic\n \"log-topic\":
persistent://public/default/log-topic\n \"classname\":
org.example.test.ExclamationFunction\n \"jar\":
java-function-1.0-SNAPSHOT.jar\n}"
@@ -214,7 +214,7 @@
"description" : "A JSON value presenting a functions config
playload. An example of the expected functions can be found down here.
\nautoAck \n Whether or not the framework will automatically acknowledge
messages. \nruntime \n What is the runtime of the function. Possible Values:
[JAVA, PYTHON, GO] \nresources \n The size of the system resources allowed
by the function runtime. The resources include: cpu, ram, disk. \nclassName
\n The class name of functions. \ncus [...]
"required" : false,
"schema" : {
- "type" : "string"
+ "$ref" : "#/definitions/FunctionConfig"
},
"x-examples" : {
"application/json" : "{\n \"inputs\":
persistent://public/default/input-topic,\n \"parallelism\": 4\n \"output\":
persistent://public/default/output-topic\n \"log-topic\":
persistent://public/default/log-topic\n \"classname\":
org.example.test.ExclamationFunction\n \"jar\":
java-function-1.0-SNAPSHOT.jar\n}"
@@ -1359,15 +1359,12 @@
"replicated" : {
"type" : "boolean"
},
- "topicName" : {
- "type" : "string"
- },
- "messageId" : {
- "$ref" : "#/definitions/MessageId"
- },
- "sequenceId" : {
- "type" : "integer",
- "format" : "int64"
+ "keyBytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "string",
+ "format" : "byte"
+ }
},
"orderingKey" : {
"type" : "array",
@@ -1390,12 +1387,8 @@
"format" : "byte"
}
},
- "keyBytes" : {
- "type" : "array",
- "items" : {
- "type" : "string",
- "format" : "byte"
- }
+ "topicName" : {
+ "type" : "string"
},
"replicatedFrom" : {
"type" : "string"
@@ -1403,6 +1396,13 @@
"producerName" : {
"type" : "string"
},
+ "messageId" : {
+ "$ref" : "#/definitions/MessageId"
+ },
+ "sequenceId" : {
+ "type" : "integer",
+ "format" : "int64"
+ },
"data" : {
"type" : "array",
"items" : {
diff --git a/content/swagger/2.4.0-SNAPSHOT/swaggersink.json
b/content/swagger/2.4.0-SNAPSHOT/swaggersink.json
index b7248ff..c43892a 100644
--- a/content/swagger/2.4.0-SNAPSHOT/swaggersink.json
+++ b/content/swagger/2.4.0-SNAPSHOT/swaggersink.json
@@ -155,7 +155,7 @@
"description" : "A JSON value presenting a sink config playload. All
available configuration options are: \nclassname \n The sink's class name
if archive is file-url-path (file://) \nsourceSubscriptionName \n Pulsar
source subscription name if user wants a specific \n subscription-name for
input-topic consumer \ninputs \n The sink's input topic or topics
(specified as a JSON array) \ntopicsPattern \n TopicsPattern to consume
from list of topics under a namesp [...]
"required" : false,
"schema" : {
- "type" : "string"
+ "$ref" : "#/definitions/SinkConfig"
},
"x-examples" : {
"application/json" : "{ \n\t\"classname\":
\"org.example.MySinkTest\",\n\t\"inputs\":
[\"persistent://public/default/sink-input\"],\n\t\"processingGuarantees\":
\"EFFECTIVELY_ONCE\",\n\t\"parallelism\": 10\n}"
@@ -207,10 +207,18 @@
}, {
"in" : "body",
"name" : "body",
- "description" : "A JSON value presenting a sink config playload. All
available configuration options are: \nclassname \n The sink's class name
if archive is file-url-path (file://) \nsourceSubscriptionName \n Pulsar
source subscription name if user wants a specific \n subscription-name for
input-topic consumer \ninputs \n The sink's input topic or topics
(specified as a JSON array) \ntopicsPattern \n TopicsPattern to consume
from list of topics under a namesp [...]
+ "description" : "URL of sink's archive",
"required" : false,
"schema" : {
"type" : "string"
+ }
+ }, {
+ "in" : "body",
+ "name" : "body",
+ "description" : "A JSON value presenting a sink config playload. All
available configuration options are: \nclassname \n The sink's class name
if archive is file-url-path (file://) \nsourceSubscriptionName \n Pulsar
source subscription name if user wants a specific \n subscription-name for
input-topic consumer \ninputs \n The sink's input topic or topics
(specified as a JSON array) \ntopicsPattern \n TopicsPattern to consume
from list of topics under a namesp [...]
+ "required" : false,
+ "schema" : {
+ "$ref" : "#/definitions/SinkConfig"
},
"x-examples" : {
"application/json" : "{ \n\t\"classname\":
\"org.example.SinkStressTest\", \n\t\"inputs\":
[\"persistent://public/default/sink-input\"],\n\t\"processingGuarantees\":
\"EFFECTIVELY_ONCE\",\n\t\"parallelism\": 5\n}"
@@ -218,6 +226,7 @@
}, {
"in" : "body",
"name" : "body",
+ "description" : "Update options for sink",
"required" : false,
"schema" : {
"$ref" : "#/definitions/UpdateOptions"
diff --git a/content/swagger/2.4.0-SNAPSHOT/swaggersource.json
b/content/swagger/2.4.0-SNAPSHOT/swaggersource.json
index d8c8a17..c8b5690 100644
--- a/content/swagger/2.4.0-SNAPSHOT/swaggersource.json
+++ b/content/swagger/2.4.0-SNAPSHOT/swaggersource.json
@@ -167,7 +167,7 @@
"description" : "A JSON value presenting source configuration
payload. An example of the expected functions can be found here. \nclassname
\n The source's class name if archive is file-url-path (file://). \ntopicName
\n The Pulsar topic to which data is sent. \nserdeClassName \n The SerDe
classname for the source. \nschemaType \n The schema type (either a builtin
schema like 'avro', 'json', etc.. or custom Schema class name to be used to
encode messages emitted f [...]
"required" : false,
"schema" : {
- "type" : "string"
+ "$ref" : "#/definitions/SourceConfig"
},
"x-examples" : {
"application/json" : "{\n \"tenant\": public\n \"namespace\":
default\n \"name\": pulsar-io-mysql\n \"className\": TestSourceMysql\n
\"topicName\": pulsar-io-mysql\n \"parallelism\": 1\n \"archive\":
/connectors/pulsar-io-mysql-0.0.1.nar\n \"schemaType\": avro\n}"
@@ -219,14 +219,30 @@
}, {
"in" : "body",
"name" : "body",
- "description" : "A JSON value presenting source configuration
payload. An example of the expected functions can be found here. \nclassname
\n The source's class name if archive is file-url-path (file://). \ntopicName
\n The Pulsar topic to which data is sent. \nserdeClassName \n The SerDe
classname for the source. \nschemaType \n The schema type (either a builtin
schema like 'avro', 'json', etc.. or custom Schema class name to be used to
encode messages emitted f [...]
+ "description" : "URL of sources' archive",
"required" : false,
"schema" : {
"type" : "string"
+ }
+ }, {
+ "in" : "body",
+ "name" : "body",
+ "description" : "A JSON value presenting source configuration
payload. An example of the expected functions can be found here. \nclassname
\n The source's class name if archive is file-url-path (file://). \ntopicName
\n The Pulsar topic to which data is sent. \nserdeClassName \n The SerDe
classname for the source. \nschemaType \n The schema type (either a builtin
schema like 'avro', 'json', etc.. or custom Schema class name to be used to
encode messages emitted f [...]
+ "required" : false,
+ "schema" : {
+ "$ref" : "#/definitions/SourceConfig"
},
"x-examples" : {
"application/json" : "{\n \"tenant\": public\n \"namespace\":
default\n \"name\": pulsar-io-mysql\n \"className\": TestSourceMysql\n
\"topicName\": pulsar-io-mysql\n \"parallelism\": 1\n \"archive\":
/connectors/pulsar-io-mysql-0.0.1.nar\n \"schemaType\": avro\n}"
}
+ }, {
+ "in" : "body",
+ "name" : "body",
+ "description" : "Update options for source",
+ "required" : false,
+ "schema" : {
+ "$ref" : "#/definitions/UpdateOptions"
+ }
} ],
"responses" : {
"200" : {
@@ -855,6 +871,16 @@
}
}
}
+ },
+ "UpdateOptions" : {
+ "type" : "object",
+ "properties" : {
+ "update-auth-data" : {
+ "type" : "boolean",
+ "description" : "Whether or not to update the auth data"
+ }
+ },
+ "description" : "Options while updating the sink"
}
}
}
\ No newline at end of file
