diff --git a/docker/streaming/scenarios/DetectLargeTransactions.json b/docker/streaming/scenarios/DetectLargeTransactions.json index a03c0204..8d45e9ac 100644 --- a/docker/streaming/scenarios/DetectLargeTransactions.json +++ b/docker/streaming/scenarios/DetectLargeTransactions.json @@ -1,140 +1,125 @@ { - "metaData" : { - "id" : "DetectLargeTransactions", - "typeSpecificData" : { - "parallelism" : 2, - "spillStateToDisk" : true, - "useAsyncInterpretation" : null, - "checkpointIntervalInSeconds" : null, - "type" : "StreamMetaData" - }, - "isSubprocess" : false, - "additionalFields" : { - "description" : null, - "groups" : [ - ], - "properties" : { - - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "DetectLargeTransactions", + "additionalFields": { + "description": null, + "properties": { + "parallelism": "2", + "spillStateToDisk": "true" + }, + "metaDataType": "StreamMetaData" } }, - "exceptionHandlerRef" : { - "parameters" : [ - ] - }, - "nodes" : [ + "nodes": [ { - "id" : "transactions", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "transactions", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'transactions'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'transactions'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } } ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "only large ones", - "expression" : { - "language" : "spel", - "expression" : "#input.amount > 20" + "id": "only large ones", + "expression": { + "language": "spel", + "expression": "#input.amount > 20" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 180 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 180 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "send for audit", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'processedEvents'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" } }, { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" } }, { - "name" : "Value", - "expression" : { - "language" : "spel", - "expression" : "#input" + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 360 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 360 } }, - "type" : "Sink" + "type": "Sink" } ], - "additionalBranches" : [ + "additionalBranches": [ ] } \ No newline at end of file diff --git a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregation.json b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregation.json index 818dd5ba..d2505202 100644 --- a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregation.json +++ b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregation.json @@ -1,278 +1,270 @@ { - "metaData" : { - "id" : "DetectLargeTransactions", - "typeSpecificData" : { - "parallelism" : 2, - "spillStateToDisk" : true, - "useAsyncInterpretation" : null, - "checkpointIntervalInSeconds" : null, - "type" : "StreamMetaData" - }, - "additionalFields" : { - "description" : null, - "properties" : { - - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "DetectLargeTransactions", + "additionalFields": { + "description": null, + "properties": { + "parallelism": "2", + "spillStateToDisk": "true" + }, + "metaDataType": "StreamMetaData" } }, - "nodes" : [ + "nodes": [ { - "id" : "bank-transactions", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "bank-transactions", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'transactions'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'transactions'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } } ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "nexts" : [ + "nexts": [ [ { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "only large ones", - "expression" : { - "language" : "spel", - "expression" : "#input.amount > 20" + "id": "only large ones", + "expression": { + "language": "spel", + "expression": "#input.amount > 20" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 360 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 360 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "send for audit", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'processedEvents'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" } }, { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" } }, { - "name" : "Value", - "expression" : { - "language" : "spel", - "expression" : "#input" + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 540 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 540 } }, - "type" : "Sink" + "type": "Sink" } ], [ { - "id" : "aggregate-sliding", - "outputVar" : "aggregated", - "nodeType" : "aggregate-sliding", - "parameters" : [ + "id": "aggregate-sliding", + "outputVar": "aggregated", + "nodeType": "aggregate-sliding", + "parameters": [ { - "name" : "groupBy", - "expression" : { - "language" : "spel", - "expression" : "#input.clientId" + "name": "groupBy", + "expression": { + "language": "spel", + "expression": "#input.clientId" } }, { - "name" : "aggregator", - "expression" : { - "language" : "spel", - "expression" : "#AGG.sum" + "name": "aggregator", + "expression": { + "language": "spel", + "expression": "#AGG.sum" } }, { - "name" : "aggregateBy", - "expression" : { - "language" : "spel", - "expression" : "#input.amount" + "name": "aggregateBy", + "expression": { + "language": "spel", + "expression": "#input.amount" } }, { - "name" : "windowLength", - "expression" : { - "language" : "spel", - "expression" : "T(java.time.Duration).parse('P1D')" + "name": "windowLength", + "expression": { + "language": "spel", + "expression": "T(java.time.Duration).parse('P1D')" } }, { - "name" : "emitWhenEventLeft", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "emitWhenEventLeft", + "expression": { + "language": "spel", + "expression": "false" } } ], - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 360 + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 360 } }, - "type" : "CustomNode" + "type": "CustomNode" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "filter large amount", - "expression" : { - "language" : "spel", - "expression" : "#aggregated > 30" + "id": "filter large amount", + "expression": { + "language": "spel", + "expression": "#aggregated > 30" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 540 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 540 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "alert", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "alert", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'alerts'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'alerts'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" } }, { - "name" : "eventDate", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "eventDate", + "expression": { + "language": "spel", + "expression": "" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] ], - "id" : "split", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 180 + "id": "split", + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 180 } }, - "type" : "Split" + "type": "Split" } ], - "additionalBranches" : [ + "additionalBranches": [ ] } \ No newline at end of file diff --git a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricher.json b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricher.json index 58c051d9..b601296a 100644 --- a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricher.json +++ b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricher.json @@ -1,398 +1,390 @@ { - "metaData" : { - "id" : "DetectLargeTransactions", - "typeSpecificData" : { - "parallelism" : 2, - "spillStateToDisk" : true, - "useAsyncInterpretation" : null, - "checkpointIntervalInSeconds" : null, - "type" : "StreamMetaData" - }, - "additionalFields" : { - "description" : null, - "properties" : { - - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "DetectLargeTransactions", + "additionalFields": { + "description": null, + "properties": { + "parallelism": "2", + "spillStateToDisk": "true" + }, + "metaDataType": "StreamMetaData" } }, - "nodes" : [ + "nodes": [ { - "id" : "bank-transactions", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "bank-transactions", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'transactions'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'transactions'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } } ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "nexts" : [ + "nexts": [ [ { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "only large ones", - "expression" : { - "language" : "spel", - "expression" : "#input.amount > 20" + "id": "only large ones", + "expression": { + "language": "spel", + "expression": "#input.amount > 20" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 360 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 360 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "customer data", - "service" : { - "id" : "getCustomer", - "parameters" : [ + "id": "customer data", + "service": { + "id": "getCustomer", + "parameters": [ { - "name" : "customer_id", - "expression" : { - "language" : "spel", - "expression" : "#CONV.toNumber(#input.clientId).longValue" + "name": "customer_id", + "expression": { + "language": "spel", + "expression": "#CONV.toNumber(#input.clientId).longValue" } } ] }, - "output" : "customerData", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 540 + "output": "customerData", + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 540 } }, - "type" : "Enricher" + "type": "Enricher" }, { - "defaultNext" : [ + "defaultNext": [ ], - "nexts" : [ + "nexts": [ { - "expression" : { - "language" : "spel", - "expression" : "#customerData.category == \"STANDARD\"" + "expression": { + "language": "spel", + "expression": "#customerData.category == \"STANDARD\"" }, - "nodes" : [ + "nodes": [ { - "id" : "alert large transaction", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "alert large transaction", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'alerts'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'alerts'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Client: ' + #input.clientId + ' has exceeded limit for single transaction, value: ' + #input.amount" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Client: ' + #input.clientId + ' has exceeded limit for single transaction, value: ' + #input.amount" } }, { - "name" : "eventDate", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "eventDate", + "expression": { + "language": "spel", + "expression": "" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 900 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 900 } }, - "type" : "Sink" + "type": "Sink" } ] }, { - "expression" : { - "language" : "spel", - "expression" : "true" + "expression": { + "language": "spel", + "expression": "true" }, - "nodes" : [ + "nodes": [ { - "id" : "send for audit", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'processedEvents'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" } }, { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" } }, { - "name" : "Value", - "expression" : { - "language" : "spel", - "expression" : "#input" + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 900 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 900 } }, - "type" : "Sink" + "type": "Sink" } ] } ], - "id" : "category", - "expression" : { - "language" : "spel", - "expression" : "" + "id": "category", + "expression": { + "language": "spel", + "expression": "" }, - "exprVal" : "", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 720 + "exprVal": "", + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 720 } }, - "type" : "Switch" + "type": "Switch" } ], [ { - "id" : "aggregate-sliding", - "outputVar" : "aggregated", - "nodeType" : "aggregate-sliding", - "parameters" : [ + "id": "aggregate-sliding", + "outputVar": "aggregated", + "nodeType": "aggregate-sliding", + "parameters": [ { - "name" : "groupBy", - "expression" : { - "language" : "spel", - "expression" : "#input.clientId" + "name": "groupBy", + "expression": { + "language": "spel", + "expression": "#input.clientId" } }, { - "name" : "aggregator", - "expression" : { - "language" : "spel", - "expression" : "#AGG.sum" + "name": "aggregator", + "expression": { + "language": "spel", + "expression": "#AGG.sum" } }, { - "name" : "aggregateBy", - "expression" : { - "language" : "spel", - "expression" : "#input.amount" + "name": "aggregateBy", + "expression": { + "language": "spel", + "expression": "#input.amount" } }, { - "name" : "windowLength", - "expression" : { - "language" : "spel", - "expression" : "T(java.time.Duration).parse('P1D')" + "name": "windowLength", + "expression": { + "language": "spel", + "expression": "T(java.time.Duration).parse('P1D')" } }, { - "name" : "emitWhenEventLeft", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "emitWhenEventLeft", + "expression": { + "language": "spel", + "expression": "false" } } ], - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 360 + "additionalFields": { + "description": null, + "layoutData": { + "x": 540, + "y": 360 } }, - "type" : "CustomNode" + "type": "CustomNode" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "filter large amount", - "expression" : { - "language" : "spel", - "expression" : "#aggregated > 30" + "id": "filter large amount", + "expression": { + "language": "spel", + "expression": "#aggregated > 30" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 540 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 540, + "y": 540 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "alert", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "alert", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'alerts'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'alerts'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" } }, { - "name" : "eventDate", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "eventDate", + "expression": { + "language": "spel", + "expression": "" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 540, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] ], - "id" : "split", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 180 + "id": "split", + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 180 } }, - "type" : "Split" + "type": "Split" } ], - "additionalBranches" : [ + "additionalBranches": [ ] -} +} \ No newline at end of file diff --git a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricherFiltered.json b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricherFiltered.json index fa3208f1..a89e73da 100644 --- a/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricherFiltered.json +++ b/docker/streaming/scenarios/DetectLargeTransactionsWithAggregationAndEnricherFiltered.json @@ -1,416 +1,403 @@ { - "metaData" : { - "id" : "DetectLargeTransactions", - "typeSpecificData" : { - "parallelism" : 2, - "spillStateToDisk" : true, - "useAsyncInterpretation" : null, - "checkpointIntervalInSeconds" : null, - "type" : "StreamMetaData" - }, - "additionalFields" : { - "description" : null, - "properties" : { - - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "DetectLargeTransactions", + "additionalFields": { + "description": null, + "properties": { + "parallelism": "2", + "spillStateToDisk": "true" + }, + "metaDataType": "StreamMetaData" } }, - "nodes" : [ + "nodes": [ { - "id" : "bank-transactions", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "bank-transactions", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'transactions'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'transactions'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } } ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "nexts" : [ + "nexts": [ [ { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "only large ones", - "expression" : { - "language" : "spel", - "expression" : "#input.amount > 20" + "id": "only large ones", + "expression": { + "language": "spel", + "expression": "#input.amount > 20" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 360 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 360 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "customer data", - "service" : { - "id" : "getCustomer", - "parameters" : [ + "id": "customer data", + "service": { + "id": "getCustomer", + "parameters": [ { - "name" : "customer_id", - "expression" : { - "language" : "spel", - "expression" : "#CONV.toNumber(#input.clientId).longValue" + "name": "customer_id", + "expression": { + "language": "spel", + "expression": "#CONV.toNumber(#input.clientId).longValue" } } ] }, - "output" : "customerData", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 540 + "output": "customerData", + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 540 } }, - "type" : "Enricher" + "type": "Enricher" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "customer exists?", - "expression" : { - "language" : "spel", - "expression" : "#customerData != null" + "id": "customer exists?", + "expression": { + "language": "spel", + "expression": "#customerData != null" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 720 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 720 } }, - "type" : "Filter" + "type": "Filter" }, { - "defaultNext" : [ + "defaultNext": [ ], - "nexts" : [ + "nexts": [ { - "expression" : { - "language" : "spel", - "expression" : "#customerData.category == \"STANDARD\"" + "expression": { + "language": "spel", + "expression": "#customerData.category == \"STANDARD\"" }, - "nodes" : [ + "nodes": [ { - "id" : "alert large transaction", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "alert large transaction", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'alerts'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'alerts'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Client: ' + #input.clientId + ' has exceeded limit for single transaction, value: ' + #input.amount" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Client: ' + #input.clientId + ' has exceeded limit for single transaction, value: ' + #input.amount" } }, { - "name" : "eventDate", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "eventDate", + "expression": { + "language": "spel", + "expression": "" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 1080 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 1080 } }, - "type" : "Sink" + "type": "Sink" } ] }, { - "expression" : { - "language" : "spel", - "expression" : "true" + "expression": { + "language": "spel", + "expression": "true" }, - "nodes" : [ + "nodes": [ { - "id" : "send for audit", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'processedEvents'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" } }, { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" } }, { - "name" : "Value", - "expression" : { - "language" : "spel", - "expression" : "#input" + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 1080 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 540, + "y": 1080 } }, - "type" : "Sink" + "type": "Sink" } ] } ], - "id" : "category", - "expression" : { - "language" : "spel", - "expression" : "" - }, - "exprVal" : "", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 900 + "id": "category", + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 900 } }, - "type" : "Switch" + "type": "Switch" } ], [ { - "id" : "aggregate-sliding", - "outputVar" : "aggregated", - "nodeType" : "aggregate-sliding", - "parameters" : [ + "id": "aggregate-sliding", + "outputVar": "aggregated", + "nodeType": "aggregate-sliding", + "parameters": [ { - "name" : "groupBy", - "expression" : { - "language" : "spel", - "expression" : "#input.clientId" + "name": "groupBy", + "expression": { + "language": "spel", + "expression": "#input.clientId" } }, { - "name" : "aggregator", - "expression" : { - "language" : "spel", - "expression" : "#AGG.sum" + "name": "aggregator", + "expression": { + "language": "spel", + "expression": "#AGG.sum" } }, { - "name" : "aggregateBy", - "expression" : { - "language" : "spel", - "expression" : "#input.amount" + "name": "aggregateBy", + "expression": { + "language": "spel", + "expression": "#input.amount" } }, { - "name" : "windowLength", - "expression" : { - "language" : "spel", - "expression" : "T(java.time.Duration).parse('P1D')" + "name": "windowLength", + "expression": { + "language": "spel", + "expression": "T(java.time.Duration).parse('P1D')" } }, { - "name" : "emitWhenEventLeft", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "emitWhenEventLeft", + "expression": { + "language": "spel", + "expression": "false" } } ], - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 360 + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 360 } }, - "type" : "CustomNode" + "type": "CustomNode" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "filter large amount", - "expression" : { - "language" : "spel", - "expression" : "#aggregated > 30" + "id": "filter large amount", + "expression": { + "language": "spel", + "expression": "#aggregated > 30" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 540 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 540 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "alert", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "alert", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'alerts'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'alerts'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Client: ' + #input.clientId + ' has exceeded limit, total amount: ' + #aggregated" } }, { - "name" : "eventDate", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "eventDate", + "expression": { + "language": "spel", + "expression": "" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] ], - "id" : "split", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 180, - "y" : 180 + "id": "split", + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 180 } }, - "type" : "Split" + "type": "Split" } ], - "additionalBranches" : [ + "additionalBranches": [ ] -} +} \ No newline at end of file diff --git a/k8s-helm/scenarios/DetectLargeTransactionsLite.json b/k8s-helm/scenarios/DetectLargeTransactionsLite.json index 8eb1ef29..cc2e3a70 100644 --- a/k8s-helm/scenarios/DetectLargeTransactionsLite.json +++ b/k8s-helm/scenarios/DetectLargeTransactionsLite.json @@ -1,137 +1,124 @@ { - "metaData" : { - "id" : "DetectLargeTransactions", - "typeSpecificData" : { - "parallelism" : 2, - "type" : "LiteStreamMetaData" - }, - "isSubprocess" : false, - "additionalFields" : { - "description" : null, - "groups" : [ - ], - "properties" : { - - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "DetectLargeTransactions", + "additionalFields": { + "description": null, + "properties": { + "parallelism": "2" + }, + "metaDataType": "LiteStreamMetaData" } }, - "exceptionHandlerRef" : { - "parameters" : [ - ] - }, - "nodes" : [ + "nodes": [ { - "id" : "transactions", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "transactions", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'transactions'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'transactions'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } } ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "nextFalse" : [ + "nextFalse": [ ], - "id" : "only large ones", - "expression" : { - "language" : "spel", - "expression" : "#input.amount > 20" + "id": "only large ones", + "expression": { + "language": "spel", + "expression": "#input.amount > 20" }, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 180 + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 180 } }, - "type" : "Filter" + "type": "Filter" }, { - "id" : "send for audit", - "ref" : { - "typ" : "kafka", - "parameters" : [ + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ { - "name" : "Topic", - "expression" : { - "language" : "spel", - "expression" : "'processedEvents'" + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" } }, { - "name" : "Schema version", - "expression" : { - "language" : "spel", - "expression" : "'latest'" + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" } }, { - "name" : "Key", - "expression" : { - "language" : "spel", - "expression" : "" + "name": "Key", + "expression": { + "language": "spel", + "expression": "" } }, { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" } }, { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" } }, { - "name" : "Value", - "expression" : { - "language" : "spel", - "expression" : "#input" + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 360 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 360 } }, - "type" : "Sink" + "type": "Sink" } ], - "additionalBranches" : [ + "additionalBranches": [ ] -} +} \ No newline at end of file diff --git a/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherFilteredLite.json b/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherFilteredLite.json index e55f523d..44b7c29e 100644 --- a/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherFilteredLite.json +++ b/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherFilteredLite.json @@ -1,23 +1,13 @@ { "metaData": { "id": "DetectLargeTransactions", - "typeSpecificData": { - "parallelism": 2, - "spillStateToDisk": true, - "useAsyncInterpretation": null, - "checkpointIntervalInSeconds": null, - "type": "StreamMetaData" - }, - "isSubprocess": false, "additionalFields": { "description": null, - "groups": [], - "properties": {} - }, - "subprocessVersions": {} - }, - "exceptionHandlerRef": { - "parameters": [] + "properties": { + "parallelism": "2" + }, + "metaDataType": "LiteStreamMetaData" + } }, "nodes": [ { @@ -51,7 +41,8 @@ "type": "Source" }, { - "nextFalse": [], + "nextFalse": [ + ], "id": "only large ones", "expression": { "language": "spel", @@ -61,8 +52,8 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 360 + "x": 180, + "y": 180 } }, "type": "Filter" @@ -85,14 +76,15 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 540 + "x": 180, + "y": 360 } }, "type": "Enricher" }, { - "nextFalse": [], + "nextFalse": [ + ], "id": "customer exists?", "expression": { "language": "spel", @@ -102,80 +94,20 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 720 + "x": 180, + "y": 540 } }, "type": "Filter" }, { "defaultNext": [ - { - "id": "send for audit", - "ref": { - "typ": "kafka", - "parameters": [ - { - "name": "Topic", - "expression": { - "language": "spel", - "expression": "'processedEvents'" - } - }, - { - "name": "Schema version", - "expression": { - "language": "spel", - "expression": "'latest'" - } - }, - { - "name": "Key", - "expression": { - "language": "spel", - "expression": "" - } - }, - { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" - } - }, - { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" - } - }, - { - "name": "Value", - "expression": { - "language": "spel", - "expression": "#input" - } - } - ] - }, - "endResult": null, - "isDisabled": null, - "additionalFields": { - "description": null, - "layoutData": { - "x": 540, - "y": 1080 - } - }, - "type": "Sink" - } ], "nexts": [ { "expression": { "language": "spel", - "expression": "#category == \"STANDARD\"" + "expression": "#customerData.category == \"STANDARD\"" }, "nodes": [ { @@ -218,8 +150,76 @@ "additionalFields": { "description": null, "layoutData": { - "x": 180, - "y": 1080 + "x": 0, + "y": 900 + } + }, + "type": "Sink" + } + ] + }, + { + "expression": { + "language": "spel", + "expression": "true" + }, + "nodes": [ + { + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ + { + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" + } + }, + { + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" + } + }, + { + "name": "Key", + "expression": { + "language": "spel", + "expression": "" + } + }, + { + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" + } + }, + { + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" + } + }, + { + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" + } + } + ] + }, + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 900 } }, "type": "Sink" @@ -228,20 +228,16 @@ } ], "id": "category", - "expression": { - "language": "spel", - "expression": "#customerData.category" - }, - "exprVal": "category", "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 900 + "x": 180, + "y": 720 } }, "type": "Switch" } ], - "additionalBranches": [] -} + "additionalBranches": [ + ] +} \ No newline at end of file diff --git a/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherLite.json b/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherLite.json index 995abfa5..3111f5fc 100644 --- a/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherLite.json +++ b/k8s-helm/scenarios/DetectLargeTransactionsWithEnricherLite.json @@ -1,20 +1,13 @@ { "metaData": { "id": "DetectLargeTransactions", - "typeSpecificData": { - "parallelism": 2, - "type": "LiteStreamMetaData" - }, - "isSubprocess": false, "additionalFields": { "description": null, - "groups": [], - "properties": {} - }, - "subprocessVersions": {} - }, - "exceptionHandlerRef": { - "parameters": [] + "properties": { + "parallelism": "2" + }, + "metaDataType": "LiteStreamMetaData" + } }, "nodes": [ { @@ -48,7 +41,8 @@ "type": "Source" }, { - "nextFalse": [], + "nextFalse": [ + ], "id": "only large ones", "expression": { "language": "spel", @@ -58,8 +52,8 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 360 + "x": 180, + "y": 180 } }, "type": "Filter" @@ -82,80 +76,20 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 540 + "x": 180, + "y": 360 } }, "type": "Enricher" }, { "defaultNext": [ - { - "id": "send for audit", - "ref": { - "typ": "kafka", - "parameters": [ - { - "name": "Topic", - "expression": { - "language": "spel", - "expression": "'processedEvents'" - } - }, - { - "name": "Schema version", - "expression": { - "language": "spel", - "expression": "'latest'" - } - }, - { - "name": "Key", - "expression": { - "language": "spel", - "expression": "" - } - }, - { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "true" - } - }, - { - "name" : "Value validation mode", - "expression" : { - "language" : "spel", - "expression" : "'strict'" - } - }, - { - "name": "Value", - "expression": { - "language": "spel", - "expression": "#input" - } - } - ] - }, - "endResult": null, - "isDisabled": null, - "additionalFields": { - "description": null, - "layoutData": { - "x": 180, - "y": 900 - } - }, - "type": "Sink" - } ], "nexts": [ { "expression": { "language": "spel", - "expression": "#category == \"STANDARD\"" + "expression": "#customerData.category == \"STANDARD\"" }, "nodes": [ { @@ -198,8 +132,76 @@ "additionalFields": { "description": null, "layoutData": { - "x": 540, - "y": 900 + "x": 0, + "y": 720 + } + }, + "type": "Sink" + } + ] + }, + { + "expression": { + "language": "spel", + "expression": "true" + }, + "nodes": [ + { + "id": "send for audit", + "ref": { + "typ": "kafka", + "parameters": [ + { + "name": "Topic", + "expression": { + "language": "spel", + "expression": "'processedEvents'" + } + }, + { + "name": "Schema version", + "expression": { + "language": "spel", + "expression": "'latest'" + } + }, + { + "name": "Key", + "expression": { + "language": "spel", + "expression": "" + } + }, + { + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "true" + } + }, + { + "name": "Value validation mode", + "expression": { + "language": "spel", + "expression": "'strict'" + } + }, + { + "name": "Value", + "expression": { + "language": "spel", + "expression": "#input" + } + } + ] + }, + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 720 } }, "type": "Sink" @@ -208,20 +210,16 @@ } ], "id": "category", - "expression": { - "language": "spel", - "expression": "#customerData.category" - }, - "exprVal": "category", "additionalFields": { "description": null, "layoutData": { - "x": 360, - "y": 720 + "x": 180, + "y": 540 } }, "type": "Switch" } ], - "additionalBranches": [] -} + "additionalBranches": [ + ] +} \ No newline at end of file diff --git a/k8s-helm/scenarios/LoanRequest.json b/k8s-helm/scenarios/LoanRequest.json index 975b3ecc..94b5e24e 100644 --- a/k8s-helm/scenarios/LoanRequest.json +++ b/k8s-helm/scenarios/LoanRequest.json @@ -1,18 +1,14 @@ { "metaData": { "id": "LoanRequest", - "typeSpecificData": { - "slug": "loan", - "type": "RequestResponseMetaData" - }, "additionalFields": { "description": null, "properties": { "inputSchema": "{\n \"type\": \"object\",\n \"properties\": {\n \"customerId\": {\n \"type\": \"string\"\n },\n \"location\": {\n \"type\": \"object\",\n \"properties\": {\n \"city\": {\n \"type\": \"string\"\n },\n \"street\": {\n \"type\": \"string\"\n }\n }\n },\n \"requestType\": {\n \"type\": \"string\"\n },\n \"requestedAmount\": {\n \"type\": \"number\"\n }\n },\n \"required\": [\"customerId\", \"location\", \"requestType\", \"requestedAmount\"],\n \"additionalProperties\": false\n}", - "outputSchema": "{\n \"type\": \"object\",\n \"properties\": {\n \"acceptedAmount\": {\n \"type\": \"number\",\n \"description\": \"Accepted amount\"\n },\n \"message\": {\n \"type\": \"string\",\n \"description\": \"Additional message\"\n }\n },\n \"required\": [\"acceptedAmount\", \"message\"],\n \"additionalProperties\": false\n}" - } - }, - "subprocessVersions": { + "outputSchema": "{\n \"type\": \"object\",\n \"properties\": {\n \"acceptedAmount\": {\n \"type\": \"number\",\n \"description\": \"Accepted amount\"\n },\n \"message\": {\n \"type\": \"string\",\n \"description\": \"Additional message\"\n }\n },\n \"required\": [\"acceptedAmount\", \"message\"],\n \"additionalProperties\": false\n}", + "slug": "loan" + }, + "metaDataType": "RequestResponseMetaData" } }, "nodes": [ @@ -20,24 +16,26 @@ "id": "request", "ref": { "typ": "request", - "parameters": [] + "parameters": [ + ] }, "additionalFields": { "description": null, "layoutData": { - "x": 540, + "x": 360, "y": 0 } }, "type": "Source" }, { - "defaultNext": [], + "defaultNext": [ + ], "nexts": [ { "expression": { "language": "spel", - "expression": "#type == 'loan'" + "expression": "#input.requestType == 'loan'" }, "nodes": [ { @@ -66,7 +64,7 @@ "additionalFields": { "description": null, "layoutData": { - "x": 900, + "x": 0, "y": 360 } }, @@ -77,16 +75,17 @@ { "expression": { "language": "spel", - "expression": "#type == 'mortgage'" + "expression": "#input.requestType == 'mortgage'" }, "nodes": [ { - "defaultNext": [], + "defaultNext": [ + ], "nexts": [ { "expression": { "language": "spel", - "expression": "#city == 'Warszawa'" + "expression": "#input.location.city == 'Warszawa'" }, "nodes": [ { @@ -115,7 +114,7 @@ "additionalFields": { "description": null, "layoutData": { - "x": 360, + "x": 180, "y": 540 } }, @@ -162,7 +161,7 @@ "additionalFields": { "description": null, "layoutData": { - "x": 0, + "x": 540, "y": 540 } }, @@ -172,15 +171,10 @@ } ], "id": "switch", - "expression": { - "language": "spel", - "expression": "#input.location.city" - }, - "exprVal": "city", "additionalFields": { "description": null, "layoutData": { - "x": 180, + "x": 360, "y": 360 } }, @@ -220,7 +214,7 @@ "additionalFields": { "description": null, "layoutData": { - "x": 540, + "x": 720, "y": 360 } }, @@ -230,20 +224,16 @@ } ], "id": "loan type", - "expression": { - "language": "spel", - "expression": "#input.requestType" - }, - "exprVal": "type", "additionalFields": { "description": null, "layoutData": { - "x": 540, + "x": 360, "y": 180 } }, "type": "Switch" } ], - "additionalBranches": [] + "additionalBranches": [ + ] } \ No newline at end of file diff --git a/k8s-helm/scenarios/LoanRequestWithEnrichers.json b/k8s-helm/scenarios/LoanRequestWithEnrichers.json index 4b49ac31..fc856ebe 100644 --- a/k8s-helm/scenarios/LoanRequestWithEnrichers.json +++ b/k8s-helm/scenarios/LoanRequestWithEnrichers.json @@ -1,278 +1,263 @@ { - "metaData" : { - "id" : "LoanRequest", - "typeSpecificData" : { - "slug" : "loan", - "type" : "RequestResponseMetaData" - }, - "additionalFields" : { - "description" : null, - "properties" : { - "inputSchema" : "{\n \"properties\": {\n \"customerId\": {\n \"type\": \"string\"\n },\n \"location\": {\n \"properties\": {\n \"city\": {\n \"type\": \"string\"\n },\n \"street\": {\n \"type\": \"string\"\n }\n }\n },\n \"requestType\": {\n \"type\": \"string\"\n },\n \"requestedAmount\": {\n \"type\": \"number\"\n }\n },\n \"required\": [\"customerId\", \"location\", \"requestType\", \"requestedAmount\"],\n \"additionalProperties\": false\n}", - "outputSchema" : "{\n \"properties\": {\n \"acceptedAmount\": {\n \"type\": \"number\",\n \"description\": \"Accepted amount\"\n },\n \"message\": {\n \"type\": \"string\",\n \"description\": \"Additional message\"\n }\n },\n \"required\": [\"acceptedAmount\", \"message\"],\n \"additionalProperties\": false\n}" - } - }, - "subprocessVersions" : { - + "metaData": { + "id": "LoanRequest", + "additionalFields": { + "description": null, + "properties": { + "inputSchema": "{\n \"type\": \"object\",\n \"properties\": {\n \"customerId\": {\n \"type\": \"string\"\n },\n \"location\": {\n \"properties\": {\n \"city\": {\n \"type\": \"string\"\n },\n \"street\": {\n \"type\": \"string\"\n }\n }\n },\n \"requestType\": {\n \"type\": \"string\"\n },\n \"requestedAmount\": {\n \"type\": \"number\"\n },\n \"category\": {\n \"type\": \"string\"\n }\n },\n \"required\": [\"customerId\", \"location\", \"requestType\", \"requestedAmount\"],\n \"additionalProperties\": false\n}", + "outputSchema": "{\n \"type\": \"object\",\n \"properties\": {\n \"acceptedAmount\": {\n \"type\": \"number\",\n \"description\": \"Accepted amount\"\n },\n \"message\": {\n \"type\": \"string\",\n \"description\": \"Additional message\"\n }\n },\n \"required\": [\"acceptedAmount\", \"message\"],\n \"additionalProperties\": false\n}", + "slug": "loan" + }, + "metaDataType": "RequestResponseMetaData" } }, - "nodes" : [ + "nodes": [ { - "id" : "request", - "ref" : { - "typ" : "request", - "parameters" : [ + "id": "request", + "ref": { + "typ": "request", + "parameters": [ ] }, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 0 + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 0 } }, - "type" : "Source" + "type": "Source" }, { - "id" : "getCustomer", - "service" : { - "id" : "getCustomer", - "parameters" : [ + "id": "getCustomer", + "service": { + "id": "getCustomer", + "parameters": [ { - "name" : "customer_id", - "expression" : { - "language" : "spel", - "expression" : "#input.customerId" + "name": "customer_id", + "expression": { + "language": "spel", + "expression": "#CONV.toNumber(#input.customerId).longValue" } } ] }, - "output" : "customer", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 180 + "output": "customer", + "additionalFields": { + "description": null, + "layoutData": { + "x": 180, + "y": 179 } }, - "type" : "Enricher" + "type": "Enricher" }, { - "defaultNext" : [ + "defaultNext": [ ], - "nexts" : [ + "nexts": [ { - "expression" : { - "language" : "spel", - "expression" : "{'GOLD', 'PLATINUM'}.contains(#category)" + "expression": { + "language": "spel", + "expression": "#input.category == 'GOLD' || #input.category == 'PLATINUM'" }, - "nodes" : [ + "nodes": [ { - "id" : "VIP", - "ref" : { - "typ" : "response", - "parameters" : [ + "id": "VIP", + "ref": { + "typ": "response", + "parameters": [ { - "name" : "acceptedAmount", - "expression" : { - "language" : "spel", - "expression" : "#input.requestedAmount" + "name": "acceptedAmount", + "expression": { + "language": "spel", + "expression": "#input.requestedAmount" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'For VIP everything they want'" + "name": "message", + "expression": { + "language": "spel", + "expression": "'For VIP everything they want'" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 720, - "y" : 540 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 540 } }, - "type" : "Sink" + "type": "Sink" } ] }, { - "expression" : { - "language" : "spel", - "expression" : "true" + "expression": { + "language": "spel", + "expression": "true" }, - "nodes" : [ + "nodes": [ { - "defaultNext" : [ + "defaultNext": [ ], - "nexts" : [ + "nexts": [ { - "expression" : { - "language" : "spel", - "expression" : "#type == 'loan'" + "expression": { + "language": "spel", + "expression": "#input.requestType == 'loan'" }, - "nodes" : [ + "nodes": [ { - "id" : "loan response", - "ref" : { - "typ" : "response", - "parameters" : [ + "id": "loan response", + "ref": { + "typ": "response", + "parameters": [ { - "name" : "acceptedAmount", - "expression" : { - "language" : "spel", - "expression" : "#NUMERIC.min(50, #input.requestedAmount)" + "name": "acceptedAmount", + "expression": { + "language": "spel", + "expression": "#NUMERIC.min(50, #input.requestedAmount)" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'only small amount available'" + "name": "message", + "expression": { + "language": "spel", + "expression": "'only small amount available'" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 720, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 0, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] }, { - "expression" : { - "language" : "spel", - "expression" : "#type == 'mortgage'" + "expression": { + "language": "spel", + "expression": "#input.requestType == 'mortgage'" }, - "nodes" : [ + "nodes": [ { - "id" : "mortgage response", - "ref" : { - "typ" : "response", - "parameters" : [ + "id": "mortgage response", + "ref": { + "typ": "response", + "parameters": [ { - "name" : "Raw editor", - "expression" : { - "language" : "spel", - "expression" : "false" + "name": "Raw editor", + "expression": { + "language": "spel", + "expression": "false" } }, { - "name" : "acceptedAmount", - "expression" : { - "language" : "spel", - "expression" : "1000" + "name": "acceptedAmount", + "expression": { + "language": "spel", + "expression": "1000" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Large sum for mortgage'" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Large sum for mortgage'" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 0, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] }, { - "expression" : { - "language" : "spel", - "expression" : "true" + "expression": { + "language": "spel", + "expression": "true" }, - "nodes" : [ + "nodes": [ { - "id" : "unknown", - "ref" : { - "typ" : "response", - "parameters" : [ + "id": "unknown", + "ref": { + "typ": "response", + "parameters": [ { - "name" : "acceptedAmount", - "expression" : { - "language" : "spel", - "expression" : "0" + "name": "acceptedAmount", + "expression": { + "language": "spel", + "expression": "0" } }, { - "name" : "message", - "expression" : { - "language" : "spel", - "expression" : "'Unknown loan type'" + "name": "message", + "expression": { + "language": "spel", + "expression": "'Unknown loan type'" } } ] }, - "endResult" : null, - "isDisabled" : null, - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 720 + "endResult": null, + "isDisabled": null, + "additionalFields": { + "description": null, + "layoutData": { + "x": 720, + "y": 720 } }, - "type" : "Sink" + "type": "Sink" } ] } ], - "id" : "loan type", - "expression" : { - "language" : "spel", - "expression" : "#input.requestType" - }, - "exprVal" : "type", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 360, - "y" : 540 + "id": "loan type", + "additionalFields": { + "description": null, + "layoutData": { + "x": 360, + "y": 540 } }, - "type" : "Switch" + "type": "Switch" } ] } ], - "id" : "category", - "expression" : { - "language" : "spel", - "expression" : "#customer?.category" - }, - "exprVal" : "category", - "additionalFields" : { - "description" : null, - "layoutData" : { - "x" : 540, - "y" : 360 + "id": "category", + "additionalFields": { + "description": null, + "layoutData": { + "x": 181, + "y": 360 } }, - "type" : "Switch" + "type": "Switch" } ], - "additionalBranches" : [ + "additionalBranches": [ ] } \ No newline at end of file