You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/06/24 08:47:32 UTC
[pulsar] branch asf-site updated: Updated site at revision 95df092
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 <bu...@apache.org>
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