pipeline object — REQUIREDsources object[] — REQUIREDid string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | type string — REQUIREDPossible values: [businessObject, reference] | businessObjectId string | referenceId string | timeRange objectfield string — REQUIRED | relative objectdirection string — REQUIREDPossible values: [past, future] | value number — REQUIREDPossible values: 1 ≤ value | unit string — REQUIREDPossible values: [seconds, minutes, hours, days, weeks, months] |
| absolute objectstart string — REQUIRED | end string — REQUIRED |
|
| filters object[]field string — REQUIRED | operator string — REQUIREDPossible values: [=, !=, >, <, >=, <=, in, notIn, like, between, notBetween, isNull, isNotNull, contains, notContains, startsWith, endsWith, isEmpty, isNotEmpty, minLength, maxLength] | value object |
| fields object[] — REQUIREDid stringPubNub-generated unique ID for the field. Required when creating metrics and decisions. Used as measureId, dimensionIds, or inputFields[].sourceId. | name string — REQUIREDPossible values: 1 ≤ length ≤ 50 Field name (1-50 characters). | source stringPossible values: [JSONPATH, DERIVED] Field source type: JSONPATH or DERIVED. | jsonPath stringPossible values: length ≤ 200 JSON path expression for extracting data (max 200 chars). Required when source is JSONPATH and isActive is true. | jsonFieldType stringPossible values: [TEXT, TEXT_LONG, NUMERIC, TIMESTAMP, DURATION_SECONDS] Field data type: TEXT, TEXT_LONG (character limit is 1000, limited to 5 per Business Object), NUMERIC, or TIMESTAMP. Required when source is JSONPATH. | isKeyset booleanBoolean flag indicating if this field is part of the keyset. Informational only. | derivation objectDerivation configuration. Required when source is DERIVED. operation string — REQUIREDPossible values: [TIME_DIFF] Derivation operation type. Currently only TIME_DIFF is supported. | params object — REQUIREDParameters for the derivation calculation. startSource string — REQUIREDPossible values: [DATA_FIELD, PUBLISH_TIMETOKEN] Start source for time difference calculation: DATA_FIELD or PUBLISH_TIMETOKEN. DATA_FIELD accepts only TIMESTAMP data type. | startFieldIndex numberIndex or position of the start timestamp data field in your array. Not required if startSource is PUBLISH_TIMETOKEN. | endSource string — REQUIREDPossible values: [DATA_FIELD, PUBLISH_TIMETOKEN] End source for time difference calculation: DATA_FIELD or PUBLISH_TIMETOKEN. | endFieldIndex numberIndex or position of the end timestamp data field in your array. Not required if endSource is PUBLISH_TIMETOKEN. |
|
|
|
| transforms object[]id string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | type string — REQUIREDPossible values: [aggregate, window, join, dedupe, calculate, unnest, filter_join] | input string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | aggregate objectgroupBy string[] — REQUIRED | aggregations object[] — REQUIREDfunction string — REQUIREDPossible values: [sum, count, avg, min, max, countDistinct, stddev, percentile, groupArray, groupUniqArray, any] | field string — REQUIRED | alias string — REQUIRED | parameter number |
| collectFields object[]field string — REQUIRED | function string — REQUIREDPossible values: [groupArray, groupUniqArray] | alias string — REQUIRED | limit numberPossible values: 1 ≤ value | orderBy objectfield string — REQUIRED | direction stringPossible values: [ASC, DESC] |
|
|
| window objectfunctions object[] — REQUIREDfunction string — REQUIREDPossible values: [rowNumber, rank, denseRank, percentRank, lag, lead, firstValue, lastValue, sumOver, avgOver] | partitionBy string[] — REQUIRED | orderBy object[] — REQUIREDfield string — REQUIRED | direction stringPossible values: [ASC, DESC] |
| alias string — REQUIRED | offset number |
|
| join objectwith string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | type string — REQUIREDPossible values: [inner, left, right, full] | on object[] — REQUIREDleft string — REQUIRED | operator string — REQUIREDPossible values: [=, !=, >, <, >=, <=] | right string — REQUIRED |
|
| dedupe objectpartitionBy string[] — REQUIRED | orderBy object[] — REQUIREDfield string — REQUIRED | direction stringPossible values: [ASC, DESC] |
| keep string — REQUIREDPossible values: [first, last] |
| calculate objectexpressions object[] — REQUIREDexpression object — REQUIRED | alias string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | type string — REQUIREDPossible values: [dimension, measure] |
|
| unnest objectarrayField string — REQUIRED | alias string |
| filter_join objectcriteriaAggregate object — REQUIREDgroupBy string[] — REQUIRED | aggregations object[] — REQUIREDfunction string — REQUIREDPossible values: [sum, count, avg, min, max, countDistinct, stddev, percentile, groupArray, groupUniqArray, any] | field string — REQUIRED | alias string — REQUIRED | parameter number |
| collectFields object[]field string — REQUIRED | function string — REQUIREDPossible values: [groupArray, groupUniqArray] | alias string — REQUIRED | limit numberPossible values: 1 ≤ value | orderBy objectfield string — REQUIRED | direction stringPossible values: [ASC, DESC] |
|
|
| criteriaFilters object[]field string — REQUIRED | operator string — REQUIREDPossible values: [=, !=, >, <, >=, <=, in, notIn, like, between, notBetween, isNull, isNotNull, contains, notContains, startsWith, endsWith, isEmpty, isNotEmpty, minLength, maxLength] | value object |
| joinFields string[] — REQUIRED |
| filters object[]field string — REQUIRED | operator string — REQUIREDPossible values: [=, !=, >, <, >=, <=, in, notIn, like, between, notBetween, isNull, isNotNull, contains, notContains, startsWith, endsWith, isEmpty, isNotEmpty, minLength, maxLength] | value object |
|
| output object — REQUIREDfrom string — REQUIREDPossible values: length ≤ 128, Value must match regular expression IDENTIFIER_PATTERN | select object[] — REQUIREDfield string — REQUIRED | alias string | id string |
| orderBy object[]field string — REQUIRED | direction stringPossible values: [ASC, DESC] |
| limit numberPossible values: 1 ≤ value ≤ 500 | offset number |
|
|