diff options
Diffstat (limited to 'dcae-analytics-cdap-plugins/widgets')
5 files changed, 418 insertions, 0 deletions
diff --git a/dcae-analytics-cdap-plugins/widgets/DMaaPMRSink-batchsink.json b/dcae-analytics-cdap-plugins/widgets/DMaaPMRSink-batchsink.json new file mode 100644 index 0000000..3f61dd6 --- /dev/null +++ b/dcae-analytics-cdap-plugins/widgets/DMaaPMRSink-batchsink.json @@ -0,0 +1,94 @@ +{ + "metadata": { + "spec-version": "1.3" + }, + "configuration-groups": [ + { + "label": "DMaaP MR Sink Configuration", + "properties": [ + { + "widget-type": "textbox", + "label": "Reference Name", + "name": "referenceName", + "widget-attributes": { + "default": "DMaaPMRSink" + } + }, + { + "widget-type": "textbox", + "label": "Host Name", + "name": "hostName" + }, + { + "widget-type": "number", + "label": "Host Port number", + "name": "portNumber" + }, + { + "widget-type": "textbox", + "label": "Topic Name", + "name": "topicName" + }, + { + "widget-type": "textbox", + "label": "Protocol", + "name": "protocol", + "widget-attributes": { + "default": "https" + } + }, + { + "widget-type": "textbox", + "label": "User Name", + "name": "userName" + }, + { + "widget-type": "textbox", + "label": "User Password", + "name": "userPassword" + }, + { + "widget-type": "textbox", + "label": "Content Type'", + "name": "contentType", + "widget-attributes": { + "default": "application/json" + } + }, + { + "widget-type": "string", + "label": "Message Column Name", + "name": "messageColumnName", + "widget-attributes": { + "default": "message" + } + }, + { + "widget-type": "string", + "label": "Max Batch Size", + "name": "maxBatchSize", + "widget-attributes": { + "default": "50" + } + }, + { + "widget-type": "string", + "label": "Max Recovery Queue Size", + "name": "maxRecoveryQueueSize" + } + ] + } + ], + "outputs": [ + { + "name": "schema", + "widget-type": "schema", + "widget-attributes": { + "schema-types": [ + "string" + ], + "schema-default-type": "string" + } + } + ] +} diff --git a/dcae-analytics-cdap-plugins/widgets/DMaaPMRSource-streamingsource.json b/dcae-analytics-cdap-plugins/widgets/DMaaPMRSource-streamingsource.json new file mode 100644 index 0000000..86f058c --- /dev/null +++ b/dcae-analytics-cdap-plugins/widgets/DMaaPMRSource-streamingsource.json @@ -0,0 +1,106 @@ +{ + "metadata": { + "spec-version": "1.0" + }, + "configuration-groups": [ + { + "label": "DMaaP MR Source Configuration", + "properties": [ + { + "widget-type": "textbox", + "label": "Reference Name", + "name": "referenceName", + "widget-attributes": { + "default": "DMaaPMRSource" + } + }, + { + "widget-type": "textbox", + "label": "Host Name", + "name": "hostName" + }, + { + "widget-type": "number", + "label": "Host Port number", + "name": "portNumber" + }, + { + "widget-type": "textbox", + "label": "Topic Name", + "name": "topicName" + }, + { + "widget-type": "textbox", + "label": "Polling Interval (ms)", + "name": "pollingInterval", + "widget-attributes": { + "default": "20000" + } + }, + { + "widget-type": "textbox", + "label": "Protocol", + "name": "protocol", + "widget-attributes": { + "default": "https" + } + }, + { + "widget-type": "textbox", + "label":"User Name", + "name": "userName" + }, + { + "widget-type": "textbox", + "label": "User Password", + "name": "userPassword" + }, + { + "widget-type": "textbox", + "label": "Content Type'", + "name": "contentType", + "widget-attributes": { + "default": "application/json" + } + }, + { + "widget-type": "textbox", + "label": "Source Consumer ID", + "name": "consumerId", + "widget-attributes": { + "default": "C1" + } + }, + { + "widget-type": "textbox", + "label": "Source Consumer Group", + "name": "consumerGroup", + "widget-attributes": { + "default": "OpenDCAE-G1" + } + }, + { + "widget-type": "string", + "label": "Consumer Timeout (ms)", + "name": "timeoutMS" + }, + { + "widget-type": "string", + "label": "Subscriber Message Limit", + "name": "messageLimit" + } + ] + } + ], + "outputs": [ + { + "widget-type": "non-editable-schema-editor", + "schema": { + "ts": "long", + "responseCode": "int", + "responseMessage": "string", + "message": "string" + } + } + ] +} diff --git a/dcae-analytics-cdap-plugins/widgets/JsonPathFilter-transform.json b/dcae-analytics-cdap-plugins/widgets/JsonPathFilter-transform.json new file mode 100644 index 0000000..a3b6286 --- /dev/null +++ b/dcae-analytics-cdap-plugins/widgets/JsonPathFilter-transform.json @@ -0,0 +1,58 @@ +{ + "metadata": { + "spec-version": "1.0" + }, + "configuration-groups": [ + { + "label": "JSON Path Filter", + "properties": [ + { + "widget-type": "textbox", + "label": "Reference Name", + "name": "referenceName", + "widget-attributes": { + "default": "JsonPathFilter" + } + }, + { + "widget-type": "textbox", + "label": "Input Field Name", + "name": "incomingJsonFieldName" + }, + { + "widget-type": "textbox", + "label": "Output Schema Field Name", + "name": "outputSchemaFieldName" + }, + { + "widget-type": "keyvalue", + "label": "Json Path Filter Mappings", + "name": "jsonFilterMappings", + "widget-attributes": { + "showDelimiter": "false" + } + } + ] + } + ], + "outputs": [ + { + "name": "schema", + "label": "schema", + "widget-type": "schema", + "widget-attributes": { + "schema-types": [ + "boolean", + "int", + "long", + "float", + "double", + "bytes", + "string" + ], + "schema-default-type": "string", + "property-watch": "format" + } + } + ] +} diff --git a/dcae-analytics-cdap-plugins/widgets/MockDMaaPMRSource-streamingsource.json b/dcae-analytics-cdap-plugins/widgets/MockDMaaPMRSource-streamingsource.json new file mode 100644 index 0000000..0441b5f --- /dev/null +++ b/dcae-analytics-cdap-plugins/widgets/MockDMaaPMRSource-streamingsource.json @@ -0,0 +1,106 @@ +{ + "metadata": { + "spec-version": "1.0" + }, + "configuration-groups": [ + { + "label": "DMaaP MR Source Configuration", + "properties": [ + { + "widget-type": "textbox", + "label": "Reference Name", + "name": "referenceName", + "widget-attributes": { + "default": "DMaaPMRSource" + } + }, + { + "widget-type": "textbox", + "label": "Host Name", + "name": "hostName" + }, + { + "widget-type": "number", + "label": "Host Port number", + "name": "portNumber" + }, + { + "widget-type": "textbox", + "label": "Topic Name", + "name": "topicName" + }, + { + "widget-type": "textbox", + "label": "Polling Interval (ms)", + "name": "pollingInterval", + "widget-attributes": { + "default": "20000" + } + }, + { + "widget-type": "textbox", + "label": "Protocol", + "name": "protocol", + "widget-attributes": { + "default": "https" + } + }, + { + "widget-type": "textbox", + "label": "User Name", + "name": "userName" + }, + { + "widget-type": "textbox", + "label": "User Password", + "name": "userPassword" + }, + { + "widget-type": "textbox", + "label": "Content Type'", + "name": "contentType", + "widget-attributes": { + "default": "application/json" + } + }, + { + "widget-type": "textbox", + "label": "Source Consumer ID", + "name": "consumerId", + "widget-attributes": { + "default": "C1" + } + }, + { + "widget-type": "textbox", + "label": "Source Consumer Group", + "name": "consumerGroup", + "widget-attributes": { + "default": "OpenDCAE-G1" + } + }, + { + "widget-type": "string", + "label": "Consumer Timeout (ms)", + "name": "timeoutMS" + }, + { + "widget-type": "string", + "label": "Subscriber Message Limit", + "name": "messageLimit" + } + ] + } + ], + "outputs": [ + { + "widget-type": "non-editable-schema-editor", + "schema": { + "ts": "long", + "responseCode": "int", + "responseMessage": "string", + "message": "string" + } + } + ] +} diff --git a/dcae-analytics-cdap-plugins/widgets/SimpleTCAPlugin-sparkcompute.json b/dcae-analytics-cdap-plugins/widgets/SimpleTCAPlugin-sparkcompute.json new file mode 100644 index 0000000..ea42d94 --- /dev/null +++ b/dcae-analytics-cdap-plugins/widgets/SimpleTCAPlugin-sparkcompute.json @@ -0,0 +1,54 @@ +{ + "metadata": { + "spec-version": "1.0" + }, + "configuration-groups": [ + { + "label": "Simple TCA Transform Properties", + "properties": [ + { + "widget-type": "textbox", + "label": "InputSchema field name that contains CEF Message", + "name": "vesMessageFieldName" + }, + { + "widget-type": "textbox", + "label": "TCA Policy JSON string", + "name": "policyJson" + }, + { + "widget-type": "textbox", + "label": "OutputSchema field name that will contain alert message", + "name": "alertFieldName" + }, + { + "widget-type": "textbox", + "label": "OutputSchema field name that will contain the TCA message type", + "name": "messageTypeFieldName" + }, + { + "widget-type": "textbox", + "label": "Enable Alert Output Format in CEF format", + "name": "enableAlertCEFFormat", + "widget-attributes": { + "default": "false" + } + } + ] + } + ], + "outputs": [ + { + "name": "schema", + "label": "schema", + "widget-type": "schema", + "widget-attributes": { + "schema-types": [ + "string" + ], + "schema-default-type": "string", + "property-watch": "format" + } + } + ] +} |