Compute service#
The Compute Service provides the ability to compute the output of compute graphs.
OpenAPI file: ComputeService.json
Endpoints#
Compute#
POST /compute/v2/compute
Computes the output of the compute graph specified by a ComputeNodeRequest.
Body
nodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Fields of
SummarizeRangesinputRangeSeriesrequired
maxRangesintegerThe maximum number of ranges to return in the response. If more ranges are found, a RangesSummary will be returned. Defaults to 2000 if not specified.
Set
typeto"series".seriesSummarizeSeries
Fields of
SummarizeSeriesinputSeriesrequired
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY.
numericOutputFieldsarray ofNumericOutputFielddeprecatedThe fields to output from the summarization. Applies only to Arrow format numeric series. Deprecated: Use numericOutputFieldsV2 instead.
numericAggregationsmap of string toNumericAggregationOperatorAdditional numeric aggregations per decimation bucket (e.g. percentiles). Map key is the name of the column in the result.
numericOutputFieldsV2array ofNumericOutputFieldV2Numeric bucket output fields to return. Applies only to Arrow format numeric series. Defaults to MEAN when no numeric output selector is specified. Mutually exclusive with numericOutputFields and numericAggregations.
resolutioninteger (int64) deprecatedResolution of the output series specifying time interval between decimated points, in nanoseconds. Deprecated: Use summarizationStrategy instead.
bucketsinteger deprecatedNumber of points to generate in the output series. Deprecated: Use summarizationStrategy instead.
summarizationStrategySummarizationStrategyThe strategy to use when summarizing the series.
Set
typeto"value".valueSelectValue
Set
typeto"firstPoint".firstPointSeries
Set
typeto"firstValuePoint".firstValuePointSeries
Set
typeto"firstRange".firstRangeRangeSeries
Set
typeto"lastPoint".lastPointSeries
Set
typeto"lastValuePoint".lastValuePointSeries
Set
typeto"lastRange".lastRangeRangeSeries
Set
typeto"nthRange".nthRangeNthRange
Set
typeto"cartesian".cartesianSummarizeCartesian
Fields of
SummarizeCartesianinputCartesianrequired
boundsCartesianBounds
summarizationStrategyScatterSummarizationStrategyThe summarization strategy to use when there are more than
maxPoints. Defaults to spatial.maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesianPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Fields of
SummarizeCartesian3dinputCartesian3drequired
boundsCartesian3dBounds
maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesian3dPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
summarizationStrategyScatterSummarizationStrategyThe strategy to use when summarizing the series. Only spatial decimation is supported.
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"fft".fftFft
Set
typeto"periodogram".periodogramPeriodogram
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Fields of
SpectrograminputNumericSeriesrequiredA numeric series from a single data source. Series grouped by tags are not supported.
stftOptionsStftOptionsWindow and FFT parameters.
quantitySpectrogramQuantityWhat each cell measures. Defaults to PSD.
magnitudeScalingMagnitudeScalingHow each cell’s value is scaled. Defaults to decibels: 10·log10 of the PSD, or 20·log10 of the amplitude.
bucketingSpectrogramBucketingThe output’s time and frequency buckets, frequency band and reductions.
Set
typeto"histogram".histogramHistogram
Set
typeto"numeric".numericNumericHistogramNode
Set
typeto"enum".enumEnumHistogramNode
Set
typeto"curveV2".curveV2CurveFitV2
Fields of
CurveFitV2targetCurveFitTargetrequiredTarget to fit the equation against.
fitRangeCurveFitRangerequiredThe range to fit the curve over
curveToFitCurveFitV2DetailsrequiredThe curve type to fit against the target series.
Set
typeto"curve".curveCurveFit
Fields of
CurveFitcurveFitPlotTypeCurveFitPlotTyperequired
curveFitDetailsCurveFitDetailsrequired
curveFitOptionsCurveFitOptionsrequired
Set
typeto"multivariate".multivariateSummarizeMultivariate
Fields of
SummarizeMultivariateinputsarray ofMultivariateInputList of input series to temporally align at the raw point level, then bucket the aligned tuples together. The series with the largest tag group acts as the “driver” that determines which raw timestamps are included in the alignment. All subsequent series are aligned to the driver’s raw timestamps using the interpolation configuration. After alignment, the resulting (x, y, z, …) tuples are bucketed into time windows and aggregated.
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY (JSON).
bucketCountintegerThe number of buckets to return in the response. Maximum is 10,000. Defaults to 1,000 if not specified.
interpolationConfigurationInterpolationConfigurationControls how the N input series are aligned at the raw point level when producing multivariate buckets. When present, the server may fill forward a series value from the most recent prior raw point (bounded by the interpolation radius). This alignment happens BEFORE bucketing, ensuring that aggregated values in each bucket are computed from temporally aligned raw tuples. When absent, the default interpolation configuration is used.
startTimestamprequiredThe start of the time range (inclusive).
Fields of
Timestampsecondsinteger (int64) required
nanosinteger (int64) required
endTimestamprequiredThe end of the time range (inclusive).
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
Set
typeto"double".doublenumber
Set
typeto"computeNode".computeNodeComputeNodeWithContext
Set
typeto"duration".durationrun.api.Duration
Set
typeto"integer".integerinteger
Set
typeto"channel".channelChannelSeriesdeprecatedDeprecated: use series instead.
Set
typeto"derived".derivedDerivedSeries
Set
typeto"series".seriesSeriesVariable
Set
typeto"string".stringstring
Set
typeto"stringSet".stringSetarray of string
Set
typeto"timestamp".timestampTimestamp
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
Fields of
FunctionVariablesvariablesmap ofVariableNametoVariableValue
subFunctionVariablesmap ofFunctionReferencetoFunctionVariables
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.Set
typeto"asset".assetAssetSingle asset. Expands to one grouping per data scope on the asset. Groupings are tagged by
assetRidanddataScopeso callers can safely compose multiple assets withcombine.
Set
typeto"run".runRunSingle run. Expands to one grouping per data source attached to the run: asset-typed sources contribute one grouping per data scope on the asset; dataset-typed sources contribute one grouping per dataset. Groupings are tagged by
runRidanddataScope; asset-typed groupings additionally carryassetRidso callers can safely compose multiple runs withcombine.
Set
typeto"saved".savedSavedDataset
Set
typeto"search".searchSearchDataset
Set
typeto"combine".combineCombinedDataset
Set
typeto"tag".tagTaggedDataset
Set
typeto"filter".filterFilteredDataset
Set
typeto"timeShift".timeShiftTimeShiftedDataset
Set
typeto"alignByAnchor".alignByAnchorAnchorAlignedDataset
Set
typeto"withSeries".withSeriesWithSeriesDataset
Set
typeto"dropSeries".dropSeriesDropSeriesDataset
Set
typeto"reference".referenceDatasetReference
Set
typeto"withDimensions".withDimensionsDimensionsDataset
defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
Set
typeto"forwardFill".forwardFillForwardFill
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
Set
typeto"driverSeries".driverSeriesDriverSeries
Set
typeto"union".unionUnion
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
sourceRidstring (RID)Optional RID identifying the resource that initiated this query (e.g. workbook/notebook RID, checklist RID, dataset RID). Used for observability only — trusted as-is, no permission checks are performed on this value.
requestIdstring (UUID)Optional UUID to provide as a handle to selectively cancel the execution of this compute request.
Response
A ComputeNodeResponse union.
Set type to "range".
rangearray ofRange
Fields of
RangestartTimestamp
Fields of
Timestampsecondsinteger (int64)
nanosinteger (int64)
endTimestamp
valueRangeValue
Set
typeto"double".doublenumber
Set
typeto"aggregation".aggregationRangeAggregation
Fields of
RangeAggregationaveragenumber
minnumber
maxnumber
standardDeviationnumber
countnumber
sumnumber
rootMeanSquarenumber
Set
typeto"noPointsInRange".noPointsInRangeEmpty
Set type to "rangesSummary".
rangesSummaryRangesSummary
Fields of
RangesSummaryrangesSummaryarray ofRangeSummary
Fields of
RangeSummaryrangeRangeThe range representing the minimum start and maximum end times of the ranges.
subRangeCountintegerThe number of ranges found within this time range.
Set type to "rangeValue".
rangeValueRange
Set type to "numeric".
numericNumericPlot
Fields of
NumericPlottimestampsarray ofTimestamp
valuesarray of number
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.Set
typeto"timestampAndId".timestampAndIdTimestampAndId
Fields of
TimestampAndIdtimestampTimestamp
idstring (UUID)
Set type to "bucketedNumeric".
bucketedNumericBucketedNumericPlot
Fields of
BucketedNumericPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofNumericBucket
Fields of
NumericBucketminnumber
maxnumber
meannumber
countinteger (int64)
variancenumberThe population variance of the bucket. If the bucket has only one value, this will be 0.
firstPointNumericPoint
Fields of
NumericPointtimestampTimestamp
valuenumber
lastPointNumericPointWill be empty if the bucket only has a single point.
aggregationsmap of string to numberAdditional per-bucket aggregations that have no dedicated field above, keyed by the output column name requested via
numericAggregationsornumericOutputFieldsV2(e.g.sum,standardDeviation,rootMeanSquare,p50). Empty when no additional aggregations were requested.
Set type to "numericPoint".
numericPointNumericPoint
Set type to "singlePoint".
singlePointSinglePoint
Fields of
SinglePointtimestampTimestamp
valueValue
Set
typeto"stringValue".stringValuestring
Set
typeto"float64Value".float64Valuenumber
Set
typeto"int64Value".int64Valuestring
Set
typeto"arrayValue".arrayValuearray ofValue
Set
typeto"structValue".structValueany JSON valueA JSON representation of the struct
precisionLossbooleanReturns true if the result required downcasting to a type with less precision, for example if the input series was Int64 and the result is a Float64.
Set type to "arrowNumeric".
arrowNumericArrowPlot
Fields of
ArrowPlotarrowBinarystring (base64)The raw binary containing an Arrow IPC stream.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set type to "arrowBucketedNumeric".
arrowBucketedNumericArrowPlot
Set type to "enum".
enumEnumPlot
Fields of
EnumPlottimestampsarray ofTimestamp
valuesarray of integer
categoriesarray of string
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set type to "enumPoint".
Set type to "bucketedEnum".
bucketedEnumBucketedEnumPlot
Fields of
BucketedEnumPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofEnumBucket
Fields of
EnumBuckethistogrammap of string to integer (int64)The map of values within the bucket to their frequency.
firstPointCompactEnumPoint
Fields of
CompactEnumPointtimestampTimestamp
valueinteger
lastPointCompactEnumPointWill be empty if the bucket only has a single point.
categoriesarray of string
Set type to "arrowEnum".
arrowEnumArrowPlot
Set type to "arrowBucketedEnum".
arrowBucketedEnumArrowPlot
Set type to "pagedLog".
pagedLogPagedLogPlot
Fields of
PagedLogPlottimestampsarray ofTimestamp
valuesarray ofLogValue
Fields of
LogValuemessagestring
argsmap of string to string
idstring (UUID)
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set type to "arrowLog".
arrowLogArrowPlot
Set type to "cartesian".
cartesianCartesianPlot
Fields of
CartesianPlottimestampsarray ofTimestamp
xValuesarray of number
yValuesarray of number
Set type to "bucketedCartesian".
bucketedCartesianBucketedCartesianPlot
Fields of
BucketedCartesianPlotbucketsarray ofCartesianBucket
Set type to "bucketedCartesian3d".
bucketedCartesian3dBucketedCartesian3dPlot
Fields of
BucketedCartesian3dPlotbucketsarray ofCartesian3dBucket
Fields of
Cartesian3dBucketminXnumber deprecatedDeprecated: Switching to point-based min/maxes
maxXnumber deprecatedDeprecated: Switching to point-based min/maxes
meanXnumber
minYnumber deprecatedDeprecated: Switching to point-based min/maxes
maxYnumber deprecatedDeprecated: Switching to point-based min/maxes
meanYnumber
minZnumber deprecatedDeprecated: Switching to point-based min/maxes
maxZnumber deprecatedDeprecated: Switching to point-based min/maxes
meanZnumber
minXPointPoint3d
Fields of
Point3dxnumber
ynumber
znumber
timestampTimestamp
maxXPointPoint3d
minYPointPoint3d
maxYPointPoint3d
minZPointPoint3d
maxZPointPoint3d
minTimestampTimestamp
maxTimestampTimestamp
countinteger (int64)
Set type to "frequencyDomain".
frequencyDomainFrequencyDomainPlot
Fields of
FrequencyDomainPlotfrequenciesarray of number
amplitudesarray of number
Set type to "frequencyDomainV2".
frequencyDomainV2FrequencyDomainPlotV2
Set
typeto"real".realFrequencyDomainPlot
Set
typeto"complex".complexFrequencyDomainPlotComplex
Fields of
FrequencyDomainPlotComplexfrequenciesarray of number
realarray of number
imaginaryarray of number
Set
typeto"magnitudeAndPhase".magnitudeAndPhaseFrequencyDomainPlotMagnitudeAndPhase
Fields of
FrequencyDomainPlotMagnitudeAndPhasefrequenciesarray of number
magnitudesarray of number
phasesarray of number
Set type to "spectrogram".
spectrogramSpectrogramPlot
Fields of
SpectrogramPlotfrequencyCentersarray of numberCenter frequency in Hz of each column.
frequencyEdgesarray of numberColumn boundaries in Hz, one more than
frequencyCenters: columncspansfrequencyEdges[c]tofrequencyEdges[c + 1]. Columns may differ in width.rowsarray ofSpectrogramRow
Set type to "bucketedFrequencyDomain".
bucketedFrequencyDomainBucketedFrequencyDomainPlot
Fields of
BucketedFrequencyDomainPlotbucketsarray ofFrequencyBucket
Fields of
FrequencyBucketfrequencyStartnumberThe start frequency of this bucket (inclusive).
frequencyEndnumberThe end frequency of this bucket (exclusive).
frequencyCenternumberThe center frequency of this bucket.
minAmplitudenumberThe minimum amplitude value in this bucket.
maxAmplitudenumberThe maximum amplitude value in this bucket.
meanAmplitudenumberThe mean amplitude value in this bucket.
countinteger (int64)The number of original frequency points that were aggregated into this bucket.
firstPointFrequencyPointThe first point (lowest frequency) in this bucket.
Fields of
FrequencyPointfrequencynumber
amplitudenumber
lastPointFrequencyPointThe last point (highest frequency) in this bucket. Will be empty if the bucket only has a single point.
Set type to "numericHistogram".
numericHistogramNumericHistogramPlot
Fields of
NumericHistogramPlotbucketsarray ofNumericHistogramBucket
Fields of
NumericHistogramBucketlowerBoundnumberThe lower bound of the bucket, inclusive
upperBoundnumberThe upper bound of the bucket, exclusive
countsByChannelmap ofVariableNametoHistogramChannelCount
Fields of
HistogramChannelCountcountinteger (int64)
bucketsmap ofVariableNametoHistogramChannelCountdeprecatedDeprecated: Use countsByChannel instead
Set type to "enumHistogram".
enumHistogramEnumHistogramPlot
Fields of
EnumHistogramPlotbucketsarray ofEnumHistogramBucket
Fields of
EnumHistogramBucketvaluestringThe value of the enum as a string
countsByChannelmap ofVariableNametoHistogramChannelCount
Set type to "curveFit".
curveFitCurveFitResultDeprecated: use
curveFitV2(CurveFitResultV2) instead. Returned only for deprecated CurveFit requests.Fields of
CurveFitResultr2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsDescription of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Fields of
ExponentialResultDetailsanumber
bnumber
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Fields of
LogarithmicResultDetailsanumber
bnumber
Set
typeto"polynomial".polynomialPolynomialResultDetails
Fields of
PolynomialResultDetailsaarray of number
Set
typeto"power".powerPowerResultDetails
Fields of
PowerResultDetailsanumber
bnumber
Set type to "curveFitV2".
curveFitV2CurveFitResultV2
Fields of
CurveFitResultV2r2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsV2Description of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Set
typeto"polynomial".polynomialPolynomialResultDetails
Set
typeto"power".powerPowerResultDetails
Set
typeto"custom".customCustomCurveResultDetails
Fields of
CustomCurveResultDetailsparametersmap of string to numberOptimized parameter values produced by the curve fit. Keys match the parameter names provided in the request.
convergedbooleanWhether the optimizer converged to a solution within its iteration limit. When false, the returned parameters are the best estimate found before the iteration cap was reached and did not satisfy the solver’s convergence tolerances.
iterationsintegerNumber of iterations the solver completed.
Set type to "grouped".
groupedGroupedComputeNodeResponses
Fields of
GroupedComputeNodeResponsesresponsesarray ofGroupedComputeNodeResponse
Fields of
GroupedComputeNodeResponsegroupingGrouping
Set
typeto"tagsWithValues".tagsWithValuesmap of string to stringA grouping identified by a specific instantiation of tag keys and values.
responseComputeNodeResponse
Set type to "array".
arrayArrowArrayPlot
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericArrayPlot
Fields of
BucketedNumericArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional numeric array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedEnum".bucketedEnumBucketedEnumArrayPlot
Fields of
BucketedEnumArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional enum array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set type to "bucketedStruct".
bucketedStructArrowPlot
Set type to "arrowStruct".
arrowStructArrowPlot
Set type to "fullResolution".
fullResolutionArrowPlot
Set type to "arrowBucketedMultivariate".
arrowBucketedMultivariateArrowPlot
Set type to "multivariate".
multivariateBucketedMultivariatePlot
Fields of
BucketedMultivariatePlotbucketsarray ofMultivariateBucket
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
}
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"type": "range",
"range": [
{
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"value": {
"type": "double",
"double": 1
}
}
]
}
Parameterized compute#
POST /compute/v2/compute/parameterized
Computes the output of the compute graph specified by a ParameterizedComputeNodeRequest. A parameterized compute request supports multiple values for a single variable, supplied by the ParameterizedContext. Results are returned in the same order of the request.
Body
nodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Fields of
SummarizeRangesinputRangeSeriesrequired
maxRangesintegerThe maximum number of ranges to return in the response. If more ranges are found, a RangesSummary will be returned. Defaults to 2000 if not specified.
Set
typeto"series".seriesSummarizeSeries
Fields of
SummarizeSeriesinputSeriesrequired
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY.
numericOutputFieldsarray ofNumericOutputFielddeprecatedThe fields to output from the summarization. Applies only to Arrow format numeric series. Deprecated: Use numericOutputFieldsV2 instead.
numericAggregationsmap of string toNumericAggregationOperatorAdditional numeric aggregations per decimation bucket (e.g. percentiles). Map key is the name of the column in the result.
numericOutputFieldsV2array ofNumericOutputFieldV2Numeric bucket output fields to return. Applies only to Arrow format numeric series. Defaults to MEAN when no numeric output selector is specified. Mutually exclusive with numericOutputFields and numericAggregations.
resolutioninteger (int64) deprecatedResolution of the output series specifying time interval between decimated points, in nanoseconds. Deprecated: Use summarizationStrategy instead.
bucketsinteger deprecatedNumber of points to generate in the output series. Deprecated: Use summarizationStrategy instead.
summarizationStrategySummarizationStrategyThe strategy to use when summarizing the series.
Set
typeto"value".valueSelectValue
Set
typeto"firstPoint".firstPointSeries
Set
typeto"firstValuePoint".firstValuePointSeries
Set
typeto"firstRange".firstRangeRangeSeries
Set
typeto"lastPoint".lastPointSeries
Set
typeto"lastValuePoint".lastValuePointSeries
Set
typeto"lastRange".lastRangeRangeSeries
Set
typeto"nthRange".nthRangeNthRange
Set
typeto"cartesian".cartesianSummarizeCartesian
Fields of
SummarizeCartesianinputCartesianrequired
boundsCartesianBounds
summarizationStrategyScatterSummarizationStrategyThe summarization strategy to use when there are more than
maxPoints. Defaults to spatial.maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesianPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Fields of
SummarizeCartesian3dinputCartesian3drequired
boundsCartesian3dBounds
maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesian3dPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
summarizationStrategyScatterSummarizationStrategyThe strategy to use when summarizing the series. Only spatial decimation is supported.
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"fft".fftFft
Set
typeto"periodogram".periodogramPeriodogram
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Fields of
SpectrograminputNumericSeriesrequiredA numeric series from a single data source. Series grouped by tags are not supported.
stftOptionsStftOptionsWindow and FFT parameters.
quantitySpectrogramQuantityWhat each cell measures. Defaults to PSD.
magnitudeScalingMagnitudeScalingHow each cell’s value is scaled. Defaults to decibels: 10·log10 of the PSD, or 20·log10 of the amplitude.
bucketingSpectrogramBucketingThe output’s time and frequency buckets, frequency band and reductions.
Set
typeto"histogram".histogramHistogram
Set
typeto"numeric".numericNumericHistogramNode
Set
typeto"enum".enumEnumHistogramNode
Set
typeto"curveV2".curveV2CurveFitV2
Fields of
CurveFitV2targetCurveFitTargetrequiredTarget to fit the equation against.
fitRangeCurveFitRangerequiredThe range to fit the curve over
curveToFitCurveFitV2DetailsrequiredThe curve type to fit against the target series.
Set
typeto"curve".curveCurveFit
Fields of
CurveFitcurveFitPlotTypeCurveFitPlotTyperequired
curveFitDetailsCurveFitDetailsrequired
curveFitOptionsCurveFitOptionsrequired
Set
typeto"multivariate".multivariateSummarizeMultivariate
Fields of
SummarizeMultivariateinputsarray ofMultivariateInputList of input series to temporally align at the raw point level, then bucket the aligned tuples together. The series with the largest tag group acts as the “driver” that determines which raw timestamps are included in the alignment. All subsequent series are aligned to the driver’s raw timestamps using the interpolation configuration. After alignment, the resulting (x, y, z, …) tuples are bucketed into time windows and aggregated.
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY (JSON).
bucketCountintegerThe number of buckets to return in the response. Maximum is 10,000. Defaults to 1,000 if not specified.
interpolationConfigurationInterpolationConfigurationControls how the N input series are aligned at the raw point level when producing multivariate buckets. When present, the server may fill forward a series value from the most recent prior raw point (bounded by the interpolation radius). This alignment happens BEFORE bucketing, ensuring that aggregated values in each bucket are computed from temporally aligned raw tuples. When absent, the default interpolation configuration is used.
startTimestamprequiredThe start of the time range (inclusive).
Fields of
Timestampsecondsinteger (int64) required
nanosinteger (int64) required
endTimestamprequiredThe end of the time range (inclusive).
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
Set
typeto"double".doublenumber
Set
typeto"computeNode".computeNodeComputeNodeWithContext
Set
typeto"duration".durationrun.api.Duration
Set
typeto"integer".integerinteger
Set
typeto"channel".channelChannelSeriesdeprecatedDeprecated: use series instead.
Set
typeto"derived".derivedDerivedSeries
Set
typeto"series".seriesSeriesVariable
Set
typeto"string".stringstring
Set
typeto"stringSet".stringSetarray of string
Set
typeto"timestamp".timestampTimestamp
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
Fields of
FunctionVariablesvariablesmap ofVariableNametoVariableValue
subFunctionVariablesmap ofFunctionReferencetoFunctionVariables
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.Set
typeto"asset".assetAssetSingle asset. Expands to one grouping per data scope on the asset. Groupings are tagged by
assetRidanddataScopeso callers can safely compose multiple assets withcombine.
Set
typeto"run".runRunSingle run. Expands to one grouping per data source attached to the run: asset-typed sources contribute one grouping per data scope on the asset; dataset-typed sources contribute one grouping per dataset. Groupings are tagged by
runRidanddataScope; asset-typed groupings additionally carryassetRidso callers can safely compose multiple runs withcombine.
Set
typeto"saved".savedSavedDataset
Set
typeto"search".searchSearchDataset
Set
typeto"combine".combineCombinedDataset
Set
typeto"tag".tagTaggedDataset
Set
typeto"filter".filterFilteredDataset
Set
typeto"timeShift".timeShiftTimeShiftedDataset
Set
typeto"alignByAnchor".alignByAnchorAnchorAlignedDataset
Set
typeto"withSeries".withSeriesWithSeriesDataset
Set
typeto"dropSeries".dropSeriesDropSeriesDataset
Set
typeto"reference".referenceDatasetReference
Set
typeto"withDimensions".withDimensionsDimensionsDataset
defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
Set
typeto"forwardFill".forwardFillForwardFill
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
Set
typeto"driverSeries".driverSeriesDriverSeries
Set
typeto"union".unionUnion
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
sourceRidstring (RID)Optional RID identifying the resource that initiated this query (e.g. workbook/notebook RID, checklist RID, dataset RID). Used for observability only — trusted as-is, no permission checks are performed on this value.
parameterizedContextParameterizedContextrequiredSpecifies how certain variables should be parameterized. If a variable name appears in both the context and the parameterized context, it will be treated as parameterized.
Fields of
ParameterizedContextparameterInputsarray ofParameterInputEach parameter input provides a satisfying set of values for the parameterized compute node.
Fields of
ParameterInputvariablesmap ofVariableNametoVariableValue
timeRangeRangeOverrides the start and end time of the compute request. If either the start or end are not present, we default back to the start/end specified in the request.
Response
resultsarray ofComputeNodeResult
Set
typeto"success".successComputeNodeResponse
Set
typeto"range".rangearray ofRange
Fields of
RangestartTimestamp
Fields of
Timestampsecondsinteger (int64)
nanosinteger (int64)
endTimestamp
valueRangeValue
Set
typeto"double".doublenumber
Set
typeto"aggregation".aggregationRangeAggregation
Fields of
RangeAggregationaveragenumber
minnumber
maxnumber
standardDeviationnumber
countnumber
sumnumber
rootMeanSquarenumber
Set
typeto"noPointsInRange".noPointsInRangeEmpty
Set
typeto"rangesSummary".rangesSummaryRangesSummary
Fields of
RangesSummaryrangesSummaryarray ofRangeSummary
Fields of
RangeSummaryrangeRangeThe range representing the minimum start and maximum end times of the ranges.
subRangeCountintegerThe number of ranges found within this time range.
Set
typeto"rangeValue".rangeValueRange
Set
typeto"numeric".numericNumericPlot
Fields of
NumericPlottimestampsarray ofTimestamp
valuesarray of number
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.Set
typeto"timestampAndId".timestampAndIdTimestampAndId
Fields of
TimestampAndIdtimestampTimestamp
idstring (UUID)
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericPlot
Fields of
BucketedNumericPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofNumericBucket
Fields of
NumericBucketminnumber
maxnumber
meannumber
countinteger (int64)
variancenumberThe population variance of the bucket. If the bucket has only one value, this will be 0.
firstPointNumericPoint
Fields of
NumericPointtimestampTimestamp
valuenumber
lastPointNumericPointWill be empty if the bucket only has a single point.
aggregationsmap of string to numberAdditional per-bucket aggregations that have no dedicated field above, keyed by the output column name requested via
numericAggregationsornumericOutputFieldsV2(e.g.sum,standardDeviation,rootMeanSquare,p50). Empty when no additional aggregations were requested.
Set
typeto"numericPoint".numericPointNumericPoint
Set
typeto"singlePoint".singlePointSinglePoint
Fields of
SinglePointtimestampTimestamp
valueValue
Set
typeto"stringValue".stringValuestring
Set
typeto"float64Value".float64Valuenumber
Set
typeto"int64Value".int64Valuestring
Set
typeto"arrayValue".arrayValuearray ofValue
Set
typeto"structValue".structValueany JSON valueA JSON representation of the struct
precisionLossbooleanReturns true if the result required downcasting to a type with less precision, for example if the input series was Int64 and the result is a Float64.
Set
typeto"arrowNumeric".arrowNumericArrowPlot
Fields of
ArrowPlotarrowBinarystring (base64)The raw binary containing an Arrow IPC stream.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowBucketedNumeric".arrowBucketedNumericArrowPlot
Set
typeto"enum".enumEnumPlot
Fields of
EnumPlottimestampsarray ofTimestamp
valuesarray of integer
categoriesarray of string
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"enumPoint".Set
typeto"bucketedEnum".bucketedEnumBucketedEnumPlot
Fields of
BucketedEnumPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofEnumBucket
Fields of
EnumBuckethistogrammap of string to integer (int64)The map of values within the bucket to their frequency.
firstPointCompactEnumPoint
Fields of
CompactEnumPointtimestampTimestamp
valueinteger
lastPointCompactEnumPointWill be empty if the bucket only has a single point.
categoriesarray of string
Set
typeto"arrowEnum".arrowEnumArrowPlot
Set
typeto"arrowBucketedEnum".arrowBucketedEnumArrowPlot
Set
typeto"pagedLog".pagedLogPagedLogPlot
Fields of
PagedLogPlottimestampsarray ofTimestamp
valuesarray ofLogValue
Fields of
LogValuemessagestring
argsmap of string to string
idstring (UUID)
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowLog".arrowLogArrowPlot
Set
typeto"cartesian".cartesianCartesianPlot
Fields of
CartesianPlottimestampsarray ofTimestamp
xValuesarray of number
yValuesarray of number
Set
typeto"bucketedCartesian".bucketedCartesianBucketedCartesianPlot
Fields of
BucketedCartesianPlotbucketsarray ofCartesianBucket
Set
typeto"bucketedCartesian3d".bucketedCartesian3dBucketedCartesian3dPlot
Fields of
BucketedCartesian3dPlotbucketsarray ofCartesian3dBucket
Fields of
Cartesian3dBucketminXnumber deprecatedDeprecated: Switching to point-based min/maxes
maxXnumber deprecatedDeprecated: Switching to point-based min/maxes
meanXnumber
minYnumber deprecatedDeprecated: Switching to point-based min/maxes
maxYnumber deprecatedDeprecated: Switching to point-based min/maxes
meanYnumber
minZnumber deprecatedDeprecated: Switching to point-based min/maxes
maxZnumber deprecatedDeprecated: Switching to point-based min/maxes
meanZnumber
minXPointPoint3d
Fields of
Point3dxnumber
ynumber
znumber
timestampTimestamp
maxXPointPoint3d
minYPointPoint3d
maxYPointPoint3d
minZPointPoint3d
maxZPointPoint3d
minTimestampTimestamp
maxTimestampTimestamp
countinteger (int64)
Set
typeto"frequencyDomain".frequencyDomainFrequencyDomainPlot
Fields of
FrequencyDomainPlotfrequenciesarray of number
amplitudesarray of number
Set
typeto"frequencyDomainV2".frequencyDomainV2FrequencyDomainPlotV2
Set
typeto"real".realFrequencyDomainPlot
Set
typeto"complex".complexFrequencyDomainPlotComplex
Fields of
FrequencyDomainPlotComplexfrequenciesarray of number
realarray of number
imaginaryarray of number
Set
typeto"magnitudeAndPhase".magnitudeAndPhaseFrequencyDomainPlotMagnitudeAndPhase
Fields of
FrequencyDomainPlotMagnitudeAndPhasefrequenciesarray of number
magnitudesarray of number
phasesarray of number
Set
typeto"spectrogram".spectrogramSpectrogramPlot
Fields of
SpectrogramPlotfrequencyCentersarray of numberCenter frequency in Hz of each column.
frequencyEdgesarray of numberColumn boundaries in Hz, one more than
frequencyCenters: columncspansfrequencyEdges[c]tofrequencyEdges[c + 1]. Columns may differ in width.rowsarray ofSpectrogramRow
Set
typeto"bucketedFrequencyDomain".bucketedFrequencyDomainBucketedFrequencyDomainPlot
Fields of
BucketedFrequencyDomainPlotbucketsarray ofFrequencyBucket
Fields of
FrequencyBucketfrequencyStartnumberThe start frequency of this bucket (inclusive).
frequencyEndnumberThe end frequency of this bucket (exclusive).
frequencyCenternumberThe center frequency of this bucket.
minAmplitudenumberThe minimum amplitude value in this bucket.
maxAmplitudenumberThe maximum amplitude value in this bucket.
meanAmplitudenumberThe mean amplitude value in this bucket.
countinteger (int64)The number of original frequency points that were aggregated into this bucket.
firstPointFrequencyPointThe first point (lowest frequency) in this bucket.
Fields of
FrequencyPointfrequencynumber
amplitudenumber
lastPointFrequencyPointThe last point (highest frequency) in this bucket. Will be empty if the bucket only has a single point.
Set
typeto"numericHistogram".numericHistogramNumericHistogramPlot
Fields of
NumericHistogramPlotbucketsarray ofNumericHistogramBucket
Fields of
NumericHistogramBucketlowerBoundnumberThe lower bound of the bucket, inclusive
upperBoundnumberThe upper bound of the bucket, exclusive
countsByChannelmap ofVariableNametoHistogramChannelCount
Fields of
HistogramChannelCountcountinteger (int64)
bucketsmap ofVariableNametoHistogramChannelCountdeprecatedDeprecated: Use countsByChannel instead
Set
typeto"enumHistogram".enumHistogramEnumHistogramPlot
Fields of
EnumHistogramPlotbucketsarray ofEnumHistogramBucket
Fields of
EnumHistogramBucketvaluestringThe value of the enum as a string
countsByChannelmap ofVariableNametoHistogramChannelCount
Set
typeto"curveFit".curveFitCurveFitResultDeprecated: use
curveFitV2(CurveFitResultV2) instead. Returned only for deprecated CurveFit requests.Fields of
CurveFitResultr2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsDescription of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Fields of
ExponentialResultDetailsanumber
bnumber
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Fields of
LogarithmicResultDetailsanumber
bnumber
Set
typeto"polynomial".polynomialPolynomialResultDetails
Fields of
PolynomialResultDetailsaarray of number
Set
typeto"power".powerPowerResultDetails
Fields of
PowerResultDetailsanumber
bnumber
Set
typeto"curveFitV2".curveFitV2CurveFitResultV2
Fields of
CurveFitResultV2r2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsV2Description of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Set
typeto"polynomial".polynomialPolynomialResultDetails
Set
typeto"power".powerPowerResultDetails
Set
typeto"custom".customCustomCurveResultDetails
Fields of
CustomCurveResultDetailsparametersmap of string to numberOptimized parameter values produced by the curve fit. Keys match the parameter names provided in the request.
convergedbooleanWhether the optimizer converged to a solution within its iteration limit. When false, the returned parameters are the best estimate found before the iteration cap was reached and did not satisfy the solver’s convergence tolerances.
iterationsintegerNumber of iterations the solver completed.
Set
typeto"grouped".groupedGroupedComputeNodeResponses
Fields of
GroupedComputeNodeResponsesresponsesarray ofGroupedComputeNodeResponse
Fields of
GroupedComputeNodeResponsegroupingGrouping
Set
typeto"tagsWithValues".tagsWithValuesmap of string to stringA grouping identified by a specific instantiation of tag keys and values.
responseComputeNodeResponse
Set
typeto"array".arrayArrowArrayPlot
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericArrayPlot
Fields of
BucketedNumericArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional numeric array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedEnum".bucketedEnumBucketedEnumArrayPlot
Fields of
BucketedEnumArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional enum array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedStruct".bucketedStructArrowPlot
Set
typeto"arrowStruct".arrowStructArrowPlot
Set
typeto"fullResolution".fullResolutionArrowPlot
Set
typeto"arrowBucketedMultivariate".arrowBucketedMultivariateArrowPlot
Set
typeto"multivariate".multivariateBucketedMultivariatePlot
Fields of
BucketedMultivariatePlotbucketsarray ofMultivariateBucket
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"error".errorErrorResult
Fields of
ErrorResulterrorTypestring
codeinteger
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/parameterized" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
},
"parameterizedContext": {
"parameterInputs": [
{
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"timeRange": {
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"value": {
"type": "double",
"double": 1
}
}
}
]
}
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/parameterized",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
"parameterizedContext": {
"parameterInputs": [
{
"variables": {"<key>": {"type": "double", "double": 1}},
"timeRange": {
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"value": {"type": "double", "double": 1},
},
},
],
},
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/parameterized",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
"parameterizedContext": {
"parameterInputs": [
{
"variables": {"<key>": {"type": "double", "double": 1}},
"timeRange": {
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"value": {"type": "double", "double": 1},
},
},
],
},
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/parameterized",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
"parameterizedContext": {
"parameterInputs": [
{
"variables": {"<key>": {"type": "double", "double": 1}},
"timeRange": {
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"value": {"type": "double", "double": 1},
},
},
],
},
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"results": [
{
"type": "success",
"success": {
"type": "range",
"range": [
{
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"value": {
"type": "double",
"double": 1
}
}
]
}
}
]
}
Compute units#
POST /compute/v2/compute/units
Returns the resulting unit for the output of a compute graph. If the resulting unit is equivalent to exactly one existing unit in the system, it will be returned (for example, a series in Coulombs divided by a series in Volts will return an output of Farads). If the output does not have units (for example, a range output,) the unit result will return noUnitAvailable, and if the computation was not successful, corresponding errors are returned.
Body
nodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Fields of
SummarizeRangesinputRangeSeriesrequired
maxRangesintegerThe maximum number of ranges to return in the response. If more ranges are found, a RangesSummary will be returned. Defaults to 2000 if not specified.
Set
typeto"series".seriesSummarizeSeries
Fields of
SummarizeSeriesinputSeriesrequired
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY.
numericOutputFieldsarray ofNumericOutputFielddeprecatedThe fields to output from the summarization. Applies only to Arrow format numeric series. Deprecated: Use numericOutputFieldsV2 instead.
numericAggregationsmap of string toNumericAggregationOperatorAdditional numeric aggregations per decimation bucket (e.g. percentiles). Map key is the name of the column in the result.
numericOutputFieldsV2array ofNumericOutputFieldV2Numeric bucket output fields to return. Applies only to Arrow format numeric series. Defaults to MEAN when no numeric output selector is specified. Mutually exclusive with numericOutputFields and numericAggregations.
resolutioninteger (int64) deprecatedResolution of the output series specifying time interval between decimated points, in nanoseconds. Deprecated: Use summarizationStrategy instead.
bucketsinteger deprecatedNumber of points to generate in the output series. Deprecated: Use summarizationStrategy instead.
summarizationStrategySummarizationStrategyThe strategy to use when summarizing the series.
Set
typeto"value".valueSelectValue
Set
typeto"firstPoint".firstPointSeries
Set
typeto"firstValuePoint".firstValuePointSeries
Set
typeto"firstRange".firstRangeRangeSeries
Set
typeto"lastPoint".lastPointSeries
Set
typeto"lastValuePoint".lastValuePointSeries
Set
typeto"lastRange".lastRangeRangeSeries
Set
typeto"nthRange".nthRangeNthRange
Set
typeto"cartesian".cartesianSummarizeCartesian
Fields of
SummarizeCartesianinputCartesianrequired
boundsCartesianBounds
summarizationStrategyScatterSummarizationStrategyThe summarization strategy to use when there are more than
maxPoints. Defaults to spatial.maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesianPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Fields of
SummarizeCartesian3dinputCartesian3drequired
boundsCartesian3dBounds
maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesian3dPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
summarizationStrategyScatterSummarizationStrategyThe strategy to use when summarizing the series. Only spatial decimation is supported.
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"fft".fftFft
Set
typeto"periodogram".periodogramPeriodogram
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Fields of
SpectrograminputNumericSeriesrequiredA numeric series from a single data source. Series grouped by tags are not supported.
stftOptionsStftOptionsWindow and FFT parameters.
quantitySpectrogramQuantityWhat each cell measures. Defaults to PSD.
magnitudeScalingMagnitudeScalingHow each cell’s value is scaled. Defaults to decibels: 10·log10 of the PSD, or 20·log10 of the amplitude.
bucketingSpectrogramBucketingThe output’s time and frequency buckets, frequency band and reductions.
Set
typeto"histogram".histogramHistogram
Set
typeto"numeric".numericNumericHistogramNode
Set
typeto"enum".enumEnumHistogramNode
Set
typeto"curveV2".curveV2CurveFitV2
Fields of
CurveFitV2targetCurveFitTargetrequiredTarget to fit the equation against.
fitRangeCurveFitRangerequiredThe range to fit the curve over
curveToFitCurveFitV2DetailsrequiredThe curve type to fit against the target series.
Set
typeto"curve".curveCurveFit
Fields of
CurveFitcurveFitPlotTypeCurveFitPlotTyperequired
curveFitDetailsCurveFitDetailsrequired
curveFitOptionsCurveFitOptionsrequired
Set
typeto"multivariate".multivariateSummarizeMultivariate
Fields of
SummarizeMultivariateinputsarray ofMultivariateInputList of input series to temporally align at the raw point level, then bucket the aligned tuples together. The series with the largest tag group acts as the “driver” that determines which raw timestamps are included in the alignment. All subsequent series are aligned to the driver’s raw timestamps using the interpolation configuration. After alignment, the resulting (x, y, z, …) tuples are bucketed into time windows and aggregated.
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY (JSON).
bucketCountintegerThe number of buckets to return in the response. Maximum is 10,000. Defaults to 1,000 if not specified.
interpolationConfigurationInterpolationConfigurationControls how the N input series are aligned at the raw point level when producing multivariate buckets. When present, the server may fill forward a series value from the most recent prior raw point (bounded by the interpolation radius). This alignment happens BEFORE bucketing, ensuring that aggregated values in each bucket are computed from temporally aligned raw tuples. When absent, the default interpolation configuration is used.
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
Set
typeto"double".doublenumber
Set
typeto"computeNode".computeNodeComputeNodeWithContext
Set
typeto"duration".durationrun.api.Duration
Set
typeto"integer".integerinteger
Set
typeto"channel".channelChannelSeriesdeprecatedDeprecated: use series instead.
Set
typeto"derived".derivedDerivedSeries
Set
typeto"series".seriesSeriesVariable
Set
typeto"string".stringstring
Set
typeto"stringSet".stringSetarray of string
Set
typeto"timestamp".timestampTimestamp
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
Fields of
FunctionVariablesvariablesmap ofVariableNametoVariableValue
subFunctionVariablesmap ofFunctionReferencetoFunctionVariables
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.Set
typeto"asset".assetAssetSingle asset. Expands to one grouping per data scope on the asset. Groupings are tagged by
assetRidanddataScopeso callers can safely compose multiple assets withcombine.
Set
typeto"run".runRunSingle run. Expands to one grouping per data source attached to the run: asset-typed sources contribute one grouping per data scope on the asset; dataset-typed sources contribute one grouping per dataset. Groupings are tagged by
runRidanddataScope; asset-typed groupings additionally carryassetRidso callers can safely compose multiple runs withcombine.
Set
typeto"saved".savedSavedDataset
Set
typeto"search".searchSearchDataset
Set
typeto"combine".combineCombinedDataset
Set
typeto"tag".tagTaggedDataset
Set
typeto"filter".filterFilteredDataset
Set
typeto"timeShift".timeShiftTimeShiftedDataset
Set
typeto"alignByAnchor".alignByAnchorAnchorAlignedDataset
Set
typeto"withSeries".withSeriesWithSeriesDataset
Set
typeto"dropSeries".dropSeriesDropSeriesDataset
Set
typeto"reference".referenceDatasetReference
Set
typeto"withDimensions".withDimensionsDimensionsDataset
defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
Set
typeto"forwardFill".forwardFillForwardFill
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
Set
typeto"driverSeries".driverSeriesDriverSeries
Set
typeto"union".unionUnion
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
Response
A ComputeUnitResult union.
Set type to "single".
singleUnitResult
Set
typeto"success".successstring
Set
typeto"noUnitAvailable".noUnitAvailablearray ofUnitComputationErrorThe resulting values have no units associated. If this is because of an error, it is listed here.
Set
typeto"incompatibleUnitsOperation".incompatibleUnitsOperationIncompatibleUnitOperation
Fields of
IncompatibleUnitOperationoperationUnitOperation
Values of
UnitOperationUNIT_AS_EXPONENT
NON_INTEGER_AS_EXPONENT
FLOOR_DIVISION
MODULO
CROSSOVER_COMPARISON
MAX
MIN
MEAN
UNION
ADDITION
SUBTRACTION
UNIT_CONVERSION
COMPARISON
TERNARY_OPERATOR
unitsarray of string
Set
typeto"unitsMissing".unitsMissingUnitsMissing
Fields of
UnitsMissingseriesRidsarray of string (RID) deprecatedDeprecated: Use channels instead.
channelsarray ofDataSourceAndChannel
Fields of
DataSourceAndChanneldataSourceRidstring (RID)
channelstring
Set
typeto"error".errorSerializableError
Fields of
SerializableErrornamestring
messagestring
errorInstanceIdstring
statusCodeinteger
paramsmap of string to string
Set type to "cartesian".
cartesianCartesianUnitResult
Fields of
CartesianUnitResultxUnitResult
yUnitResult
Set type to "cartesian3d".
cartesian3dCartesian3dUnitResult
Fields of
Cartesian3dUnitResultxUnitResult
yUnitResult
zUnitResult
Set type to "multivariate".
multivariateMultivariateUnitResult
Fields of
MultivariateUnitResultunitsarray ofUnitResult
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/units" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
}
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/units",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/units",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/units",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"type": "single",
"single": {
"type": "success",
"success": "<unit symbol>"
}
}
Batch compute with units#
POST /compute/v2/compute/batch
Computes the output of compute graphs specified by BatchComputeNodeRequest. Results are returned in the same order as the request.
Body
requestsarray ofComputeNodeRequest
Fields of
ComputeNodeRequestnodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Set
typeto"series".seriesSummarizeSeries
Set
typeto"value".valueSelectValue
Set
typeto"cartesian".cartesianSummarizeCartesian
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Set
typeto"histogram".histogramHistogram
Set
typeto"curveV2".curveV2CurveFitV2
Set
typeto"curve".curveCurveFit
Set
typeto"multivariate".multivariateSummarizeMultivariate
startTimestamprequiredThe start of the time range (inclusive).
Fields of
Timestampsecondsinteger (int64) required
nanosinteger (int64) required
endTimestamprequiredThe end of the time range (inclusive).
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
sourceRidstring (RID)Optional RID identifying the resource that initiated this query (e.g. workbook/notebook RID, checklist RID, dataset RID). Used for observability only — trusted as-is, no permission checks are performed on this value.
requestIdstring (UUID)Optional UUID to provide as a handle to selectively cancel the execution of this compute request.
Response
resultsarray ofComputeWithUnitsResult
Fields of
ComputeWithUnitsResultcomputeResultComputeNodeResult
Set
typeto"success".successComputeNodeResponse
Set
typeto"range".rangearray ofRange
Fields of
RangestartTimestamp
Fields of
Timestampsecondsinteger (int64)
nanosinteger (int64)
endTimestamp
valueRangeValue
Set
typeto"double".doublenumber
Set
typeto"aggregation".aggregationRangeAggregation
Fields of
RangeAggregationaveragenumber
minnumber
maxnumber
standardDeviationnumber
countnumber
sumnumber
rootMeanSquarenumber
Set
typeto"noPointsInRange".noPointsInRangeEmpty
Set
typeto"rangesSummary".rangesSummaryRangesSummary
Fields of
RangesSummaryrangesSummaryarray ofRangeSummary
Fields of
RangeSummaryrangeRangeThe range representing the minimum start and maximum end times of the ranges.
subRangeCountintegerThe number of ranges found within this time range.
Set
typeto"rangeValue".rangeValueRange
Set
typeto"numeric".numericNumericPlot
Fields of
NumericPlottimestampsarray ofTimestamp
valuesarray of number
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.Set
typeto"timestampAndId".timestampAndIdTimestampAndId
Fields of
TimestampAndIdtimestampTimestamp
idstring (UUID)
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericPlot
Fields of
BucketedNumericPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofNumericBucket
Fields of
NumericBucketminnumber
maxnumber
meannumber
countinteger (int64)
variancenumberThe population variance of the bucket. If the bucket has only one value, this will be 0.
firstPointNumericPoint
Fields of
NumericPointtimestampTimestamp
valuenumber
lastPointNumericPointWill be empty if the bucket only has a single point.
aggregationsmap of string to numberAdditional per-bucket aggregations that have no dedicated field above, keyed by the output column name requested via
numericAggregationsornumericOutputFieldsV2(e.g.sum,standardDeviation,rootMeanSquare,p50). Empty when no additional aggregations were requested.
Set
typeto"numericPoint".numericPointNumericPoint
Set
typeto"singlePoint".singlePointSinglePoint
Fields of
SinglePointtimestampTimestamp
valueValue
Set
typeto"stringValue".stringValuestring
Set
typeto"float64Value".float64Valuenumber
Set
typeto"int64Value".int64Valuestring
Set
typeto"arrayValue".arrayValuearray ofValue
Set
typeto"structValue".structValueany JSON valueA JSON representation of the struct
precisionLossbooleanReturns true if the result required downcasting to a type with less precision, for example if the input series was Int64 and the result is a Float64.
Set
typeto"arrowNumeric".arrowNumericArrowPlot
Fields of
ArrowPlotarrowBinarystring (base64)The raw binary containing an Arrow IPC stream.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowBucketedNumeric".arrowBucketedNumericArrowPlot
Set
typeto"enum".enumEnumPlot
Fields of
EnumPlottimestampsarray ofTimestamp
valuesarray of integer
categoriesarray of string
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"enumPoint".Set
typeto"bucketedEnum".bucketedEnumBucketedEnumPlot
Fields of
BucketedEnumPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofEnumBucket
Fields of
EnumBuckethistogrammap of string to integer (int64)The map of values within the bucket to their frequency.
firstPointCompactEnumPoint
Fields of
CompactEnumPointtimestampTimestamp
valueinteger
lastPointCompactEnumPointWill be empty if the bucket only has a single point.
categoriesarray of string
Set
typeto"arrowEnum".arrowEnumArrowPlot
Set
typeto"arrowBucketedEnum".arrowBucketedEnumArrowPlot
Set
typeto"pagedLog".pagedLogPagedLogPlot
Fields of
PagedLogPlottimestampsarray ofTimestamp
valuesarray ofLogValue
Fields of
LogValuemessagestring
argsmap of string to string
idstring (UUID)
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowLog".arrowLogArrowPlot
Set
typeto"cartesian".cartesianCartesianPlot
Fields of
CartesianPlottimestampsarray ofTimestamp
xValuesarray of number
yValuesarray of number
Set
typeto"bucketedCartesian".bucketedCartesianBucketedCartesianPlot
Fields of
BucketedCartesianPlotbucketsarray ofCartesianBucket
Set
typeto"bucketedCartesian3d".bucketedCartesian3dBucketedCartesian3dPlot
Fields of
BucketedCartesian3dPlotbucketsarray ofCartesian3dBucket
Fields of
Cartesian3dBucketminXnumber deprecatedDeprecated: Switching to point-based min/maxes
maxXnumber deprecatedDeprecated: Switching to point-based min/maxes
meanXnumber
minYnumber deprecatedDeprecated: Switching to point-based min/maxes
maxYnumber deprecatedDeprecated: Switching to point-based min/maxes
meanYnumber
minZnumber deprecatedDeprecated: Switching to point-based min/maxes
maxZnumber deprecatedDeprecated: Switching to point-based min/maxes
meanZnumber
minXPointPoint3d
Fields of
Point3dxnumber
ynumber
znumber
timestampTimestamp
maxXPointPoint3d
minYPointPoint3d
maxYPointPoint3d
minZPointPoint3d
maxZPointPoint3d
minTimestampTimestamp
maxTimestampTimestamp
countinteger (int64)
Set
typeto"frequencyDomain".frequencyDomainFrequencyDomainPlot
Fields of
FrequencyDomainPlotfrequenciesarray of number
amplitudesarray of number
Set
typeto"frequencyDomainV2".frequencyDomainV2FrequencyDomainPlotV2
Set
typeto"real".realFrequencyDomainPlot
Set
typeto"complex".complexFrequencyDomainPlotComplex
Fields of
FrequencyDomainPlotComplexfrequenciesarray of number
realarray of number
imaginaryarray of number
Set
typeto"magnitudeAndPhase".magnitudeAndPhaseFrequencyDomainPlotMagnitudeAndPhase
Fields of
FrequencyDomainPlotMagnitudeAndPhasefrequenciesarray of number
magnitudesarray of number
phasesarray of number
Set
typeto"spectrogram".spectrogramSpectrogramPlot
Fields of
SpectrogramPlotfrequencyCentersarray of numberCenter frequency in Hz of each column.
frequencyEdgesarray of numberColumn boundaries in Hz, one more than
frequencyCenters: columncspansfrequencyEdges[c]tofrequencyEdges[c + 1]. Columns may differ in width.rowsarray ofSpectrogramRow
Set
typeto"bucketedFrequencyDomain".bucketedFrequencyDomainBucketedFrequencyDomainPlot
Fields of
BucketedFrequencyDomainPlotbucketsarray ofFrequencyBucket
Fields of
FrequencyBucketfrequencyStartnumberThe start frequency of this bucket (inclusive).
frequencyEndnumberThe end frequency of this bucket (exclusive).
frequencyCenternumberThe center frequency of this bucket.
minAmplitudenumberThe minimum amplitude value in this bucket.
maxAmplitudenumberThe maximum amplitude value in this bucket.
meanAmplitudenumberThe mean amplitude value in this bucket.
countinteger (int64)The number of original frequency points that were aggregated into this bucket.
firstPointFrequencyPointThe first point (lowest frequency) in this bucket.
Fields of
FrequencyPointfrequencynumber
amplitudenumber
lastPointFrequencyPointThe last point (highest frequency) in this bucket. Will be empty if the bucket only has a single point.
Set
typeto"numericHistogram".numericHistogramNumericHistogramPlot
Fields of
NumericHistogramPlotbucketsarray ofNumericHistogramBucket
Fields of
NumericHistogramBucketlowerBoundnumberThe lower bound of the bucket, inclusive
upperBoundnumberThe upper bound of the bucket, exclusive
countsByChannelmap ofVariableNametoHistogramChannelCount
Fields of
HistogramChannelCountcountinteger (int64)
bucketsmap ofVariableNametoHistogramChannelCountdeprecatedDeprecated: Use countsByChannel instead
Set
typeto"enumHistogram".enumHistogramEnumHistogramPlot
Fields of
EnumHistogramPlotbucketsarray ofEnumHistogramBucket
Fields of
EnumHistogramBucketvaluestringThe value of the enum as a string
countsByChannelmap ofVariableNametoHistogramChannelCount
Set
typeto"curveFit".curveFitCurveFitResultDeprecated: use
curveFitV2(CurveFitResultV2) instead. Returned only for deprecated CurveFit requests.Fields of
CurveFitResultr2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsDescription of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Fields of
ExponentialResultDetailsanumber
bnumber
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Fields of
LogarithmicResultDetailsanumber
bnumber
Set
typeto"polynomial".polynomialPolynomialResultDetails
Fields of
PolynomialResultDetailsaarray of number
Set
typeto"power".powerPowerResultDetails
Fields of
PowerResultDetailsanumber
bnumber
Set
typeto"curveFitV2".curveFitV2CurveFitResultV2
Fields of
CurveFitResultV2r2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsV2Description of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Set
typeto"polynomial".polynomialPolynomialResultDetails
Set
typeto"power".powerPowerResultDetails
Set
typeto"custom".customCustomCurveResultDetails
Fields of
CustomCurveResultDetailsparametersmap of string to numberOptimized parameter values produced by the curve fit. Keys match the parameter names provided in the request.
convergedbooleanWhether the optimizer converged to a solution within its iteration limit. When false, the returned parameters are the best estimate found before the iteration cap was reached and did not satisfy the solver’s convergence tolerances.
iterationsintegerNumber of iterations the solver completed.
Set
typeto"grouped".groupedGroupedComputeNodeResponses
Fields of
GroupedComputeNodeResponsesresponsesarray ofGroupedComputeNodeResponse
Fields of
GroupedComputeNodeResponsegroupingGrouping
Set
typeto"tagsWithValues".tagsWithValuesmap of string to stringA grouping identified by a specific instantiation of tag keys and values.
responseComputeNodeResponse
Set
typeto"array".arrayArrowArrayPlot
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericArrayPlot
Fields of
BucketedNumericArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional numeric array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedEnum".bucketedEnumBucketedEnumArrayPlot
Fields of
BucketedEnumArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional enum array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedStruct".bucketedStructArrowPlot
Set
typeto"arrowStruct".arrowStructArrowPlot
Set
typeto"fullResolution".fullResolutionArrowPlot
Set
typeto"arrowBucketedMultivariate".arrowBucketedMultivariateArrowPlot
Set
typeto"multivariate".multivariateBucketedMultivariatePlot
Fields of
BucketedMultivariatePlotbucketsarray ofMultivariateBucket
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"error".errorErrorResult
Fields of
ErrorResulterrorTypestring
codeinteger
unitResultComputeUnitResult
Set
typeto"single".singleUnitResult
Set
typeto"success".successstring
Set
typeto"noUnitAvailable".noUnitAvailablearray ofUnitComputationErrorThe resulting values have no units associated. If this is because of an error, it is listed here.
Set
typeto"incompatibleUnitsOperation".incompatibleUnitsOperationIncompatibleUnitOperation
Fields of
IncompatibleUnitOperationoperationUnitOperation
Values of
UnitOperationUNIT_AS_EXPONENT
NON_INTEGER_AS_EXPONENT
FLOOR_DIVISION
MODULO
CROSSOVER_COMPARISON
MAX
MIN
MEAN
UNION
ADDITION
SUBTRACTION
UNIT_CONVERSION
COMPARISON
TERNARY_OPERATOR
unitsarray of string
Set
typeto"unitsMissing".unitsMissingUnitsMissing
Fields of
UnitsMissingseriesRidsarray of string (RID) deprecatedDeprecated: Use channels instead.
channelsarray ofDataSourceAndChannel
Fields of
DataSourceAndChanneldataSourceRidstring (RID)
channelstring
Set
typeto"error".errorSerializableError
Fields of
SerializableErrornamestring
messagestring
errorInstanceIdstring
statusCodeinteger
paramsmap of string to string
Set
typeto"cartesian".cartesianCartesianUnitResult
Fields of
CartesianUnitResultxUnitResult
yUnitResult
Set
typeto"cartesian3d".cartesian3dCartesian3dUnitResult
Fields of
Cartesian3dUnitResultxUnitResult
yUnitResult
zUnitResult
Set
typeto"multivariate".multivariateMultivariateUnitResult
Fields of
MultivariateUnitResultunitsarray ofUnitResult
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/batch" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
}
}
]
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {"type": "double", "double": 1},
},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>",
},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"results": [
{
"computeResult": {
"type": "success",
"success": {
"type": "range",
"range": [
{
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"value": {
"type": "double",
"double": 1
}
}
]
}
},
"unitResult": {
"type": "single",
"single": {
"type": "success",
"success": "<unit symbol>"
}
}
}
]
}
Batch compute units#
POST /compute/v2/compute/batch-units
Same as computeUnits, however this endpoint functions on a batch of requests for wire efficiency purposes. An extra note is that this method will serialize underlying classic REST errors into the BatchComputeUnitResult type, meaning callers are required to check for errors explicitly (rather than relying on exceptions being thrown).
Body
requestsarray ofComputeUnitsRequest
Fields of
ComputeUnitsRequestnodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Set
typeto"series".seriesSummarizeSeries
Set
typeto"value".valueSelectValue
Set
typeto"cartesian".cartesianSummarizeCartesian
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Set
typeto"histogram".histogramHistogram
Set
typeto"curveV2".curveV2CurveFitV2
Set
typeto"curve".curveCurveFit
Set
typeto"multivariate".multivariateSummarizeMultivariate
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
Response
resultsarray ofComputeUnitResult
Set
typeto"single".singleUnitResult
Set
typeto"success".successstring
Set
typeto"noUnitAvailable".noUnitAvailablearray ofUnitComputationErrorThe resulting values have no units associated. If this is because of an error, it is listed here.
Set
typeto"incompatibleUnitsOperation".incompatibleUnitsOperationIncompatibleUnitOperation
Fields of
IncompatibleUnitOperationoperationUnitOperation
Values of
UnitOperationUNIT_AS_EXPONENT
NON_INTEGER_AS_EXPONENT
FLOOR_DIVISION
MODULO
CROSSOVER_COMPARISON
MAX
MIN
MEAN
UNION
ADDITION
SUBTRACTION
UNIT_CONVERSION
COMPARISON
TERNARY_OPERATOR
unitsarray of string
Set
typeto"unitsMissing".unitsMissingUnitsMissing
Fields of
UnitsMissingseriesRidsarray of string (RID) deprecatedDeprecated: Use channels instead.
channelsarray ofDataSourceAndChannel
Fields of
DataSourceAndChanneldataSourceRidstring (RID)
channelstring
Set
typeto"error".errorSerializableError
Fields of
SerializableErrornamestring
messagestring
errorInstanceIdstring
statusCodeinteger
paramsmap of string to string
Set
typeto"cartesian".cartesianCartesianUnitResult
Fields of
CartesianUnitResultxUnitResult
yUnitResult
Set
typeto"cartesian3d".cartesian3dCartesian3dUnitResult
Fields of
Cartesian3dUnitResultxUnitResult
yUnitResult
zUnitResult
Set
typeto"multivariate".multivariateMultivariateUnitResult
Fields of
MultivariateUnitResultunitsarray ofUnitResult
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/batch-units" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
}
}
]
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch-units",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch-units",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch-units",
headers={"Authorization": "Bearer <api key>"},
json={
"requests": [
{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {"type": "double", "double": 1},
},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>",
},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
],
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"results": [
{
"type": "single",
"single": {
"type": "success",
"success": "<unit symbol>"
}
}
]
}
Compute with units#
POST /compute/v2/computeWithUnits
Computes the output of the compute graph specified by a ComputeNodeRequest, as well as providing the resulting unit for the output of a compute graph. If the resulting unit is equivalent to exactly one existing unit in the system, it will be returned (for example, a series in Coulombs divided by a series in Volts will return an output of Farads). If the output does not have units (for example, a range output,) the unit result will return noUnitAvailable, and if the computation was not successful, corresponding errors are returned.
Body
nodeComputableNoderequired
Set
typeto"ranges".rangesSummarizeRanges
Fields of
SummarizeRangesinputRangeSeriesrequired
maxRangesintegerThe maximum number of ranges to return in the response. If more ranges are found, a RangesSummary will be returned. Defaults to 2000 if not specified.
Set
typeto"series".seriesSummarizeSeries
Fields of
SummarizeSeriesinputSeriesrequired
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY.
numericOutputFieldsarray ofNumericOutputFielddeprecatedThe fields to output from the summarization. Applies only to Arrow format numeric series. Deprecated: Use numericOutputFieldsV2 instead.
numericAggregationsmap of string toNumericAggregationOperatorAdditional numeric aggregations per decimation bucket (e.g. percentiles). Map key is the name of the column in the result.
numericOutputFieldsV2array ofNumericOutputFieldV2Numeric bucket output fields to return. Applies only to Arrow format numeric series. Defaults to MEAN when no numeric output selector is specified. Mutually exclusive with numericOutputFields and numericAggregations.
resolutioninteger (int64) deprecatedResolution of the output series specifying time interval between decimated points, in nanoseconds. Deprecated: Use summarizationStrategy instead.
bucketsinteger deprecatedNumber of points to generate in the output series. Deprecated: Use summarizationStrategy instead.
summarizationStrategySummarizationStrategyThe strategy to use when summarizing the series.
Set
typeto"value".valueSelectValue
Set
typeto"firstPoint".firstPointSeries
Set
typeto"firstValuePoint".firstValuePointSeries
Set
typeto"firstRange".firstRangeRangeSeries
Set
typeto"lastPoint".lastPointSeries
Set
typeto"lastValuePoint".lastValuePointSeries
Set
typeto"lastRange".lastRangeRangeSeries
Set
typeto"nthRange".nthRangeNthRange
Set
typeto"cartesian".cartesianSummarizeCartesian
Fields of
SummarizeCartesianinputCartesianrequired
boundsCartesianBounds
summarizationStrategyScatterSummarizationStrategyThe summarization strategy to use when there are more than
maxPoints. Defaults to spatial.maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesianPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
Set
typeto"cartesian3d".cartesian3dSummarizeCartesian3d
Fields of
SummarizeCartesian3dinputCartesian3drequired
boundsCartesian3dBounds
maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesian3dPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
summarizationStrategyScatterSummarizationStrategyThe strategy to use when summarizing the series. Only spatial decimation is supported.
Set
typeto"frequency".frequencyFrequencyDomain
Set
typeto"fft".fftFft
Set
typeto"periodogram".periodogramPeriodogram
Set
typeto"frequencyV2".frequencyV2FrequencyDomainV2
Set
typeto"spectrogram".spectrogramSpectrogram
Fields of
SpectrograminputNumericSeriesrequiredA numeric series from a single data source. Series grouped by tags are not supported.
stftOptionsStftOptionsWindow and FFT parameters.
quantitySpectrogramQuantityWhat each cell measures. Defaults to PSD.
magnitudeScalingMagnitudeScalingHow each cell’s value is scaled. Defaults to decibels: 10·log10 of the PSD, or 20·log10 of the amplitude.
bucketingSpectrogramBucketingThe output’s time and frequency buckets, frequency band and reductions.
Set
typeto"histogram".histogramHistogram
Set
typeto"numeric".numericNumericHistogramNode
Set
typeto"enum".enumEnumHistogramNode
Set
typeto"curveV2".curveV2CurveFitV2
Fields of
CurveFitV2targetCurveFitTargetrequiredTarget to fit the equation against.
fitRangeCurveFitRangerequiredThe range to fit the curve over
curveToFitCurveFitV2DetailsrequiredThe curve type to fit against the target series.
Set
typeto"curve".curveCurveFit
Fields of
CurveFitcurveFitPlotTypeCurveFitPlotTyperequired
curveFitDetailsCurveFitDetailsrequired
curveFitOptionsCurveFitOptionsrequired
Set
typeto"multivariate".multivariateSummarizeMultivariate
Fields of
SummarizeMultivariateinputsarray ofMultivariateInputList of input series to temporally align at the raw point level, then bucket the aligned tuples together. The series with the largest tag group acts as the “driver” that determines which raw timestamps are included in the alignment. All subsequent series are aligned to the driver’s raw timestamps using the interpolation configuration. After alignment, the resulting (x, y, z, …) tuples are bucketed into time windows and aggregated.
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY (JSON).
bucketCountintegerThe number of buckets to return in the response. Maximum is 10,000. Defaults to 1,000 if not specified.
interpolationConfigurationInterpolationConfigurationControls how the N input series are aligned at the raw point level when producing multivariate buckets. When present, the server may fill forward a series value from the most recent prior raw point (bounded by the interpolation radius). This alignment happens BEFORE bucketing, ensuring that aggregated values in each bucket are computed from temporally aligned raw tuples. When absent, the default interpolation configuration is used.
startTimestamprequiredThe start of the time range (inclusive).
Fields of
Timestampsecondsinteger (int64) required
nanosinteger (int64) required
endTimestamprequiredThe end of the time range (inclusive).
contextContextrequired
Fields of
Contextvariablesmap ofVariableNametoVariableValue
Set
typeto"double".doublenumber
Set
typeto"computeNode".computeNodeComputeNodeWithContext
Set
typeto"duration".durationrun.api.Duration
Set
typeto"integer".integerinteger
Set
typeto"channel".channelChannelSeriesdeprecatedDeprecated: use series instead.
Set
typeto"derived".derivedDerivedSeries
Set
typeto"series".seriesSeriesVariable
Set
typeto"string".stringstring
Set
typeto"stringSet".stringSetarray of string
Set
typeto"timestamp".timestampTimestamp
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
Fields of
FunctionVariablesvariablesmap ofVariableNametoVariableValue
subFunctionVariablesmap ofFunctionReferencetoFunctionVariables
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.Set
typeto"asset".assetAssetSingle asset. Expands to one grouping per data scope on the asset. Groupings are tagged by
assetRidanddataScopeso callers can safely compose multiple assets withcombine.
Set
typeto"run".runRunSingle run. Expands to one grouping per data source attached to the run: asset-typed sources contribute one grouping per data scope on the asset; dataset-typed sources contribute one grouping per dataset. Groupings are tagged by
runRidanddataScope; asset-typed groupings additionally carryassetRidso callers can safely compose multiple runs withcombine.
Set
typeto"saved".savedSavedDataset
Set
typeto"search".searchSearchDataset
Set
typeto"combine".combineCombinedDataset
Set
typeto"tag".tagTaggedDataset
Set
typeto"filter".filterFilteredDataset
Set
typeto"timeShift".timeShiftTimeShiftedDataset
Set
typeto"alignByAnchor".alignByAnchorAnchorAlignedDataset
Set
typeto"withSeries".withSeriesWithSeriesDataset
Set
typeto"dropSeries".dropSeriesDropSeriesDataset
Set
typeto"reference".referenceDatasetReference
Set
typeto"withDimensions".withDimensionsDimensionsDataset
defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
Set
typeto"forwardFill".forwardFillForwardFill
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
Set
typeto"driverSeries".driverSeriesDriverSeries
Set
typeto"union".unionUnion
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
sourceRidstring (RID)Optional RID identifying the resource that initiated this query (e.g. workbook/notebook RID, checklist RID, dataset RID). Used for observability only — trusted as-is, no permission checks are performed on this value.
requestIdstring (UUID)Optional UUID to provide as a handle to selectively cancel the execution of this compute request.
Response
computeResultComputeNodeResponse
Set
typeto"range".rangearray ofRange
Fields of
RangestartTimestamp
Fields of
Timestampsecondsinteger (int64)
nanosinteger (int64)
endTimestamp
valueRangeValue
Set
typeto"double".doublenumber
Set
typeto"aggregation".aggregationRangeAggregation
Fields of
RangeAggregationaveragenumber
minnumber
maxnumber
standardDeviationnumber
countnumber
sumnumber
rootMeanSquarenumber
Set
typeto"noPointsInRange".noPointsInRangeEmpty
Set
typeto"rangesSummary".rangesSummaryRangesSummary
Fields of
RangesSummaryrangesSummaryarray ofRangeSummary
Fields of
RangeSummaryrangeRangeThe range representing the minimum start and maximum end times of the ranges.
subRangeCountintegerThe number of ranges found within this time range.
Set
typeto"rangeValue".rangeValueRange
Set
typeto"numeric".numericNumericPlot
Fields of
NumericPlottimestampsarray ofTimestamp
valuesarray of number
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.Set
typeto"timestampAndId".timestampAndIdTimestampAndId
Fields of
TimestampAndIdtimestampTimestamp
idstring (UUID)
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericPlot
Fields of
BucketedNumericPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofNumericBucket
Fields of
NumericBucketminnumber
maxnumber
meannumber
countinteger (int64)
variancenumberThe population variance of the bucket. If the bucket has only one value, this will be 0.
firstPointNumericPoint
Fields of
NumericPointtimestampTimestamp
valuenumber
lastPointNumericPointWill be empty if the bucket only has a single point.
aggregationsmap of string to numberAdditional per-bucket aggregations that have no dedicated field above, keyed by the output column name requested via
numericAggregationsornumericOutputFieldsV2(e.g.sum,standardDeviation,rootMeanSquare,p50). Empty when no additional aggregations were requested.
Set
typeto"numericPoint".numericPointNumericPoint
Set
typeto"singlePoint".singlePointSinglePoint
Fields of
SinglePointtimestampTimestamp
valueValue
Set
typeto"stringValue".stringValuestring
Set
typeto"float64Value".float64Valuenumber
Set
typeto"int64Value".int64Valuestring
Set
typeto"arrayValue".arrayValuearray ofValue
Set
typeto"structValue".structValueany JSON valueA JSON representation of the struct
precisionLossbooleanReturns true if the result required downcasting to a type with less precision, for example if the input series was Int64 and the result is a Float64.
Set
typeto"arrowNumeric".arrowNumericArrowPlot
Fields of
ArrowPlotarrowBinarystring (base64)The raw binary containing an Arrow IPC stream.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowBucketedNumeric".arrowBucketedNumericArrowPlot
Set
typeto"enum".enumEnumPlot
Fields of
EnumPlottimestampsarray ofTimestamp
valuesarray of integer
categoriesarray of string
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"enumPoint".Set
typeto"bucketedEnum".bucketedEnumBucketedEnumPlot
Fields of
BucketedEnumPlottimestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofEnumBucket
Fields of
EnumBuckethistogrammap of string to integer (int64)The map of values within the bucket to their frequency.
firstPointCompactEnumPoint
Fields of
CompactEnumPointtimestampTimestamp
valueinteger
lastPointCompactEnumPointWill be empty if the bucket only has a single point.
categoriesarray of string
Set
typeto"arrowEnum".arrowEnumArrowPlot
Set
typeto"arrowBucketedEnum".arrowBucketedEnumArrowPlot
Set
typeto"pagedLog".pagedLogPagedLogPlot
Fields of
PagedLogPlottimestampsarray ofTimestamp
valuesarray ofLogValue
Fields of
LogValuemessagestring
argsmap of string to string
idstring (UUID)
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Set
typeto"arrowLog".arrowLogArrowPlot
Set
typeto"cartesian".cartesianCartesianPlot
Fields of
CartesianPlottimestampsarray ofTimestamp
xValuesarray of number
yValuesarray of number
Set
typeto"bucketedCartesian".bucketedCartesianBucketedCartesianPlot
Fields of
BucketedCartesianPlotbucketsarray ofCartesianBucket
Set
typeto"bucketedCartesian3d".bucketedCartesian3dBucketedCartesian3dPlot
Fields of
BucketedCartesian3dPlotbucketsarray ofCartesian3dBucket
Fields of
Cartesian3dBucketminXnumber deprecatedDeprecated: Switching to point-based min/maxes
maxXnumber deprecatedDeprecated: Switching to point-based min/maxes
meanXnumber
minYnumber deprecatedDeprecated: Switching to point-based min/maxes
maxYnumber deprecatedDeprecated: Switching to point-based min/maxes
meanYnumber
minZnumber deprecatedDeprecated: Switching to point-based min/maxes
maxZnumber deprecatedDeprecated: Switching to point-based min/maxes
meanZnumber
minXPointPoint3d
Fields of
Point3dxnumber
ynumber
znumber
timestampTimestamp
maxXPointPoint3d
minYPointPoint3d
maxYPointPoint3d
minZPointPoint3d
maxZPointPoint3d
minTimestampTimestamp
maxTimestampTimestamp
countinteger (int64)
Set
typeto"frequencyDomain".frequencyDomainFrequencyDomainPlot
Fields of
FrequencyDomainPlotfrequenciesarray of number
amplitudesarray of number
Set
typeto"frequencyDomainV2".frequencyDomainV2FrequencyDomainPlotV2
Set
typeto"real".realFrequencyDomainPlot
Set
typeto"complex".complexFrequencyDomainPlotComplex
Fields of
FrequencyDomainPlotComplexfrequenciesarray of number
realarray of number
imaginaryarray of number
Set
typeto"magnitudeAndPhase".magnitudeAndPhaseFrequencyDomainPlotMagnitudeAndPhase
Fields of
FrequencyDomainPlotMagnitudeAndPhasefrequenciesarray of number
magnitudesarray of number
phasesarray of number
Set
typeto"spectrogram".spectrogramSpectrogramPlot
Fields of
SpectrogramPlotfrequencyCentersarray of numberCenter frequency in Hz of each column.
frequencyEdgesarray of numberColumn boundaries in Hz, one more than
frequencyCenters: columncspansfrequencyEdges[c]tofrequencyEdges[c + 1]. Columns may differ in width.rowsarray ofSpectrogramRow
Set
typeto"bucketedFrequencyDomain".bucketedFrequencyDomainBucketedFrequencyDomainPlot
Fields of
BucketedFrequencyDomainPlotbucketsarray ofFrequencyBucket
Fields of
FrequencyBucketfrequencyStartnumberThe start frequency of this bucket (inclusive).
frequencyEndnumberThe end frequency of this bucket (exclusive).
frequencyCenternumberThe center frequency of this bucket.
minAmplitudenumberThe minimum amplitude value in this bucket.
maxAmplitudenumberThe maximum amplitude value in this bucket.
meanAmplitudenumberThe mean amplitude value in this bucket.
countinteger (int64)The number of original frequency points that were aggregated into this bucket.
firstPointFrequencyPointThe first point (lowest frequency) in this bucket.
Fields of
FrequencyPointfrequencynumber
amplitudenumber
lastPointFrequencyPointThe last point (highest frequency) in this bucket. Will be empty if the bucket only has a single point.
Set
typeto"numericHistogram".numericHistogramNumericHistogramPlot
Fields of
NumericHistogramPlotbucketsarray ofNumericHistogramBucket
Fields of
NumericHistogramBucketlowerBoundnumberThe lower bound of the bucket, inclusive
upperBoundnumberThe upper bound of the bucket, exclusive
countsByChannelmap ofVariableNametoHistogramChannelCount
Fields of
HistogramChannelCountcountinteger (int64)
bucketsmap ofVariableNametoHistogramChannelCountdeprecatedDeprecated: Use countsByChannel instead
Set
typeto"enumHistogram".enumHistogramEnumHistogramPlot
Fields of
EnumHistogramPlotbucketsarray ofEnumHistogramBucket
Fields of
EnumHistogramBucketvaluestringThe value of the enum as a string
countsByChannelmap ofVariableNametoHistogramChannelCount
Set
typeto"curveFit".curveFitCurveFitResultDeprecated: use
curveFitV2(CurveFitResultV2) instead. Returned only for deprecated CurveFit requests.Fields of
CurveFitResultr2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsDescription of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Fields of
ExponentialResultDetailsanumber
bnumber
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Fields of
LogarithmicResultDetailsanumber
bnumber
Set
typeto"polynomial".polynomialPolynomialResultDetails
Fields of
PolynomialResultDetailsaarray of number
Set
typeto"power".powerPowerResultDetails
Fields of
PowerResultDetailsanumber
bnumber
Set
typeto"curveFitV2".curveFitV2CurveFitResultV2
Fields of
CurveFitResultV2r2numberR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumberMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumberMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumberRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumberMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountintegerThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsV2Description of the fit curve.
Set
typeto"exponential".exponentialExponentialResultDetails
Set
typeto"logarithmic".logarithmicLogarithmicResultDetails
Set
typeto"polynomial".polynomialPolynomialResultDetails
Set
typeto"power".powerPowerResultDetails
Set
typeto"custom".customCustomCurveResultDetails
Fields of
CustomCurveResultDetailsparametersmap of string to numberOptimized parameter values produced by the curve fit. Keys match the parameter names provided in the request.
convergedbooleanWhether the optimizer converged to a solution within its iteration limit. When false, the returned parameters are the best estimate found before the iteration cap was reached and did not satisfy the solver’s convergence tolerances.
iterationsintegerNumber of iterations the solver completed.
Set
typeto"grouped".groupedGroupedComputeNodeResponses
Fields of
GroupedComputeNodeResponsesresponsesarray ofGroupedComputeNodeResponse
Fields of
GroupedComputeNodeResponsegroupingGrouping
Set
typeto"tagsWithValues".tagsWithValuesmap of string to stringA grouping identified by a specific instantiation of tag keys and values.
responseComputeNodeResponse
Set
typeto"array".arrayArrowArrayPlot
Set
typeto"bucketedNumeric".bucketedNumericBucketedNumericArrayPlot
Fields of
BucketedNumericArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional numeric array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedEnum".bucketedEnumBucketedEnumArrayPlot
Fields of
BucketedEnumArrayPlotarrowBinarystring (base64)The raw binary containing Arrow IPC stream for a bucketed N-dimensional enum array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
Set
typeto"bucketedStruct".bucketedStructArrowPlot
Set
typeto"arrowStruct".arrowStructArrowPlot
Set
typeto"fullResolution".fullResolutionArrowPlot
Set
typeto"arrowBucketedMultivariate".arrowBucketedMultivariateArrowPlot
Set
typeto"multivariate".multivariateBucketedMultivariatePlot
Fields of
BucketedMultivariatePlotbucketsarray ofMultivariateBucket
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
computeUnitComputeUnitResult
Set
typeto"single".singleUnitResult
Set
typeto"success".successstring
Set
typeto"noUnitAvailable".noUnitAvailablearray ofUnitComputationErrorThe resulting values have no units associated. If this is because of an error, it is listed here.
Set
typeto"incompatibleUnitsOperation".incompatibleUnitsOperationIncompatibleUnitOperation
Fields of
IncompatibleUnitOperationoperationUnitOperation
Values of
UnitOperationUNIT_AS_EXPONENT
NON_INTEGER_AS_EXPONENT
FLOOR_DIVISION
MODULO
CROSSOVER_COMPARISON
MAX
MIN
MEAN
UNION
ADDITION
SUBTRACTION
UNIT_CONVERSION
COMPARISON
TERNARY_OPERATOR
unitsarray of string
Set
typeto"unitsMissing".unitsMissingUnitsMissing
Fields of
UnitsMissingseriesRidsarray of string (RID) deprecatedDeprecated: Use channels instead.
channelsarray ofDataSourceAndChannel
Fields of
DataSourceAndChanneldataSourceRidstring (RID)
channelstring
Set
typeto"error".errorSerializableError
Fields of
SerializableErrornamestring
messagestring
errorInstanceIdstring
statusCodeinteger
paramsmap of string to string
Set
typeto"cartesian".cartesianCartesianUnitResult
Fields of
CartesianUnitResultxUnitResult
yUnitResult
Set
typeto"cartesian3d".cartesian3dCartesian3dUnitResult
Fields of
Cartesian3dUnitResultxUnitResult
yUnitResult
zUnitResult
Set
typeto"multivariate".multivariateMultivariateUnitResult
Fields of
MultivariateUnitResultunitsarray ofUnitResult
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/computeWithUnits" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {
"type": "abs",
"abs": {}
},
"threshold": {
"type": "literal",
"literal": 1
},
"tolerance": {
"type": "literal",
"literal": 1
},
"operator": "EQUAL_TO"
}
}
}
},
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"context": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"functionVariables": {
"<key>": {
"variables": {
"<key>": {
"type": "double",
"double": 1
}
},
"subFunctionVariables": {}
}
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {
"type": "literal",
"literal": "<literal>"
}
}
}
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {
"seconds": 1,
"nanos": 1
}
}
}
}
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {}
},
"applyDataScopeOffsets": true,
"resolveAssetsThroughDatasets": true
}
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/computeWithUnits",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/computeWithUnits",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {"rid": {"type": "literal", "literal": "<literal>"}},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {"type": "driverSeries", "driverSeries": {}},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/computeWithUnits",
headers={"Authorization": "Bearer <api key>"},
json={
"node": {
"type": "ranges",
"ranges": {
"input": {
"type": "approximateThreshold",
"approximateThreshold": {
"input": {"type": "abs", "abs": {}},
"threshold": {"type": "literal", "literal": 1},
"tolerance": {"type": "literal", "literal": 1},
"operator": "EQUAL_TO",
},
},
},
},
"start": {"seconds": 1, "nanos": 1},
"end": {"seconds": 1, "nanos": 1},
"context": {
"variables": {"<key>": {"type": "double", "double": 1}},
"functionVariables": {
"<key>": {
"variables": {"<key>": {"type": "double", "double": 1}},
"subFunctionVariables": {},
},
},
"datasetReferences": {
"<key>": {
"type": "asset",
"asset": {
"rid": {"type": "literal", "literal": "<literal>"},
},
},
},
"defaultFillStrategy": {
"type": "forwardFill",
"forwardFill": {
"limit": {
"type": "duration",
"duration": {
"type": "literal",
"literal": {"seconds": 1, "nanos": 1},
},
},
},
},
"defaultAlignmentStrategy": {
"type": "driverSeries",
"driverSeries": {},
},
"applyDataScopeOffsets": True,
"resolveAssetsThroughDatasets": True,
},
},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"computeResult": {
"type": "range",
"range": [
{
"start": {
"seconds": 1,
"nanos": 1
},
"end": {
"seconds": 1,
"nanos": 1
},
"value": {
"type": "double",
"double": 1
}
}
]
},
"computeUnit": {
"type": "single",
"single": {
"type": "success",
"success": "<unit symbol>"
}
}
}
Batch kill requests#
POST /compute/v2/compute/batch/kill
Best-effort cancellation of active compute requests. Each ID should be the request ID that the client originally passed when starting the request. A single request may correspond to one or more underlying operations, all of which will be cancelled.
Body
requestIdsarray of string (UUID)
Response
No content (HTTP 204).
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/batch/kill" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"requestIds": [
"<request ids>"
]
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/kill",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
)
response.raise_for_status()
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/kill",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
)
response.raise_for_status()
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/kill",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
) as response:
response.raise_for_status()
asyncio.run(main())
Response: 204
No content.
Batch get request progress#
POST /compute/v2/compute/batch/progress
Returns a point-in-time snapshot of progress for the given active compute requests. Each ID should be the request ID that the client originally passed when starting the request. Intended to be polled (roughly once per second) for requests that have been running longer than the slow-query threshold.
A request with no active queries is not necessarily finished: its underlying queries may not have started yet, the request may be in a post-processing phase, or the request’s work may be executed somewhere that does not report progress — in which case it stays inactive for its entire duration. Clients should derive progress from the raw row counters and must not assume monotonicity, since totalRowsApprox can grow while a request runs.
Body
requestIdsarray of string (UUID)Limited to 300 IDs per call.
Response
progressByRequestIdmap of string toRequestProgressContains an entry for every requested request ID.
Set
typeto"inProgress".inProgressRequestInProgress
Fields of
RequestInProgressreadRowsinteger (int64)
totalRowsApproxinteger (int64)May grow while a query runs as new sources to process become known.
Set
typeto"inactive".inactiveRequestInactive
Request
curl -X POST "https://api.gov.nominal.io/api/compute/v2/compute/batch/progress" \
-H "Authorization: Bearer <api key>" \
-H "Content-Type: application/json" \
--data '{
"requestIds": [
"<request ids>"
]
}'
import requests
response = requests.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/progress",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/progress",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.post(
"https://api.gov.nominal.io/api/compute/v2/compute/batch/progress",
headers={"Authorization": "Bearer <api key>"},
json={"requestIds": ["<request ids>"]},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"progressByRequestId": {
"<key>": {
"type": "inProgress",
"inProgress": {
"readRows": 1,
"totalRowsApprox": 1
}
}
}
}
Get quota usage#
GET /compute/v2/compute/quota/usage
Returns the calling user’s compute quota usage for their current organization, one entry per quota window. Returns no intervals when quotas are not enabled for the organization.
Request
No parameters and no body.
Response
intervalsarray ofQuotaIntervalUsageOne entry per quota window, ordered by ascending duration. Empty when quotas are not enabled for the organization or the user has no recorded usage yet.
Fields of
QuotaIntervalUsagedurationSecondsinteger (int64)Length of the quota window in seconds.
currentWindowQuotaWindowBounds of the current quota window. Usage counters reset at the window’s end.
Fields of
QuotaWindowstartTimestring (date-time)
endTimestring (date-time)
resourcesarray ofQuotaResourceUsageUsage per limited resource. Resources without a configured limit are not reported.
Fields of
QuotaResourceUsageresourceQuotaResourceType
Values of
QuotaResourceTypeREAD_ROWS
READ_BYTES
QUERIES
ERRORS
EXECUTION_TIME
usednumberAmount consumed within the current window, in the resource’s native unit (rows, bytes, query count, or seconds for EXECUTION_TIME).
limitnumberThe cap for this resource in this window.
Request
curl "https://api.gov.nominal.io/api/compute/v2/compute/quota/usage" \
-H "Authorization: Bearer <api key>"
import requests
response = requests.get(
"https://api.gov.nominal.io/api/compute/v2/compute/quota/usage",
headers={"Authorization": "Bearer <api key>"},
)
response.raise_for_status()
print(response.json())
import httpx
response = httpx.get(
"https://api.gov.nominal.io/api/compute/v2/compute/quota/usage",
headers={"Authorization": "Bearer <api key>"},
)
response.raise_for_status()
print(response.json())
import asyncio
import aiohttp
async def main() -> None:
async with aiohttp.ClientSession() as session:
async with session.get(
"https://api.gov.nominal.io/api/compute/v2/compute/quota/usage",
headers={"Authorization": "Bearer <api key>"},
) as response:
response.raise_for_status()
print(await response.json())
asyncio.run(main())
Response: 200
{
"intervals": [
{
"durationSeconds": 1,
"currentWindow": {
"startTime": "2026-01-01T00:00:00Z",
"endTime": "2026-01-01T00:00:00Z"
},
"resources": [
{
"resource": "READ_ROWS",
"used": 1,
"limit": 1
}
]
}
]
}
Errors#
Errors shows how these errors are sent.
Each error’s errorName is Compute: followed by its name below.
Status |
Name |
Notes |
|---|---|---|
400 |
|
|
400 |
|
The regular expression could not be compiled. |
400 |
|
|
400 |
|
Computation too complex. Try reducing the number of channels, computations, or tags. |
400 |
|
A unit could not be found for the input series, or it did not exist in the unit system. The conversion could not be computed. |
400 |
|
The output unit symbol could not be found in the unit system. The conversion could not be computed. |
400 |
|
Some points in the input had negative (or zero) x-values. Power and logarithmic curve fits do not allow negative (or zero) x-valued points. |
400 |
|
The x and y inputs to fit a curve to do not have the same length. |
400 |
|
A custom curve fit declared a parameter (with an initial guess) that its formula never references. Every declared parameter must appear in the formula; otherwise it is an unconstrained degree of freedom for the solver. Remove the unused parameter or reference it in the formula. |
400 |
|
A custom curve fit declared a variable that its formula never references. The unused variable’s series would be fetched and aligned for nothing, so it almost certainly indicates a mistake in the formula. Remove the unused variable or reference it in the formula. |
400 |
|
A custom curve fit may declare at most one time variable; there is only one sample-timestamp axis for the formula to refer to. |
400 |
|
|
400 |
|
|
400 |
|
At least one input must be provided. |
400 |
|
Specified path cannot be empty. |
400 |
|
The provided set must contain at least one element. |
400 |
|
Due to limits in how numbers are represented by computers, exponential fits cannot be performed on data with x-values that are too large (> 650). This includes timestamp data based on the Time Unit parameter to the curve fit - e.g. 1 second at millisecond scale is too large, as it is 1000 milliseconds. |
400 |
|
Not enough data points to estimate a sampling frequency for frequency-domain analysis. Try again with a larger time range. |
400 |
|
The selected window for the frequency domain is empty. Try again with a larger time range. |
400 |
|
The selected window for the frequency domain is too large. Try again with a smaller time range. |
400 |
|
Some operations that require matching granularity did not have matching granularity. |
400 |
|
Attempted to group by a tag that does not exist. |
400 |
|
Group by tags must be equal, or one set must be a subset of the other. |
400 |
|
Group by queries are not supported for the compute node supplied |
400 |
|
The bit operation is invalid due to the index or operand being out of range. Valid range - [0, 63]. |
400 |
|
|
400 |
|
Struct field names cannot contain ‘.’ |
400 |
|
The starting timestamp of a range cannot be greater than or equal to the end timestamp. At least one of start and end timestamps must be present. Only the first range when sorted may omit the start, and only the last may omit the end. |
400 |
|
Numeric aggregations can only be specified on numeric series requests. |
400 |
|
Numeric output fields can only be specified on Arrow format numeric series requests. At least one field must be specified. |
400 |
|
|
400 |
|
The compute node was given a starting timestamp after the end of the view range window. |
400 |
|
REFPROP requires exactly two input series. |
400 |
|
|
400 |
|
Invalid tag filter configuration was provided. |
400 |
|
The time unit associated with the series is incompatible with the current transform. |
400 |
|
The Rust UDF source failed validation or compilation. |
400 |
|
Range end must be greater than range start. Range start may only be undefined if in the first range, or the prior end is defined and less. Range end may only be undefined if in the last range, or the next start is defined and greater. Ranges must be in increasing order. |
400 |
|
The maximum query size was exceeded. |
400 |
|
The query exceeded the memory limit. Try querying a smaller time range or fewer series. |
400 |
|
No scatter points could be aligned for plotting. This typically means the input series do not have overlapping timestamps within the configured interpolation window. |
400 |
|
The requested module function could not be executed because a required parameter was not provided. |
400 |
|
The requested module application could not be found. This may be because the reference is incorrect or the application is unavailable in the current execution context. |
400 |
|
The requested module function could not be found. This may be because the reference is incorrect or the function is unavailable in the current execution context. |
400 |
|
|
400 |
|
|
400 |
|
Duration must be strictly positive. |
400 |
|
The resample interval must be strictly positive. |
400 |
|
There were not enough points to fit the curve requested. |
400 |
|
Ranges cannot overlap. Only the first range when sorted may omit the start, and only the last may omit the end. |
400 |
|
The requested time range is too large. Try again with a smaller time range. |
400 |
|
The number of points in the REFPROP inputs is too large. |
400 |
|
The output property cannot be one of the input properties for REFPROP. |
400 |
|
The compute request was cancelled by the user. |
400 |
|
The maximum number of points that can be returned is 10,000. |
400 |
|
The default value provided for resampling does not match the type of the series being resampled. |
400 |
|
|
400 |
|
The query exceeded that limit for number of rows returned. For the query to complete, either zoom in or downsample. |
400 |
|
S3 rejected the request with a TooManyRequests error. Try again with a smaller time range, fewer series, or after a short wait. |
400 |
|
No resolved asset or run branch provides the selected property. |
400 |
|
A resolved branch has the selected property, but its typed variant differs from the numeric or string type required by the series node. |
400 |
|
A SelectSeries node provided both the |
400 |
|
A channel selection (channel name plus tag filters) resolved to zero dataset channels for the requested scope and time range, so the series has nothing to read. Verify the channel exists in the dataset and that the tag filters match at least one channel over the requested range. |
400 |
|
Select tags keys must be a subset of the tags available on the input series. |
400 |
|
The query was rejected because the compute backend is temporarily overloaded. This is a transient, load-shedding response that protects overall availability; the query itself is valid. Callers do not receive this error directly: the read path wraps it in a QoS unavailable response (503), so standard classic REST clients back off and retry automatically. The error type is retained as the 503’s cause for server-side logging and query_log correlation via queryId. |
400 |
|
Lower band cutoff frequency must be less than or equal to upper band cutoff frequency. |
400 |
|
Cutoff frequency must be less than half the sampling frequency. |
400 |
|
Order must be positive even numbers for bidirectional filters. Bidirectional filters are applied once forwards and once backwards, effectively doubling order. Doubled again for bandpass/bandstop filters, requiring a multiple of 4 for filter order. |
400 |
|
Cutoff frequency must be strictly positive. |
400 |
|
Not enough data to apply the filter. Required data scales with filter order. Try again with a larger time range. |
400 |
|
Queries from this source are temporarily blocked. |
400 |
|
The spectrogram input reads from more than one data source or uses an operation spectrograms do not support. |
400 |
|
The query timed out. Try querying a smaller time range or fewer series. |
400 |
|
The operation requires more input series than were provided. |
400 |
|
The number of buckets returned is greater than the max allowed (1000). Try again by specifying a larger bucket width or fewer bucket counts. |
400 |
|
An enum series has more categories than the max allowed. |
400 |
|
Number of events is greater than the max allowed (1000). |
400 |
|
The number of one-sided frequency bins exceeds the maximum allowed. Reduce nfft in transform settings to produce fewer bins. |
400 |
|
Too many literals provided in a literal node. |
400 |
|
The number of points returned is greater than the max allowed. Try again with a smaller time range, or a larger resolution. |
400 |
|
Ranges is greater than the max allowed (2000). |
400 |
|
The resample interval is too short and would produce more than the max points (10,000,000). Try again by specifying a larger interval. |
400 |
|
Asset or run search returned more matches than a single page allows. Refine the query or raise maxResults for the search frame so all matches fit in one page. |
400 |
|
Number of parameterized subrequests is greater than the max allowed (300). |
400 |
|
A value map series contains too many range mappings. |
400 |
|
The requested series type does not support truncation for this compute request. |
400 |
|
A user-defined function exceeded its per-query execution limit while processing this query. Try querying a smaller time range, increasing the aggregation bucket size to reduce the number of UDF invocations, or simplifying the function’s per-row logic. |
400 |
|
A user-defined function exceeded its per-invocation memory limit. |
400 |
|
A user-defined function panicked or aborted at runtime. |
400 |
|
The paired inputs for a calculation do not have the same length. |
400 |
|
The unit conversion could not be computed because the input unit cannot be converted to the output unit. |
400 |
|
|
400 |
|
The specified REFPROP property is not supported or not available in the current configuration. |
400 |
|
The specified REFPROP substance is not supported or not available in the current configuration. |
400 |
|
|
403 |
|
|
500 |
|
The compute backend was temporarily unavailable before the query could be submitted. Retry the request after a short delay. |
500 |
|
There are too many concurrent queries running. |
500 |
|
A native user-defined function was not registered on the when the query executed. This indicates an internal failure rather than invalid user input. |
500 |
|
An unexpected timeout occurred when executing a query. This indicates an internal error where the query may have succeeded but the response did not reach the client. |
Each error’s errorName is ExternalDatabase: followed by its name below.
Status |
Name |
Notes |
|---|---|---|
400 |
|
A gateway timeout was encountered while trying to fetch data from the external database. |
400 |
|
The external database rate limit was exceeded. |
500 |
|
A bad gateway result was encountered while trying to fetch data from the external database. |
500 |
|
A socket timeout was encountered while trying to fetch data from the external database. |
Types#
Abs#
Computes the absolute value of each point in the series.
xNumericSeriesrequiredInput numeric series.
AbsoluteThreshold#
Threshold defined as a real number corresponding the unit of a series.
valueDoubleConstantrequiredAllowed spread, in the series’ own unit.
AbsoluteTimestampSeries#
Replaces values in a series with the absolute timestamps.
Acos#
Computes the arccosine of each value, returning radians.
xNumericSeriesrequiredInput numeric series (values in [-1, 1]).
Add#
Adds two numeric series pointwise.
leftNumericSeriesrequiredLeft-hand operand.
rightNumericSeriesrequiredRight-hand operand.
AfterPersistenceWindow#
The first point in the output range will be the first point after the condition has been true for the min duration and min points.
An empty JSON object, {}.
AggregateEnumSeries#
Aggregates values with duplicate timestamps in the input series values into a single value using the specified aggregation function.
inputEnumSeriesrequired
functionEnumAggregationFunctionrequired
AggregateNumericSeries#
DEPRECATED. Use a dedicated group-by-and-aggregate nodes instead.
Aggregates values with duplicate timestamps in the input series values into a single value using the specified aggregation function.
inputNumericSeriesrequired
functionNumericAggregationFunctionrequired
groupByTagsarray ofStringConstantTags to group by for the aggregation. If left empty, the tags to group by will be equivalent to those in the input series. If specified, the result will be grouped ONLY by the specified tags. The tags specified here MUST be a (non-strict) subset of the input series’s group by tags.
aggregateByAllGroupingsbooleanThis field’s purpose is to distinguish between the two flavors of groupByTags being empty. It has no effect when groupByTags is non-empty. When true and groupByTags is empty, aggregate across all series in the input. When false and groupByTags is empty, the result will be grouped by the same tags as the input series.
interpolationConfigurationInterpolationConfigurationdeprecatedIf provided, interpolates values at timestamps where the input series has values before aggregating. If not provided, only aggregates when timestamps match exactly (existing behavior). Deprecated: Setting interpolation on this node is deprecated.
AggregateUnderRangesSeries#
Aggregates the input series under the ranges in the provided ranges series, and outputs a new series with one point at the start of each range, where the value is the aggregation result. If a range has no points, no point will be produced for it. If a range has no start, the point produced for it will be at the start of the compute request range.
inputNumericSeriesrequired
rangesRangeSeriesrequired
operationNumericAggregationFunctionrequired deprecatedDeprecated: Use a dedicated group-by-and-aggregate node instead (coming in a follow-up PR). This field is retained as required for backwards compatibility with existing callers.
AggregationBuilder#
Set type to the name of one of the other fields, and set only that field.
rollingTimeRollingTimeAggregationBuilder
rollingPointsRollingPointsAggregationBuilder
groupByGroupByAggregationBuilder
Alignment#
Specifies how to set the timestamp grid for multi-input operations.
Set type to the name of one of the other fields, and set only that field.
driverSeriesDriverSeries
unionUnion
AlignmentConfiguration#
interpolationConfigurationInterpolationConfigurationrequiredThe interpolation rules to use when aligning the non-driver series.
driverSeriesAlignmentDriverSeriesrequiredThe series whose timestamps drive alignment.
AlignmentDriverSeries#
FIRST
SECOND
AllowNegativeValues#
An empty JSON object, {}.
AnchorAlignedDataset#
Aligns each anchored portion of the input dataset onto a common anchor timestamp while preserving grouping tags. Without a reference the selected anchor becomes timestamp zero, so the output is in a relative time domain; with a reference the anchors are aligned onto the referenced portion’s anchor and the output stays in the input’s absolute time domain. Currently run boundary, event, and range anchors are supported, and every storage-backed leaf of the input must resolve to run-backed branches.
inputDatasetrequiredThe dataset to align.
anchorDatasetAnchorrequiredSelects the timestamp each anchored portion of the input is aligned by.
referenceAnchorReferenceWhen present, each anchor is aligned onto the referenced anchor timestamp instead of onto timestamp zero, so output remains in the input’s absolute time domain and the referenced portion is unshifted. When absent, the selected anchor becomes timestamp zero.
AnchorReference#
Selects the anchor timestamp every other anchor is aligned onto.
Set type to the name of one of the other fields, and set only that field.
earliestAnchorEarliestAnchorReferenceAligns every anchor onto the earliest anchor resolved from the input, so the earliest-anchored run is unshifted and every other run shifts backwards onto it.
AndSeries#
Combines two boolean series point-wise using logical AND, producing true where both inputs are true and false otherwise.
leftBooleanSeriesrequired
rightBooleanSeriesrequired
ApproximateThresholdOperator#
EQUAL_TO
NOT_EQUAL_TO
ApproximateThresholdRanges#
Produces a list of ranges for which the threshold condition is satisfied.
inputNumericSeriesrequired
thresholdDoubleConstantrequired
toleranceDoubleConstantrequired
operatorApproximateThresholdOperatorrequired
persistenceWindowConfigurationPersistenceWindowConfiguration
ArithmeticSeries#
inputsmap ofLocalVariableNametoNumericSeries
expressionstring required
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
ArraySeries#
Set type to the name of one of the other fields, and set only that field.
numeric1dNumeric1dArraySeries
enum1dEnum1dArraySeries
ArrowArrayPlot#
Set type to the name of one of the other fields, and set only that field.
bucketedNumericBucketedNumericArrayPlot
bucketedEnumBucketedEnumArrayPlot
ArrowPlot#
A generic Arrow IPC plot response. Used for all Arrow-serialized plot types (numeric, bucketed numeric, enum, bucketed enum, struct, bucketed struct, full resolution, and bucketed multivariate).
arrowBinarystring (base64) requiredThe raw binary containing an Arrow IPC stream.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
Asin#
Computes the arcsine of each value, returning radians.
xNumericSeriesrequiredInput numeric series (values in [-1, 1]).
Asset#
Asset reference for Dataset.asset. The rid field accepts either a literal asset RID or a StringConstant reference resolved from Context.
ridStringConstantrequiredResource identifier of an asset
AssetChannel#
assetRidStringConstantrequired
dataScopeNameStringConstantrequiredUsed to disambiguate when multiple data scopes within this asset contain channels with the same name.
channelStringConstantrequired
additionalTagsmap of string toStringConstantdeprecatedDeprecated: Use additionalTagFilters
additionalTagFiltersTagFiltersTags to filter the channel by, in addition to tag filters defined for a given Asset data scope. Throws on collisions with tag keys already defined for the given Asset data scope. Only returns points that match both sets of tag filters. For log series, include arg filters here in addition to tag filters.
tagsToGroupByarray of string deprecatedDeprecated: Use groupByTags instead. Throws if both tagsToGroupBy and groupByTags are specified.
groupByTagsarray ofStringConstantTags that the channel should be grouped by. If this is non-empty a grouped result will be returned with an entry for each grouping. Only one of tagsToGroupBy and groupByTags should be specified.
AssetsSearchTarget#
Search assets. Each match expands to one grouping per data scope on that asset.
queryResourceSearchQueryrequiredPredicate tree used to filter matching assets.
Atan2#
Computes the two-argument arctangent atan2(y, x) using signs to determine the quadrant.
yNumericSeriesrequiredY-coordinate series.
xNumericSeriesrequiredX-coordinate series.
Average#
A average that gives the same weight to each observation inside the time window
An empty JSON object, {}.
BandPassConfiguration#
lowPassbandFrequencyDoubleConstantrequired
highPassbandFrequencyDoubleConstantrequired
BandStopConfiguration#
lowStopbandFrequencyDoubleConstantrequired
highStopbandFrequencyDoubleConstantrequired
BinaryArithmeticOperation#
ATAN2Calculates the angle measure between the x-axis and a ray from the origin to a point (input2, input1) in radians. Note the order of arguments.
BinaryArithmeticSeries#
Applies a point-wise transformation to a pair of series.
input1NumericSeriesrequired
input2NumericSeriesrequired
operationBinaryArithmeticOperationrequired
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
BitAnd#
Applies a bitwise AND between each value (cast to int64) and the operand.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
operandIntegerConstantrequiredThe value to AND with each point.
BitAndFunction#
operandinteger (int64) required
BitOperationFunction#
Set type to the name of one of the other fields, and set only that field.
andBitAndFunction
orBitOrFunction
xorBitXorFunction
shiftRightBitShiftRightFunction
shiftLeftBitShiftLeftFunction
bitTestBitTestFunction
BitOperationSeries#
Casts input series values to long before applying the bitwise operation.
inputNumericSeriesrequired
functionBitOperationFunctionrequired
BitOr#
Applies a bitwise OR between each value (cast to int64) and the operand.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
operandIntegerConstantrequiredThe value to OR with each point.
BitOrFunction#
operandinteger (int64) required
BitShiftLeft#
Left-shifts the bits in each value (cast to int64) by the given number of positions.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
operandIntegerConstantrequiredNumber of positions to shift left.
BitShiftLeftFunction#
Shifts the bits in each value left according to the given operand.
operandinteger required
BitShiftRight#
Right-shifts the bits in each value (cast to int64) by the given number of positions.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
operandIntegerConstantrequiredNumber of positions to shift right.
BitShiftRightFunction#
Right shifts the bits in each value right according to the given operand.
operandinteger required
BitTest#
Returns the bit at the specified index for each value (cast to int64), where index 0 is the least significant bit.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
indexIntegerConstantrequiredZero-based bit index, where 0 is the least significant bit.
BitTestFunction#
Returns the bit at the specified index, where the right-most bit has index 0.
indexinteger required
BitXor#
Applies a bitwise XOR between each value (cast to int64) and the operand.
inputNumericSeriesrequiredInput numeric series (values cast to int64).
operandIntegerConstantrequiredThe value to XOR with each point.
BitXorFunction#
operandinteger (int64) required
Bode#
Returns the bode magnitude and phase of a system’s frequency response.
inputNumericSeriesrequired
outputNumericSeriesrequired
alignmentConfigurationAlignmentConfigurationWhen present, aligns one Bode input to the other using the configured interpolation and driver series before estimating the frequency response. When absent, Bode preserves the existing strict behavior and requires the input and output value arrays to have equal length. For Bode, FIRST uses the input timestamps and SECOND uses the output timestamps.
stftOptionsStftOptions
magnitudeScalingMagnitudeScalingThe scaling to apply to the output magnitude. Defaults to MAGNITUDE_DB_20 if not specified.
outputFrequencyTypeOutputFrequencyTypeThe type of the output frequency. Defaults to LINEAR if not specified.
unwrapPhasebooleanUnwrap the phase of the output. Defaults to true if not specified.
BooleanRanges#
Produces ranges spanning the regions where a boolean input is true.
The condition is evaluated point-wise at each aligned timestamp; the numeric series it compares are aligned against each other the same way arithmetic between them would be.
inputBooleanSeriesrequiredThe condition whose true regions become ranges.
minPointsIntegerConstantMinimum number of matching points. Defaults to 1.
minDurationcompute.api.DurationMinimum matching duration. Defaults to one nanosecond.
rangeStartRangeStartSelects whether the output begins at the first match or after persistence is satisfied.
BooleanSeries#
Set type to the name of one of the other fields, and set only that field.
greaterThanGreaterThanSeries
lessThanLessThanSeries
equalToEqualToSeries
notEqualToNotEqualToSeries
greaterThanOrEqualToGreaterThanOrEqualToSeries
lessThanOrEqualToLessThanOrEqualToSeries
andAndSeries
orOrSeries
BucketedCartesian3dPlot#
bucketsarray ofCartesian3dBucket
BucketedCartesianPlot#
bucketsarray ofCartesianBucket
BucketedEnumArrayPlot#
The array is flattened out into a an arrow stream of bucketed primitive results, with an extra column to indicate the index of the array that the bucket corresponds to.
arrowBinarystring (base64) requiredThe raw binary containing Arrow IPC stream for a bucketed N-dimensional enum array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
BucketedEnumPlot#
timestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofEnumBucket
categoriesarray of string
BucketedFrequencyDomainPlot#
A bucketed/decimated frequency domain plot where multiple frequency bins have been aggregated.
bucketsarray ofFrequencyBucket
BucketedMultivariatePlot#
bucketsarray ofMultivariateBucket
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
BucketedNumericArrayPlot#
The array is flattened out into a an arrow stream of bucketed primitive results, with an extra column to indicate the index of the array that the bucket corresponds to.
arrowBinarystring (base64) requiredThe raw binary containing Arrow IPC stream for a bucketed N-dimensional numeric array plot.
groupByKeysarray of stringThis field specifies the tags that the final output is grouped by. When you combine multiple channels, this list represents the superset of all group by keys used across every individual channel.
BucketedNumericPlot#
timestampsarray ofTimestampThe end of the bucket, exclusive.
bucketsarray ofNumericBucket
BuiltinConstant#
A system-defined constant referenceable by name. The server resolves the symbol to its numeric value during query resolution.
Set type to the name of one of the other fields, and set only that field.
mathMathConstant
physicalPhysicalConstant
BuiltInCurveFit#
A closed-form curve fit (exponential, logarithmic, or power) of the enclosing target (y) against the chosen independent variable (x): either sample time (a time variable) or another series (a numeric variable).
independentVariableCurveFitVariablerequiredThe
xaxis the target is fit against — either relative sample time or another series.
Cartesian#
Set type to the name of one of the other fields, and set only that field.
scatterScatter
Cartesian3d#
Set type to the name of one of the other fields, and set only that field.
scatter3dScatter3d
Cartesian3dBounds#
Min/max bounds of an XYZ Cartesian plot, inclusive.
minXDoubleConstantrequired
maxXDoubleConstantrequired
minYDoubleConstantrequired
maxYDoubleConstantrequired
minZDoubleConstantrequired
maxZDoubleConstantrequired
Cartesian3dBucket#
minXnumber deprecatedDeprecated: Switching to point-based min/maxes
maxXnumber deprecatedDeprecated: Switching to point-based min/maxes
meanXnumber required
minYnumber deprecatedDeprecated: Switching to point-based min/maxes
maxYnumber deprecatedDeprecated: Switching to point-based min/maxes
meanYnumber required
minZnumber deprecatedDeprecated: Switching to point-based min/maxes
maxZnumber deprecatedDeprecated: Switching to point-based min/maxes
meanZnumber required
minXPointPoint3drequired
maxXPointPoint3drequired
minYPointPoint3drequired
maxYPointPoint3drequired
minZPointPoint3drequired
maxZPointPoint3drequired
minTimestampTimestamprequired
maxTimestampTimestamprequired
countinteger (int64) required
Cartesian3dUnitResult#
xUnitResultrequired
yUnitResultrequired
zUnitResultrequired
CartesianBounds#
Min/max bounds of an XY Cartesian plot, inclusive.
minXDoubleConstantrequired
maxXDoubleConstantrequired
minYDoubleConstantrequired
maxYDoubleConstantrequired
CartesianBucket#
CartesianPlot#
timestampsarray ofTimestamp
xValuesarray of number
yValuesarray of number
CartesianUnitResult#
xUnitResultrequired
yUnitResultrequired
CategoricalEqualityRangesV2#
Produces ranges where all categorical inputs are equal or are not all equal.
inputsarray ofEnumSeriesThe series compared against each other. At least two are required.
minPointsIntegerConstantMinimum number of matching points. Defaults to 1.
minDurationcompute.api.DurationMinimum matching duration. Defaults to one nanosecond.
rangeStartRangeStartSelects whether the output begins at the first match or after persistence is satisfied.
equalityOperatorEqualityOperatorrequired
CategoricalOnChangeRangesV2#
Produces a zero-duration range whenever a categorical input changes value.
inputEnumSeriesrequired
CategoricalStaleRangesV2#
Produces ranges where a categorical input has no data for at least a duration.
inputEnumSeriesrequired
thresholdcompute.api.DurationrequiredMinimum gap without data that produces an output range.
CategoryFilterRangesV2#
Produces ranges where a categorical input matches a set of values.
inputEnumSeriesrequired
valuesarray ofStringConstantCategory labels matched against each input point.
minPointsIntegerConstantMinimum number of matching points. Defaults to 1.
minDurationcompute.api.DurationMinimum matching duration. Defaults to one nanosecond.
rangeStartRangeStartSelects whether the output begins at the first match or after persistence is satisfied.
operatorEnumFilterOperatorrequired
ChannelSeries#
Deprecated: prefer SelectSeries-based nodes with an explicit dataset (or VariableValue.series when binding a series to a variable), which select from an arbitrary dataset and let the consuming node decide the series type.
Set type to the name of one of the other fields, and set only that field.
dataSourceDataSourceChannel
assetAssetChannel
runRunChannel
CombinedDataset#
Combines multiple datasets into a single dataset by taking the union of all points from each input (akin to SQL {@code UNION ALL}). Duplicate timestamps are preserved rather than merged; callers that need aggregation should wrap the selected series downstream.
inputsarray ofDatasetThe datasets to combine.
CombineStructSeries#
Combines named input series into one struct-valued series. Each map key becomes a field name in the resulting struct; a downstream UDF receives the struct as a JSON object keyed by these names and parses it itself. Alignment uses the interpolation configuration before producing row-aligned values.
inputsmap of string toSeriesInput series keyed by struct field name.
interpolationConfigurationInterpolationConfigurationdeprecatedOptional interpolation rules used when aligning input series before combining them. Deprecated: Setting interpolation on this node is deprecated.
CompactEnumPoint#
timestampTimestamprequired
valueinteger required
ComputableNode#
Set type to the name of one of the other fields, and set only that field.
rangesSummarizeRanges
seriesSummarizeSeries
valueSelectValue
cartesianSummarizeCartesian
cartesian3dSummarizeCartesian3d
frequencyFrequencyDomain
frequencyV2FrequencyDomainV2
spectrogramSpectrogram
histogramHistogram
curveV2CurveFitV2
curveCurveFit
multivariateSummarizeMultivariate
compute.api.Duration#
A length of time. Can be constructed from literal values in various units or composed via arithmetic. Used for window sizes, time shifts, persistence thresholds, and resampling intervals.
Set type to the name of one of the other fields, and set only that field.
referenceReference
nanosecondsDurationNanoseconds
millisecondsDurationMilliseconds
secondsDurationSeconds
minutesDurationMinutes
hoursDurationHours
daysDurationDays
addDurationAdd
subtractDurationSubtract
negateDurationNegate
ComputeEventQuery#
Set type to the name of one of the other fields, and set only that field.
searchTextStringConstant
afterTimestampConstantFilters to events after this timestamp, exclusive. This includes events that start before, but end after this time.
beforeTimestampConstantFilters to events before this timestamp, exclusive. This includes events that start before, but end after this time.
advancedTimeFilterEventTimeFilter
assetStringConstant
templateStringConstant
workbookStringConstant
dataReviewStringConstant
originTypeSearchEventOriginType
dataReviewCheckStringConstant
dispositionStatusEventDispositionStatus
priorityStringConstant
assigneeStringConstant
eventTypeEventType
createdByStringConstant
labelStringConstant
propertyProperty
andarray ofComputeEventQuery
orarray ofComputeEventQuery
notComputeEventQuery
workspaceStringConstant
procedureStringConstant
procedureExecutionStringConstant
stepIdStringConstant
ComputeNode#
Set type to the name of one of the other fields, and set only that field.
enumEnumSeries
numericNumericSeries
logLogSeries
rangesRangeSeries
arrayArraySeries
structStructSeries
curveFitCurveFitDeprecated: use
curveV2(CurveFitV2) instead.curveV2CurveFitV2
videoReference
rawReferencedeprecatedDeprecated: wrap raw references in a typed compute node.
ComputeNodeRequest#
nodeComputableNoderequired
startTimestamprequiredThe start of the time range (inclusive).
endTimestamprequiredThe end of the time range (inclusive).
contextContextrequired
sourceRidstring (RID)Optional RID identifying the resource that initiated this query (e.g. workbook/notebook RID, checklist RID, dataset RID). Used for observability only — trusted as-is, no permission checks are performed on this value.
requestIdstring (UUID)Optional UUID to provide as a handle to selectively cancel the execution of this compute request.
ComputeNodeResponse#
Set type to the name of one of the other fields, and set only that field.
rangearray ofRange
rangesSummaryRangesSummary
rangeValueRange
numericNumericPlot
bucketedNumericBucketedNumericPlot
numericPointNumericPoint
singlePointSinglePoint
arrowNumericArrowPlot
arrowBucketedNumericArrowPlot
enumEnumPlot
enumPointEnumPoint
bucketedEnumBucketedEnumPlot
arrowEnumArrowPlot
arrowBucketedEnumArrowPlot
pagedLogPagedLogPlot
logPointLogPoint
arrowLogArrowPlot
cartesianCartesianPlot
bucketedCartesianBucketedCartesianPlot
bucketedCartesian3dBucketedCartesian3dPlot
frequencyDomainFrequencyDomainPlot
frequencyDomainV2FrequencyDomainPlotV2
spectrogramSpectrogramPlot
bucketedFrequencyDomainBucketedFrequencyDomainPlot
numericHistogramNumericHistogramPlot
enumHistogramEnumHistogramPlot
curveFitCurveFitResultDeprecated: use
curveFitV2(CurveFitResultV2) instead. Returned only for deprecated CurveFit requests.curveFitV2CurveFitResultV2
groupedGroupedComputeNodeResponses
arrayArrowArrayPlot
bucketedStructArrowPlot
arrowStructArrowPlot
fullResolutionArrowPlot
arrowBucketedMultivariateArrowPlot
multivariateBucketedMultivariatePlot
ComputeNodeResult#
Set type to the name of one of the other fields, and set only that field.
successComputeNodeResponse
errorErrorResult
ComputeNodeWithContext#
seriesNodeComputeNoderequired
contextContextrequired
ComputeUnitResult#
Set type to the name of one of the other fields, and set only that field.
singleUnitResult
cartesianCartesianUnitResult
cartesian3dCartesian3dUnitResult
multivariateMultivariateUnitResult
ComputeUnitsRequest#
nodeComputableNoderequired
contextContextrequired
ComputeWithUnitsResult#
computeResultComputeNodeResultrequired
unitResultComputeUnitResultrequired
ConstantNumericSeries#
A synthetic series that produces a constant value across the entire time range.
Set type to the name of one of the other fields, and set only that field.
doubleDoubleConstantCreate from a floating-point constant.
ContainsSeries#
Maps each log line to 1.0 when operator matches it and 0.0 otherwise.
inputLogSeriesrequired
operatorLogFilterOperatorrequired
Context#
variablesmap ofVariableNametoVariableValue
functionVariablesmap ofFunctionReferencetoFunctionVariablesdeprecatedDeprecated: This field is deprecated and will be removed in a future version.
datasetReferencesmap ofDatasetReferenceNametoDatasetNamed datasets looked up by
DatasetReferencenodes in the compute tree.defaultFillStrategyFillStrategyDefault fill strategy applied at every multi-input alignment boundary where no per-node interpolationConfiguration is specified. When absent, falls back to the server-configured default (forward fill with a 1 second fill limit).
defaultAlignmentStrategyAlignmentDefault alignment strategy applied at every multi-input alignment boundary where no per-node alignment strategy is specified. When absent, falls back to the server default (driver-series alignment).
applyDataScopeOffsetsbooleanWhen true, dataset resolution applies each data scope’s persisted offset as a time shift, and the client must not pre-apply those offsets itself. When absent or false, scope offsets are left to the client, preserving behavior for legacy clients that inject equivalent timeShift nodes into the compute request. Read from the context in scope at resolution time.
resolveAssetsThroughDatasetsbooleanWhen true,
Dataset.asset, the asset-typed sources ofDataset.run, and asset or run search expand through each asset’s mirrored derived dataset instead of its data scopes. Branches then carry the dataset’s declared channel-search split tag keys in place of the reservedDATA_SCOPEtag, so callers must filter and group on those keys; the definition’s own time shifts apply regardless ofapplyDataScopeOffsets; and an asset with no mirrored dataset resolves to no data. When absent or false, assets expand from their data scopes as before.
Cos#
Computes the trigonometric cosine of each value (input in radians).
xNumericSeriesrequiredInput numeric series (radians).
Count#
The number of points inside the time window.
An empty JSON object, {}.
Cpsd#
Returns the cross-spectral density magnitude and phase of the two input series.
xNumericSeriesrequired
yNumericSeriesrequired
stftOptionsStftOptions
magnitudeScalingMagnitudeScalingThe scaling to apply to the output magnitude. Defaults to MAGNITUDE_DB_10 if not specified.
outputFrequencyTypeOutputFrequencyTypeThe type of the output frequency. Defaults to LINEAR if not specified. Changing the output frequency type may also rescale the magnitude of the output in order to ensure the density of the output is consistent.
unwrapPhasebooleanUnwrap the phase of the output. Defaults to true if not specified.
outputPhaseUnitOutputPhaseUnitThe unit of the output phase. Defaults to RADIANS if not specified.
CumulativeSumSeries#
Calculates the running total of the series values.
inputNumericSeriesrequired
startTimestampTimestampConstantrequired
CurveFit#
Deprecated: use CurveFitV2 instead.
curveFitPlotTypeCurveFitPlotTyperequired
curveFitDetailsCurveFitDetailsrequired
curveFitOptionsCurveFitOptionsrequired
CurveFitBoundsConfiguration#
minDoubleConstant
maxDoubleConstant
CurveFitDetails#
Set type to the name of one of the other fields, and set only that field.
exponentialExponentialCurve
logarithmicLogarithmicCurve
polynomialPolynomialCurve
powerPowerCurve
CurveFitOptions#
startTimeTimestampConstantrequired
endTimeTimestampConstantrequired
CurveFitPlotType#
Set type to the name of one of the other fields, and set only that field.
timeSeriesTimeSeriesCurveFit
scatterScatterCurveFit
CurveFitRange#
startTimeTimestampConstantrequired
endTimeTimestampConstantrequired
CurveFitResult#
r2number requiredR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumber requiredMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumber requiredMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumber requiredRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumber requiredMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountinteger requiredThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsrequiredDescription of the fit curve.
CurveFitResultV2#
r2number requiredR^2 (coefficient of determination) for the fit curve, a normalized measure of how well the curve fits the data. Usually ranges from 0 to 1, with higher indicating better fit (points closer to fit line).
maenumber requiredMean Absolute Error (MAE) - the average of the absolute differences between predicted and actual values. Measured in the same units as the y-values.
msenumber requiredMean Squared Error (MSE) - the average of the squared differences between predicted and actual values. Measured in the squared units of the y-values.
rmsenumber requiredRoot Mean Squared Error (RMSE) - the square root of the mean squared error. Measured in the same units as the y-values.
maxAbsoluteErrornumber requiredMaximum Absolute Error - the largest absolute difference between any predicted and actual value. Measured in the same units as the y-values.
sampleCountinteger requiredThe number of data points used in the curve fitting calculation.
curveResultDetailsCurveResultDetailsV2requiredDescription of the fit curve.
CurveFitSeriesVariable#
seriesNumericSeriesrequired
boundsConfigCurveFitBoundsConfigurationOptional inclusive bounds selecting which variable samples are fit. Samples outside the bounds are excluded.
CurveFitTarget#
The series a curve is fit against (the y of the fit). Modeled as a union so additional target types can be added in the future; today the only arm is a numeric series.
Set type to the name of one of the other fields, and set only that field.
numericCurveFitSeriesVariable
CurveFitTimeVariable#
timeUnitTimeUnitThe unit of the time variable in the formula expression. If not specified, the time unit is assumed to be seconds.
CurveFitV2#
targetCurveFitTargetrequiredTarget to fit the equation against.
fitRangeCurveFitRangerequiredThe range to fit the curve over
curveToFitCurveFitV2DetailsrequiredThe curve type to fit against the target series.
CurveFitV2Details#
Set type to the name of one of the other fields, and set only that field.
exponentialBuiltInCurveFit
logarithmicBuiltInCurveFit
polynomialPolynomialCurveFit
powerBuiltInCurveFit
customCustomCurveFit
CurveFitVariable#
A series a curve fit reads from: another numeric series, or the target’s own sample timestamps. Used both as the named formula inputs of a custom fit and as the independent (x) axis of a built-in fit.
Set type to the name of one of the other fields, and set only that field.
numericCurveFitSeriesVariable
timeCurveFitTimeVariable
CurveResultDetails#
Set type to the name of one of the other fields, and set only that field.
exponentialExponentialResultDetails
logarithmicLogarithmicResultDetails
polynomialPolynomialResultDetails
powerPowerResultDetails
CurveResultDetailsV2#
Set type to the name of one of the other fields, and set only that field.
exponentialExponentialResultDetails
logarithmicLogarithmicResultDetails
polynomialPolynomialResultDetails
powerPowerResultDetails
customCustomCurveResultDetails
CustomCurveFit#
formulaStringConstantrequiredA mathematical expression in terms of variable and parameter names, e.g.
a * x + b * sin(x). Variable names must match keys in thevariablesmap; parameter names must match keys in theparametersmap.variablesmap ofLocalVariableNametoCurveFitVariableNamed input series referenced in the formula. Keys must match the variable names used in the formula expression.
parametersmap of string toDoubleConstantNamed fitting parameters and their initial guesses. Keys must match the parameter names used in the formula expression; values are the starting points passed to the optimizer. The target the curve is fit against is the
yof the enclosing curve fit (the timeSeries series values, or the scatteryseries).
CustomCurveResultDetails#
The result of fitting a custom curve, containing the optimized values for each named parameter.
parametersmap of string to numberOptimized parameter values produced by the curve fit. Keys match the parameter names provided in the request.
convergedboolean requiredWhether the optimizer converged to a solution within its iteration limit. When false, the returned parameters are the best estimate found before the iteration cap was reached and did not satisfy the solver’s convergence tolerances.
iterationsinteger requiredNumber of iterations the solver completed.
Dataset#
A logical bundle of named series. For the time being, columns are each a time series (series name + tags). A dataset is either rooted in persisted data (asset or dataset) or defined as a transformation of another dataset.
Set type to the name of one of the other fields, and set only that field.
assetAssetSingle asset. Expands to one grouping per data scope on the asset. Groupings are tagged by
assetRidanddataScopeso callers can safely compose multiple assets withcombine.runRunSingle run. Expands to one grouping per data source attached to the run: asset-typed sources contribute one grouping per data scope on the asset; dataset-typed sources contribute one grouping per dataset. Groupings are tagged by
runRidanddataScope; asset-typed groupings additionally carryassetRidso callers can safely compose multiple runs withcombine.savedSavedDataset
searchSearchDataset
combineCombinedDataset
tagTaggedDataset
filterFilteredDataset
timeShiftTimeShiftedDataset
alignByAnchorAnchorAlignedDataset
withSeriesWithSeriesDataset
dropSeriesDropSeriesDataset
referenceDatasetReference
withDimensionsDimensionsDataset
DatasetAnchor#
Set type to the name of one of the other fields, and set only that field.
runIntervalAnchorUses the start or end of each run as its anchor. The input dataset must resolve exclusively to run-backed branches.
DatasetReference#
References a named dataset in Context.datasetReferences.
nameStringConstantrequiredName of the dataset reference to resolve from the context.
DataSourceAndChannel#
dataSourceRidstring (RID) required
channelstring required
DataSourceChannel#
dataSourceRidStringConstantrequired
channelStringConstantrequired
tagsmap of string toStringConstantdeprecatedDeprecated: Use tagFilters
tagFiltersTagFiltersTags to filter the channel by. Only returns points from the channel where tag values match the provided expression. For log series, include arg filters here in addition to tag filters.
tagsToGroupByarray of string deprecatedDeprecated: Use groupByTags instead. Throws if both tagsToGroupBy and groupByTags are specified.
groupByTagsarray ofStringConstantTags that the channel should be grouped by. If this is non-empty a grouped result will be returned with an entry for each grouping. Only one of tagsToGroupBy and groupByTags should be specified.
DecimateStrategy#
Set type to the name of one of the other fields, and set only that field.
resolutionDecimateWithResolution
bucketsDecimateWithBuckets
DecimateWithBuckets#
bucketsinteger requiredNumber of points to generate in the output series.
DecimateWithResolution#
resolutioninteger (int64) requiredResolution of the output series specifying time interval between decimated points, in nanoseconds.
DerivativeSeries#
Calculates the rate of change between subsequent points.
inputNumericSeriesrequired
timeUnitTimeUnitTime unit used to calculate the derivative. Defaults to seconds if not specified.
negativeValuesConfigurationNegativeValueConfigurationDefines the strategy for handling negative output values. Defaults to allowNegativeValues if not specified.
DerivedSeries#
Represents a derived series within a compute graph. This is a series that is derived from a function within a module.
Set type to the name of one of the other fields, and set only that field.
functionFunctionDerivedSeries
DetrendType#
The type of detrending to apply to the signal. When absent, will default to the detrend behavior for that function.
CONSTANTRemoves the mean value of the signal.
LINEARRemoves a best-fit linear trend from the signal.
NO_OPDoes not perform any detrending.
Dimension#
A value derived per asset or run, injected as a tag.
tagKeyStringConstantThe tag key to inject the value under. Defaults to the key derived by
value.valueDimensionValuerequiredThe value to inject.
DimensionsDataset#
Injects one tag per dimension onto every series of the underlying dataset, valued from the asset or run the series belongs to. This makes resource metadata usable as a grouping, filtering and aggregation dimension with selectTags, tag predicates and groupByTags. Group by the dimension together with ASSET_RID (or RUN_RID) to keep each resource separate, or by the dimension alone to pivot so that resources sharing a value fall into one group.
Dimensions are only supported on asset and run branches. Any other branch, such as a saved dataset or a derived series from withSeries, gets the reserved value NOMINAL_ABSENT for every dimension. To group derived series by a dimension, apply withDimensions to the withSeries input instead, so that the series they are computed from carry the dimension tags. A dimension tag replaces a series tag with the same key.
inputDatasetrequiredThe underlying dataset to tag.
dimensionsarray ofDimensionThe dimensions to inject. Must not be empty, must have at most 10 entries, and every dimension must have a distinct tag key. A tag key must not be a
ReservedTagKey, start withEVENT_LABEL_PREFIX:, or start withNOMINAL_.
DimensionValue#
Set type to the name of one of the other fields, and set only that field.
stringPropertyStringPropertyDimensionThe value of a string property on the asset or run.
identityIdentityDimensionThe value of an asset’s primary key under one of its types.
Divide#
Divides left by right pointwise.
leftNumericSeriesrequiredNumerator.
rightNumericSeriesrequiredDenominator.
DoubleConstant#
A floating-point constant that can be a literal value, a named variable reference, or a named builtin constant.
Set type to the name of one of the other fields, and set only that field.
literalnumberCreate from a literal floating-point value.
variablestringCreate from a named reference name.
builtinBuiltinConstantCreate from a named builtin constant; the server resolves the numeric value.
DriverSeries#
Uses the driver series timestamps as the alignment grid.
An empty JSON object, {}.
DriverSeries3d#
X
Y
Z
DropSeriesDataset#
Removes series from the base dataset by name: raw and derived series alike are no longer selectable under those names. Dropping a name absent from input has no effect. Combined with WithSeriesDataset, which can expose a series under another name, this renames a series: dropSeries(withSeries(input, [newName = select(oldName)]), [oldName]).
inputDatasetrequiredThe base dataset to drop series from.
namesarray ofStringConstantNames of the series to drop.
DurationAdd#
The sum of two durations.
leftcompute.api.DurationrequiredFirst duration.
rightcompute.api.DurationrequiredSecond duration.
DurationConstant#
A duration constant that can be a literal value or a named variable reference.
Set type to the name of one of the other fields, and set only that field.
literalrun.api.DurationCreate from a literal duration value.
variablestringCreate from a named reference name.
DurationDays#
Constructs a duration from a number of days.
daysIntegerConstantrequiredThe number of days.
DurationFilterRanges#
Filters a list of ranges down to only those satisfying a threshold condition on the range’s duration.
inputRangeSeriesrequired
thresholdDurationConstantrequired
operatorThresholdOperatorrequired
unboundedBehaviorUnboundedBehavior
DurationFilterRangesV2#
Filters ranges by duration using an authored Duration expression.
inputRangeSeriesrequired
durationcompute.api.DurationrequiredThe duration each input range is compared against.
unboundedBehaviorUnboundedBehaviorHow a range with an open start or end is measured. Defaults to treating the missing bound as the edge of the compute request window.
comparisonThresholdOperatorrequired
DurationHours#
Constructs a duration from a number of hours.
hoursIntegerConstantrequiredThe number of hours.
DurationMilliseconds#
Constructs a duration from a number of milliseconds.
millisecondsIntegerConstantrequiredThe number of milliseconds.
DurationMinutes#
Constructs a duration from a number of minutes.
minutesIntegerConstantrequiredThe number of minutes.
DurationNanoseconds#
Constructs a duration from a number of nanoseconds. Limited to values within the 32-bit integer range (~2.1 billion ns, or ~2.1 seconds). For larger durations, use DurationSeconds or DurationMilliseconds.
nanosecondsIntegerConstantrequiredThe number of nanoseconds.
DurationNegate#
Negates a duration (reverses its sign).
inputcompute.api.DurationrequiredThe duration to negate.
DurationSeconds#
Constructs a duration from a number of seconds.
secondsIntegerConstantrequiredThe number of seconds.
DurationSubtract#
The difference of two durations (left minus right).
leftcompute.api.DurationrequiredDuration to subtract from.
rightcompute.api.DurationrequiredDuration to subtract.
EarliestAnchorReference#
Selects the earliest anchor resolved from the input.
An empty JSON object, {}.
Empty#
An empty JSON object, {}.
Enum1dArraySeries#
Set type to the name of one of the other fields, and set only that field.
channelChannelSeries
rawReference
derivedDerivedSeries
selectEnum1dArraySelectSeries
extractFromStructExtractEnum1dArrayFromStructSeries
toStartOfIntervalEnum1dArrayToStartOfIntervalSeries
timeShiftEnum1dArrayTimeShiftSeries
filterByTagEnum1dArrayTagFilterSeries
selectTagsEnum1dArraySelectTagsSeries
Enum1dArrayTagFilterSeries#
Applies a tag predicate to the enum 1d array series produced by input.
inputEnum1dArraySeriesrequired
predicateTagPredicaterequired
Enum1dArrayTimeShiftSeries#
inputEnum1dArraySeriesrequired
durationDurationConstantrequired
Enum1dArrayToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputEnum1dArraySeriesrequired
windowcompute.api.Durationrequired
EnumAggregation#
Aggregates an input series using an enum aggregation operator. Rolling aggregation builders are not supported; only the group-by shape is accepted at resolution time. Min and Max require a categorical input series. Udf also accepts a numeric input, which reaches the function as Vec<f64>; a categorical input reaches it as Vec<String>.
inputAggregationBuilderrequiredThe aggregation shape to apply the operator over. Only the group-by shape is supported; rolling builders are rejected at resolution time. The Python
enum_aggregation(...)sugar form is categorical-only. Numeric builders expose the UDF-onlyenum_udf(...)andrust_enum_udf(...)terminals instead.operatorEnumAggregationOperatorrequiredThe enum reduction applied to each group (min, max, or a user-defined function).
EnumAggregationFunction#
Aggregates duplicate timestamps on a single enum series. For aggregating across tag groupings, use EnumSeries.enumAggregation with aggregation.AggregationBuilder.groupBy.
MIN
MAX
EnumAggregationOperator#
Set type to the name of one of the other fields, and set only that field.
minEmpty
maxEmpty
udfEnumAggregationUdf
EnumAggregationUdf#
A user-defined enum aggregation. The supported ABI is a Rust function with one vector input and a String return value. Numeric input series use Vec<f64> and enum input series use Vec<String>.
sourceUdfSourcerequired
EnumBucket#
histogrammap of string to integer (int64)The map of values within the bucket to their frequency.
firstPointCompactEnumPointrequired
lastPointCompactEnumPointWill be empty if the bucket only has a single point.
EnumConstantResampleInterpolationConfiguration#
Fills all empty resample intervals with a single constant value.
If a resampled time interval (bucket) contains no data points from the input, it will be assigned the specified ‘constant’ as a default value. This applies to gaps at the start of the series, between data points, and at the end.
constantStringConstantrequired
EnumCountDuplicateSeries#
Counts the number of points along each timestamp in the input series.
inputsarray ofEnumSeries
EnumFilterOperator#
IS_INTrue when the value is contained in the set.
IS_NOT_INTrue when the value is not contained in the set.
MATCHES_ANY_REGEXTrue when the value matches at least one pattern in the set. Values are RE2 regular expressions, anchored to the entire string.
EnumFilterRanges#
Produces a list of ranges for which the filter condition is satisfied.
inputEnumSeriesrequired
operatorEnumFilterOperatorrequired
valuesStringSetConstantrequiredThe set of literal values (for IS_IN / IS_NOT_IN) or RE2 regex patterns (for MATCHES_ANY_REGEX) to match against.
persistenceWindowConfigurationPersistenceWindowConfiguration
EnumFilterTransformationSeries#
Outputs categorical input values that fall within the supplied ranges.
inputEnumSeriesrequired
filterRangeSeriesrequiredKeeps only input points whose timestamp falls inside one of these ranges.
EnumHistogramBucket#
A bucket in an enum histogram representing all the counts for a specific enumerated value, across all input series.
valuestring requiredThe value of the enum as a string
countsByChannelmap ofVariableNametoHistogramChannelCount
EnumHistogramNode#
inputsmap ofVariableNametoEnumSeries
EnumHistogramPlot#
bucketsarray ofEnumHistogramBucket
EnumMultivariateAggregation#
Aggregations for enum series in multivariate queries.
MODE
EnumNthPointDownsampleSeries#
Keeps every Nth row of the timestamp-ordered input, per series. No grid arithmetic, no interpolation, no boundary handling. Output count is ceil(input_count / n) per series. Caller is responsible for choosing n consistent with the input’s sample rate; output spacing is only uniform when the input is.
inputEnumSeriesrequired
nIntegerConstantrequiredKeep every Nth point starting from the earliest in each series. Must be >= 1.
EnumPlot#
timestampsarray ofTimestamp
valuesarray of integer
categoriesarray of string
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
EnumPoint#
timestampTimestamprequired
valuestring required
EnumResampleConfiguration#
intervalDurationConstantrequiredInterval between resampled points
interpolationEnumResampleInterpolationConfigurationInterpolation strategy to use (defaults to forward fill).
EnumResampleInterpolationConfiguration#
Set type to the name of one of the other fields, and set only that field.
forwardFillResampleInterpolationConfigurationForwardFillResampleInterpolationConfiguration
constantResampleInterpolationConfigurationEnumConstantResampleInterpolationConfiguration
EnumResampleSeries#
Resamples the input series to a new resolution using interpolation. Outputs data for timestamps corresponding to the defined frequency. Based on interpolation strategy, determines range of timestamps to output data for and interpolates values where necessary.
inputEnumSeriesrequired
resampleConfigurationEnumResampleConfigurationrequiredThe interval at which to resample the series and interpolation strategy
EnumResampleSeriesV2#
Resamples categorical points at the authored interval using forward-fill interpolation.
inputEnumSeriesrequired
intervalcompute.api.DurationrequiredInterval at which to resample.
EnumSeries#
Set type to the name of one of the other fields, and set only that field.
aggregateAggregateEnumSeriesdeprecatedDeprecated: AggregateEnumSeries is deprecated. Use
enumAggregationwithaggregation.GroupByAggregationBuilderinstead.rawReference
channelChannelSeries
derivedDerivedSeries
resampleEnumResampleSeries
resampleV2EnumResampleSeriesV2
nthPointDownsampleEnumNthPointDownsampleSeries
timeRangeFilterEnumTimeRangeFilterSeries
timeShiftEnumTimeShiftSeries
timeShiftV2EnumTimeShiftSeriesV2
unionEnumUnionSeries
filterTransformationEnumFilterTransformationSeries
valueMapValueMapSeries
select1dArrayIndexSelectIndexFrom1dEnumArraySeries
extractFromStructExtractEnumFromStructSeries
eventAggregationEventsEnumSeries
enumAggregationEnumAggregation
selectEnumSelectSeries
selectCategoricalPropertySelectProperty
filterByTagEnumTagFilterSeries
selectTagsEnumSelectTagsSeries
scalarUdfScalarUdfSeries
toStartOfIntervalEnumToStartOfIntervalSeries
EnumSeriesEqualityRanges#
Produces a list of ranges for which provided enum series are all equal (or are not all equal).
inputarray ofEnumSeries
equalityOperatorEqualityOperatorrequired
persistenceWindowConfigurationPersistenceWindowConfiguration
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
EnumTagFilterSeries#
Applies a tag predicate to the enum series produced by input.
inputEnumSeriesrequired
predicateTagPredicaterequired
EnumTimeRangeFilterSeries#
Filters the series to points within the specified time range.
inputEnumSeriesrequired
startTimeTimestampConstantRepresents the start time (inclusive) of the time range.
endTimeTimestampConstantRepresents the end time (inclusive) of the time range.
EnumTimeShiftSeries#
inputEnumSeriesrequired
durationDurationConstantrequired
EnumTimeShiftSeriesV2#
Shifts the timestamps in the input series by the resolved duration.
inputEnumSeriesrequired
durationcompute.api.DurationrequiredDuration to shift the input series by.
EnumToNumericSeries#
Maps an enumerated series to a numeric series by mapping each string value to a double.
inputEnumSeriesrequired
mappingmap of string toDoubleConstantThe mapping from enum values to doubles.
defaultValueDoubleConstantThe value to use for enum values not present in the mapping. If not specified, points with unmapped enum values will be dropped.
EnumToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputEnumSeriesrequired
windowcompute.api.Durationrequired
EnumUnionOperation#
THROWThrows an exception if two series contain points with a duplicate timestamp.
MAXAggregates duplicates by String MAX.
MINAggregates duplicates by String MIN.
EnumUnionSeries#
Combines multiple enum series together and outputs a single series. The strategy to merge input values with the same timestamp together is specified in the operation field.
inputarray ofEnumSeries
operationEnumUnionOperationrequiredThe strategy to merge points with duplicate timestamps.
EqualityOperator#
ALL_EQUAL
NOT_ALL_EQUAL
EqualToSeries#
Compares two numeric series point-wise, producing true where left == right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
ErrorResult#
errorTypestring required
codeinteger required
EventAnchor#
Uses the start timestamp of the event at the configured zero-based index from this query whose event time lies in the anchor window [start, end), or [start, +infinity) when the end is absent. The window is the run bounds for a run anchor. Shares the wire shape of numeric.EventTimeShift, which tagByIntervals time shifts use; a separate type so dataset anchors evolve independently.
queryComputeEventQueryrequired
indexIntegerConstantZero-based event index after sorting. Defaults to zero and must be non-negative.
sortOrderEventSortOrderOrdering by event start timestamp before selecting the index. Defaults to ASC.
EventDispositionStatus#
PENDING_REVIEW
CLOSED_IGNORED
CLOSED_REQUIRES_FURTHER_ACTION
NO_DISPOSITION
EventIntervalSource#
Intervals come from an event query. Each event defines [timestamp, timestamp+duration).
queryComputeEventQueryrequired
tagByarray ofEventTagSourceNon-empty ordered list of tag sources. Each contributes a tag key-value pair per event interval.
EventLabelTag#
labelStringConstantrequired
EventLevelTag#
An empty JSON object, {}.
EventPropertyTag#
propertyNameStringConstantrequired
EventsEnumSeries#
Queries events and emits an enum series where each data point corresponds to an event and the enum value is derived from a single event field (property, label, etc).
queryComputeEventQueryrequired
valueSourceEventsEnumValueSourcerequired
EventsEnumValueSource#
Set type to the name of one of the other fields, and set only that field.
propertyStringConstantName of the event property whose value should be used as the enum value.
levelEmptyThe event level (INFO, FLAG, VIOLATION, SUCCESS). This field corresponds to the event type.
EventSortOrder#
ASC
DESC
EventsSearchRanges#
Produces a range series with a range for each event matching the query. Throws if there are more than 1,000 results.
queryComputeEventQueryrequired
EventTimeFilter#
timestampTimestampConstantrequired
timestampConditionEventTimeFilterConditionrequired
EventTimeFilterCondition#
START_TIME_BEFORE_INCLUSIVE
START_TIME_BEFORE_EXCLUSIVE
START_TIME_AFTER_INCLUSIVE
START_TIME_AFTER_EXCLUSIVE
END_TIME_BEFORE_INCLUSIVE
END_TIME_BEFORE_EXCLUSIVE
END_TIME_AFTER_INCLUSIVE
END_TIME_AFTER_EXCLUSIVE
EventTimeShift#
Shift by the start timestamp of the event at the configured zero-based index from this query whose event time lies in the anchor window [start, end), or [start, +infinity) when the end is absent. The window is the tagging interval for tagByIntervals and the run bounds for a run anchor. The query may differ from the query that produced a tagging interval.
queryComputeEventQueryrequired
indexIntegerConstantZero-based event index after sorting. Defaults to zero and must be non-negative.
sortOrderEventSortOrderOrdering by event start timestamp before selecting the index. Defaults to ASC.
EventType#
INFO
FLAG
ERROR
SUCCESS
EveryNthPerSeriesSampling#
Returns every Nth timestamp-ordered point from each distinct series.
nIntegerConstantrequiredKeep every Nth point starting from the earliest in each series. Must be > 1.
ExcludeNegativeValues#
An empty JSON object, {}.
ExponentialCurve#
An empty JSON object, {}.
ExponentialResultDetails#
y = a * e^(b * x)
anumber required
bnumber required
ExtractEnum1dArrayFromStructSeries#
inputStructSeriesrequired
fieldPatharray ofStringConstant
ExtractEnumFromStructSeries#
inputStructSeriesrequired
fieldPatharray ofStringConstantPath segments that are joined to locate a nested enum field. Use dots to traverse objects (e.g.
a.b.c) and 0-based brackets to index into arrays (e.g.items[0].value). A bare numeric name like0refers to an object key named “0”; use[0]to index into an array. Rows where the path is invalid or resolves to a nested object rather than a scalar are filtered out.
ExtractNumeric1dArrayFromStructSeries#
inputStructSeriesrequired
fieldPatharray ofStringConstant
ExtractNumericFromStructSeries#
inputStructSeriesrequired
fieldPatharray ofStringConstantPath segments that are joined to locate a nested numeric field. Use dots to traverse objects (e.g.
a.b.c) and 0-based brackets to index into arrays (e.g.items[0].value). A bare numeric name like0refers to an object key named “0”; use [0] to index into an array. Rows where the path is invalid or the value cannot be converted to the specified type are filtered out.dataTypeNumericDataTypeThe type the numeric data will be cast to, defaults to FLOAT64
ExtractStructFromStructSeries#
inputStructSeriesrequired
fieldPatharray ofStringConstantPath segments that are joined to locate a nested struct field. Use dots to traverse objects (e.g.
a.b.c) and 0-based brackets to index into arrays (e.g.items[0].value). A bare numeric name like0refers to an object key named “0”; use [0] to index into an array. Returns an empty struct when the path does not resolve to a valid JSON object.
ExtremaRangesV2#
Produces ranges for the selected extrema type.
inputNumericSeriesrequired
minimumProminenceDoubleConstantThe minimum topographic prominence for an extrema to be returned.
selectionPeakTyperequired
Fft#
Returns the single sided amplitude spectrum of the input series.
inputNumericSeriesrequired
windowFftWindowWindow function applied to the input series. Defaults to RECT is not specified.
summarizationStrategyFrequencySummarizationStrategyStrategy to downsample the output frequency spectrum.
nfftintegerLength of the FFT. When nfft < input length, the input is truncated to the first nfft samples before windowing and transforming. When nfft > input length, the windowed input is zero-padded up to nfft before transforming. When nfft is unset, defaults to the input length, producing the same result as setting nfft to the input length. The output contains nfft/2 + 1 single-sided frequency bins with spacing fs/nfft. For best performance, prefer a power of 2 (e.g. 512, 1024, 2048).
FftWindow#
BLACKMAN
HANN
HAMMING
RECT
FillLimit#
How far forward in time a sample’s value may be carried.
Set type to the name of one of the other fields, and set only that field.
durationDurationConstant
FillStrategy#
Default strategy for filling gaps when aligning multi-input series.
Set type to the name of one of the other fields, and set only that field.
forwardFillForwardFill
FilterByExpressionSeries#
Keeps points from the base series where the boolean expression evaluates to true. Only outputs timestamps where all input series have an entry for that timestamp, or a value can be filled using the interpolation configuration.
basestring requiredThe variable name for the series that will be returned by this filter. The expression can filter points conditional on multiple series. The base defines which series’ points will be returned after applying all the filters.
inputsmap ofLocalVariableNametoNumericSeriesA map containing all the numeric series present in the expression.
expressionstring requiredAn expression that evaluates to a boolean. For example - a > 5.
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
FilteredDataset#
Applies a conjunctive tag predicate to the series produced by the inner dataset. Resolved by threading tag filters into channel specs and folding against known tag assignments; does not add a resolved numeric node.
inputDatasetrequiredThe underlying dataset to filter.
predicateTagPredicaterequiredConjunctive tag predicate used to keep matching series.
FirstPointMatchingCondition#
The first point in the output range will be the first point where the condition evaluates to true.
An empty JSON object, {}.
FloorDivide#
Divides left by right pointwise and rounds down to the nearest integer.
leftNumericSeriesrequiredNumerator.
rightNumericSeriesrequiredDenominator.
ForwardFill#
At each grid point, carries the most recent prior sample value forward. The value is held only up to the configured limit; grid points with no prior sample within that window are left empty.
limitFillLimitrequired
ForwardFillInterpolation#
interpolationRadiusDurationConstantrequired
ForwardFillResampleInterpolationConfiguration#
Forward fill interpolation for resampling. Rounds the earliest and latest timestamp up to the nearest interval multiple and generates timestamps at the given interval between the new earliest and latest timestamps. For every timestamp in the resampled timestamps, takes the last known value before the timestamp as the value.
An empty JSON object, {}.
FrequencyBucket#
A single bucket in a bucketed frequency domain plot.
frequencyStartnumber requiredThe start frequency of this bucket (inclusive).
frequencyEndnumber requiredThe end frequency of this bucket (exclusive).
frequencyCenternumber requiredThe center frequency of this bucket.
minAmplitudenumber requiredThe minimum amplitude value in this bucket.
maxAmplitudenumber requiredThe maximum amplitude value in this bucket.
meanAmplitudenumber requiredThe mean amplitude value in this bucket.
countinteger (int64) requiredThe number of original frequency points that were aggregated into this bucket.
firstPointFrequencyPointrequiredThe first point (lowest frequency) in this bucket.
lastPointFrequencyPointThe last point (highest frequency) in this bucket. Will be empty if the bucket only has a single point.
FrequencyDecimateWithBuckets#
bucketsinteger requiredTarget number of frequency bins/buckets.
minFrequencynumberOptional minimum frequency bound. When set, frequencies below this value are excluded before bucketing, increasing resolution within the requested range. This bound is inclusive. The bound uses the same unit as the transform’s output frequency.
maxFrequencynumberOptional maximum frequency bound. When set, frequencies above this value are excluded before bucketing, increasing resolution within the requested range. This bound is exclusive. The bound uses the same unit as the transform’s output frequency.
FrequencyDomain#
Set type to the name of one of the other fields, and set only that field.
fftFft
periodogramPeriodogram
FrequencyDomainPlot#
frequenciesarray of number
amplitudesarray of number
FrequencyDomainPlotComplex#
frequenciesarray of number
realarray of number
imaginaryarray of number
FrequencyDomainPlotMagnitudeAndPhase#
frequenciesarray of number
magnitudesarray of number
phasesarray of number
FrequencyDomainPlotV2#
Set type to the name of one of the other fields, and set only that field.
realFrequencyDomainPlot
complexFrequencyDomainPlotComplex
magnitudeAndPhaseFrequencyDomainPlotMagnitudeAndPhase
FrequencyDomainV2#
Set type to the name of one of the other fields, and set only that field.
FrequencyPoint#
A single point in a frequency domain plot.
frequencynumber required
amplitudenumber required
FrequencySummarizationStrategy#
Set type to the name of one of the other fields, and set only that field.
bucketsFrequencyDecimateWithBuckets
FunctionDerivedSeries#
A reference to a derived series resulting from applying a function to a set of arguments.
moduleNameStringConstantrequired
functionNameStringConstantrequired
versionReferenceModuleVersionReferencerequired
functionArgsmap ofFunctionParameterNametoFunctionParameterValueMap of function input names to their values. The function inputs must match the function’s parameter names and types. An input must be specified for each of the referenced function’s parameters.
FunctionParameterValue#
Set type to the name of one of the other fields, and set only that field.
variablestring
valueVariableValue
FunctionVariables#
variablesmap ofVariableNametoVariableValue
subFunctionVariablesmap ofFunctionReferencetoFunctionVariables
GreaterThanOrEqualToSeries#
Compares two numeric series point-wise, producing true where left >= right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
GreaterThanSeries#
Compares two numeric series point-wise, producing true where left > right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
GroupByAggregationBuilder#
Groups points by a tag selection and a timestamp policy and applies the operator.
inputSeriesrequiredThe series to group and aggregate.
tagsGroupByTagsrequiredSelects which tag keys form the grouping key:
GroupByTags.Current()keeps the input series’ currently selected tags, orGroupByTags.Subset([...])restricts the grouping to a subset of them.timestampGroupByTimestamprequiredSelects how timestamps participate in the grouping key:
GroupByTimestamp.Current()groups on existing timestamps, andGroupByTimestamp.Every(duration)buckets points into fixed-size, epoch-aligned tumbling windows.alignmentGroupByAlignmentOptionally aligns source tag groups that map to the same output tag group before aggregation. Alignment is currently supported only with
GroupByTimestamp.Current()and built-in numeric aggregation operators.
GroupByAlignment#
Selects how source tag groups are aligned before aggregation.
Set type to the name of one of the other fields, and set only that field.
contextDefaultsEmptyUse the compute context’s
defaultAlignmentStrategyanddefaultFillStrategy.
GroupByTimestamp#
Selects how timestamps participate in the grouping key.
Set type to the name of one of the other fields, and set only that field.
currentEmptyUse the current timestamps.
everycompute.api.DurationBucket timestamps into a tumbling fixed-size, epoch-aligned window. A point at timestamp
t(nanoseconds) falls into the bucket[floor(t / window) * window, +window), and one aggregated point is emitted per bucket per tag grouping at the bucket start timestamp.
GroupedComputeNodeResponse#
groupingGroupingrequired
responseComputeNodeResponserequired
GroupedComputeNodeResponses#
Contains a ComputeNodeResponse for each applicable grouping along with metadata describing the grouping. All the contained ComputeNodeResponses are guaranteed to be of the same type.
responsesarray ofGroupedComputeNodeResponse
Grouping#
Set type to the name of one of the other fields, and set only that field.
tagsWithValuesmap of string to stringA grouping identified by a specific instantiation of tag keys and values.
GroupWithinRangesSeriesV2#
Aggregates the input series within each supplied range and emits one point at the range start. Empty ranges emit no point, and ranges without a start use the compute request start.
inputNumericSeriesrequired
rangesRangeSeriesrequiredOne output point is emitted per range, at the range’s start.
aggregationNumericAggregationOperatorrequired
HashSubsampleSampling#
Keeps approximately 1/N of raw points via a stateless hash of each point’s timestamp.
nIntegerConstantrequiredKeep approximately one out of every N points. Must be > 1.
HighPassConfiguration#
cutoffFrequencyDoubleConstantrequired
Histogram#
Set type to the name of one of the other fields, and set only that field.
numericNumericHistogramNode
enumEnumHistogramNode
HistogramChannelCount#
The count of the value in the bucket for the specific channel.
countinteger (int64) required
IdentityDimension#
Injects the value of a type’s primary key, under a tag key equal to the primary key’s property name by default. The primary key is read when the query runs, so it follows changes to the type. Only asset branches of an asset with the type have a value; every other branch, including run branches, gets the reserved value NOMINAL_ABSENT.
typeRidStringConstantrequiredResource identifier of the type whose primary key identifies the asset.
IncompatibleUnitOperation#
Attempted an incompatible operation of units.
operationUnitOperationrequired
unitsarray of string
IntegerConstant#
An integer constant that can be a literal value or a named variable reference.
Set type to the name of one of the other fields, and set only that field.
literalintegerCreate from a literal integer value.
variablestringCreate from a named reference name.
IntegralSeries#
Calculates the running sum of the area underneath a series using the trapezoidal rule.
inputNumericSeriesrequired
startTimestampTimestampConstantrequired
timeUnitTimeUnitTime unit used to calculate the integral. Defaults to seconds if not specified.
InterpolationConfiguration#
Set type to the name of one of the other fields, and set only that field.
forwardFillInterpolationForwardFillInterpolation
IntersectRanges#
Produces the intersection of the input ranges: the ranges of time covered by every input. For best performance, pass inputs in the order in which they should be evaluated, listing the ranges that are cheapest to compute first.
inputsarray ofRangeSeries
IntervalAnchor#
Selects which boundary of an interval to use as its anchor.
Set type to the name of one of the other fields, and set only that field.
intervalStartIntervalStartTimeShiftUses the interval’s start timestamp.
intervalEndIntervalEndTimeShiftUses the interval’s end timestamp.
eventInIntervalEventAnchor
rangeInIntervalRangesAnchor
IntervalEndTimeShift#
Shift by each tagging interval’s resolved end; resolution throws if end is missing.
An empty JSON object, {}.
IntervalIndexTag#
An empty JSON object, {}.
IntervalSource#
Where the intervals come from and how each is labeled.
Set type to the name of one of the other fields, and set only that field.
eventsEventIntervalSource
rangesRangeIntervalSource
IntervalStartTimeShift#
Shift by each tagging interval’s resolved start; resolution throws if start is missing.
An empty JSON object, {}.
IntervalStartTimestampTag#
An empty JSON object, {}.
LabelsFilter#
operatorSetOperatorrequired
labelsarray of string
LessThanOrEqualToSeries#
Compares two numeric series point-wise, producing true where left <= right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
LessThanSeries#
Compares two numeric series point-wise, producing true where left < right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
LiteralRange#
A literal range of values.
startTimestampTimestampConstant
endTimestampTimestampConstant
tagsmap of string to string
LiteralRanges#
A list of literal ranges.
literalRangesarray ofLiteralRange
Ln#
Computes the natural logarithm (base e) of each value.
xNumericSeriesrequiredInput numeric series (positive values).
Log10#
Computes the base-10 logarithm of each value.
xNumericSeriesrequiredInput numeric series (positive values).
LogArgFilterOperator#
Matches against a single log arg.
keyStringConstantrequired
operatorLogRegexFilterOperatorrequired
LogarithmicCurve#
An empty JSON object, {}.
LogarithmicResultDetails#
y = a * ln(x) + b
anumber required
bnumber required
LogExactMatchCaseInsensitiveFilter#
Filters points such that the log message in each point contains an exact case-insensitive match of the provided token.
tokenstring required
LogFilterOperator#
Set type to the name of one of the other fields, and set only that field.
regexFilterLogRegexFilterOperator
exactMatchCaseInsensitiveFilterLogExactMatchCaseInsensitiveFilter
argLogArgFilterOperator
andarray ofLogFilterOperator
orarray ofLogFilterOperator
notLogFilterOperator
LogFilterSeries#
Outputs only values of the log plot that satisfy the filter.
inputLogSeriesrequired
operatorLogFilterOperatorrequired
LogPoint#
LogRegexFilterOperator#
Matches a text value against the given re2 regular expression. Regular expression syntax: https://github.com/google/re2/wiki/Syntax.
regexstring required
LogSeries#
Set type to the name of one of the other fields, and set only that field.
rawReference
channelChannelSeries
derivedDerivedSeries
selectLogsSelectSeries
unionLogUnionSeries
filterLogFilterSeries
timeShiftLogTimeShiftSeries
toStartOfIntervalLogToStartOfIntervalSeries
filterByTagLogTagFilterSeries
selectTagsLogSelectTagsSeries
LogTagFilterSeries#
Applies a tag predicate to the log series produced by input.
inputLogSeriesrequired
predicateTagPredicaterequired
LogTimeShiftSeries#
inputLogSeriesrequired
durationDurationConstantrequired
LogToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputLogSeriesrequired
windowcompute.api.Durationrequired
LogUnionOperation#
KEEP_ALLKeeps all points if multiple series contain points with a duplicate timestamp.
LogUnionSeries#
Combines multiple log series together and outputs a single series. The strategy to merge input values with the same timestamp together is specified in the operation field.
inputarray ofLogSeries
operationLogUnionOperationrequiredThe strategy to merge points with duplicate timestamps.
LogValue#
messagestring required
argsmap of string to string
idstring (UUID) required
LowPassConfiguration#
cutoffFrequencyDoubleConstantrequired
LttbStrategy#
maxPointsPerGroupinteger requiredMaximum number of selected points to return for each group. Must be positive and no greater than 10,000.
MagnitudeScaling#
LINEARLinear scaling of the magnitude.
MAGNITUDE_DB_10Scales the magnitude via 10 * log10(magnitude).
MAGNITUDE_DB_20Scales the magnitude via 20 * log10(magnitude).
MathConstant#
Math constants referenceable by name.
PIThe circle constant π (dimensionless).
TAUThe circle constant τ = 2π (dimensionless).
EEuler’s number e (dimensionless).
Maximum#
The maximum value of points inside the time window.
An empty JSON object, {}.
MaxSeries#
For every timestamp specified in the input series, outputs a value that is the maximum for that timestamp across all input series. Only outputs timestamps where all input series have an entry for that timestamp, subject to interpolation.
inputsarray ofNumericSeriesInput series across which to take the pointwise maximum
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
MeanSeries#
For every timestamp specified in the input series, outputs a value that is the mean for that timestamp across all input series. Only outputs timestamps where all input series have an entry for that timestamp, subject to interpolation.
inputsarray ofNumericSeriesInput series across which to take the pointwise mean
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
Minimum#
The minimum value of points inside the time window.
An empty JSON object, {}.
MinMaxThresholdOperator#
OUTSIDE_BOUNDS
OUTSIDE_OR_EQUAL_TO_BOUNDS
INSIDE_BOUNDS
INSIDE_OR_EQUAL_TO_BOUNDS
MinMaxThresholdRanges#
Produces a list of ranges for which the threshold condition is satisfied.
inputNumericSeriesrequired
lowerBoundDoubleConstantrequired
upperBoundDoubleConstantrequired
operatorMinMaxThresholdOperatorrequired
persistenceWindowConfigurationPersistenceWindowConfiguration
MinSeries#
For every timestamp specified in the input series, outputs a value that is the minimum for that timestamp across all input series. Only outputs timestamps where all input series have an entry for that timestamp, subject to interpolation.
inputsarray ofNumericSeriesInput series across which to take the pointwise minimum
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
ModuleVersionReference#
Set type to the name of one of the other fields, and set only that field.
pinnedPinnedModuleVersionReference
Modulo#
Computes the remainder of left divided by right pointwise.
leftNumericSeriesrequiredDividend.
rightNumericSeriesrequiredDivisor.
Multiply#
Multiplies two numeric series pointwise.
leftNumericSeriesrequiredLeft-hand operand.
rightNumericSeriesrequiredRight-hand operand.
MultivariateBucket#
MultivariateEnumInput#
seriesEnumSeriesrequired
aggregationsarray ofEnumMultivariateAggregation
MultivariateInput#
Set type to the name of one of the other fields, and set only that field.
numericMultivariateNumericInput
enumMultivariateEnumInput
MultivariateNumericInput#
seriesNumericSeriesrequired
aggregationsarray ofNumericMultivariateAggregation
MultivariateUnitResult#
unitsarray ofUnitResult
NamedSeries#
nameStringConstantrequiredName of the new derived series.
definitionSeriesrequiredCompute expression defining the series values.
Negate#
Negates each value in the series pointwise (multiplies by -1).
xNumericSeriesrequiredInput numeric series.
NegativeValueConfiguration#
Set type to the name of one of the other fields, and set only that field.
allowNegativeValuesAllowNegativeValuesInclude negative output values
setNegativeValuesToZeroSetNegativeValuesToZeroSet negative output values to zero
excludeNegativeValuesExcludeNegativeValuesExclude points with negative output values
NotEqualToSeries#
Compares two numeric series point-wise, producing true where left != right and false otherwise.
leftNumericSeriesrequired
rightNumericSeriesrequired
NotRanges#
The not ranges node will invert the ranges, filling the negative space in time.
inputRangeSeriesrequired
NthRange#
Select the Nth range (0-indexed) from a range series.
inputRangeSeriesrequired
indexIntegerConstantrequired
sortOrderRangeSortOrderrequired
Numeric1dArraySeries#
Set type to the name of one of the other fields, and set only that field.
channelChannelSeries
rawReference
derivedDerivedSeries
selectNumeric1dArraySelectSeries
extractFromStructExtractNumeric1dArrayFromStructSeries
toStartOfIntervalNumeric1dArrayToStartOfIntervalSeries
timeShiftNumeric1dArrayTimeShiftSeries
filterByTagNumeric1dArrayTagFilterSeries
selectTagsNumeric1dArraySelectTagsSeries
Numeric1dArrayTagFilterSeries#
Applies a tag predicate to the numeric 1d array series produced by input.
inputNumeric1dArraySeriesrequired
predicateTagPredicaterequired
Numeric1dArrayTimeShiftSeries#
inputNumeric1dArraySeriesrequired
durationDurationConstantrequired
Numeric1dArrayToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputNumeric1dArraySeriesrequired
windowcompute.api.Durationrequired
NumericAggregation#
Aggregates an input series using the given operator. The shape of the aggregation (rolling time window, rolling point-count window, or group by) is selected by the aggregation builder passed as input. The operator must be compatible with that builder’s series, producing a numeric output: count reduces a series of any type, whereas SUM requires a numeric series.
inputAggregationBuilderrequiredThe aggregation shape to apply the operator over: a rolling time window, a rolling point-count window, or a group-by.
operatorNumericAggregationOperatorrequiredThe reduction applied to each window or group (e.g. sum, mean, percentile). Must be compatible with the input series, producing a numeric output: Count works on any input series, whereas reductions like Sum require a numeric series.
NumericAggregationFunction#
DEPRECATED. Use NumericAggregationOperator instead.
SUM
MEAN
MIN
MAX
COUNT
STANDARD_DEVIATION
ROOT_MEAN_SQUARE
NumericAggregationOperator#
Unified numeric aggregation used across rolling windows, plain aggregates, range aggregates, union merges, and per-bucket summarization.
Set type to the name of one of the other fields, and set only that field.
sumSummation
averageAverage
minMinimum
maxMaximum
countCount
standardDeviationStandardDeviation
rootMeanSquareRootMeanSquare
percentilePercentile
udfNumericAggregationUdf
NumericAggregationUdf#
A user-defined numeric aggregation. The aggregation builder controls grouping/windowing. Supported Rust entrypoints accept grouped value vectors, optionally with leading sample timestamps, and return either one numeric value or timestamped numeric point(s), e.g. fn rms(values: Vec<f64>) -> f64, fn energy(timestamp_ns: Vec<i64>, values: Vec<f64>) -> f64, fn first(timestamp_ns: Vec<i64>, values: Vec<f64>) -> (i64, f64), or fn passthrough(timestamp_ns: Vec<i64>, values: Vec<f64>) -> Vec<(i64, f64)>. The value vector’s element type follows the aggregated series: Vec<f64> for a numeric series, and Vec<String> for a categorical or struct series, where each struct row arrives as a JSON object. A UDF over a combined struct series may instead take one vector per named struct field it needs, e.g. fn mean_product(channel0: Vec<f64>, channel1: Vec<f64>) -> f64. Parameter names select the fields, so a subset of the struct’s fields in any order is accepted.
sourceUdfSourcerequired
NumericApproximateFilterSeries#
Outputs the values of the numeric plot value that are approximately equal to the threshold value.
inputNumericSeriesrequired
thresholdDoubleConstantrequired
toleranceDoubleConstantrequired
operatorApproximateThresholdOperatorrequired
NumericBucket#
minnumber
maxnumber
meannumber
countinteger (int64)
variancenumberThe population variance of the bucket. If the bucket has only one value, this will be 0.
firstPointNumericPoint
lastPointNumericPointWill be empty if the bucket only has a single point.
aggregationsmap of string to numberAdditional per-bucket aggregations that have no dedicated field above, keyed by the output column name requested via
numericAggregationsornumericOutputFieldsV2(e.g.sum,standardDeviation,rootMeanSquare,p50). Empty when no additional aggregations were requested.
NumericConstantResampleInterpolationConfiguration#
Fills all empty resample intervals with a single constant value.
If a resampled time interval (bucket) contains no data points from the input, it will be assigned the specified ‘constant’ as a default value. This applies to gaps at the start of the series, between data points, and at the end.
constantDoubleConstantrequired
NumericDataType#
Supported numeric data types for value casting.
INT64
FLOAT64
UINT64
NumericEqualityRangesV2#
Produces ranges where all numeric inputs are equal or are not all equal.
inputsarray ofNumericSeriesThe series compared against each other. At least two are required.
toleranceDoubleConstantMaximum spread between the inputs still counted as equal. Defaults to zero, i.e. exact equality.
minPointsIntegerConstantMinimum number of matching points. Defaults to 1.
minDurationcompute.api.DurationMinimum matching duration. Defaults to one nanosecond.
rangeStartRangeStartSelects whether the output begins at the first match or after persistence is satisfied.
equalityOperatorEqualityOperatorrequired
NumericFilterTransformationSeries#
Outputs the input points whose timestamps fall within the supplied ranges.
inputNumericSeriesrequired
filterRangeSeriesrequiredKeeps input points whose timestamps fall inside any of these ranges.
NumericFilterWhereSeries#
Outputs numeric input values where the provided Boolean expression evaluates to true.
inputNumericSeriesrequired
conditionBooleanSeriesrequiredCondition evaluated point-wise at each input timestamp. A point is only kept where the condition is true.
NumericHistogramBucket#
A bucket in a numeric histogram representing a range of values, and the counts of values in that range across all input series.
lowerBoundnumber requiredThe lower bound of the bucket, inclusive
upperBoundnumber requiredThe upper bound of the bucket, exclusive
countsByChannelmap ofVariableNametoHistogramChannelCount
bucketsmap ofVariableNametoHistogramChannelCountdeprecatedDeprecated: Use countsByChannel instead
NumericHistogramBucketStrategy#
Set type to the name of one of the other fields, and set only that field.
bucketCountIntegerConstantThe number of buckets to use in the histogram. Width is automatically calculated from the range of the input series, with the lower and upper bounds of the histogram being multiples of the width.
bucketWidthAndOffsetNumericHistogramBucketWidthAndOffset
NumericHistogramBucketWidthAndOffset#
widthDoubleConstantrequiredThe width of each bucket. If offset is not specified, the left and right bounds of each bucket are multiples of the width. If offset is specified, the left and right bounds of each bucket are shifted right by the offset value.
offsetDoubleConstantThe rightward shift to apply to the left and right bounds of each bucket. If not specified, the offset will be 0. The offset must be non-negative.
NumericHistogramNode#
inputsmap ofVariableNametoNumericSeries
bucketStrategyNumericHistogramBucketStrategy
NumericHistogramPlot#
bucketsarray ofNumericHistogramBucket
NumericIfElseSeries#
Selects between two numeric series point-wise based on a boolean condition series. For every aligned timestamp, emits the value from trueValue where condition is true, and the value from falseValue otherwise.
conditionBooleanSeriesrequiredBoolean series evaluated at each point to choose between the
trueValueandfalseValuebranches.trueValueNumericSeriesrequiredValue emitted at points where
conditionis true.falseValueNumericSeriesrequiredValue emitted at points where
conditionis false.
NumericLargestTriangleThreeBucketsSeries#
Applies Largest-Triangle-Three-Buckets to a numeric time series for visualization-oriented downsampling. The algorithm preserves the first and last points, partitions the remaining input points based on the requested output count, and selects points that preserve the visual shape of the series. Results are selected input timestamp/value points, not fixed-width bucket aggregate rows.
inputNumericSeriesrequired
maxPointsToReturnIntegerConstantrequiredMaximum number of selected points to return. Must be positive and no greater than 10,000.
NumericMultivariateAggregation#
MEAN
MIN
MAX
FIRST
LAST
NumericNanFilter#
Removes points where the value is NaN from the input series.
inputNumericSeriesrequiredInput numeric series.
NumericNthPointDownsampleSeries#
Keeps every Nth row of the timestamp-ordered input, per series. No grid arithmetic, no interpolation, no boundary handling. Output count is ceil(input_count / n) per series. Caller is responsible for choosing n consistent with the input’s sample rate; output spacing is only uniform when the input is.
inputNumericSeriesrequired
nIntegerConstantrequiredKeep every Nth point starting from the earliest in each series. Must be >= 1.
NumericOutputField#
MIN
MAX
MEAN
COUNT
VARIANCE
FIRST_POINT
LAST_POINT
NumericOutputFieldV2#
Numeric bucket output field requested by the caller.
Set type to the name of one of the other fields, and set only that field.
fieldNumericOutputFieldV2Name
percentileNumericOutputPercentile
NumericOutputFieldV2Name#
MIN
MAX
MEAN
COUNT
VARIANCE
FIRST_POINT
LAST_POINT
SUM
STANDARD_DEVIATION
ROOT_MEAN_SQUARE
NumericOutputPercentile#
percentileDoubleConstantrequiredPercentile to compute, in range [0, 1].
outputNamestringOptional output column name. Defaults to pXX, e.g. p95 for 0.95.
NumericPlot#
timestampsarray ofTimestamp
valuesarray of number
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
NumericPoint#
timestampTimestamprequired
valuenumber required
NumericPropertyPredicate#
Matches resources that have a numeric value for the named property and whose value satisfies the operator. NEQ excludes resources that lack the property or store a string value under the same name.
namestring required
valuenumber required
operatorPropertyComparisonOperatorrequired
NumericPropertyRangeOperator#
BETWEEN
NOT_BETWEEN
NumericPropertyRangePredicate#
Inclusive range on a numeric property. At least one bound is required. BETWEEN: min <= x <= max. An absent bound is unbounded on that side. NOT_BETWEEN: x < min OR x > max. An absent bound drops that side. Both operators require a numeric value for name. Missing properties and string values never match. Bounds are closed [min, max] to match the number chip (is between / is not between), not half-open.
namestring required
minnumber
maxnumber
operatorNumericPropertyRangeOperatorrequired
NumericResampleConfiguration#
intervalDurationConstantrequiredInterval between resampled points
interpolationNumericResampleInterpolationConfigurationInterpolation strategy to use (defaults to forward fill).
NumericResampleInterpolationConfiguration#
Set type to the name of one of the other fields, and set only that field.
forwardFillResampleInterpolationConfigurationForwardFillResampleInterpolationConfiguration
constantResampleInterpolationConfigurationNumericConstantResampleInterpolationConfiguration
NumericResampleSeries#
Resamples the input series to a new resolution using interpolation. Outputs data for timestamps corresponding to the defined frequency. Based on interpolation strategy, determines range of timestamps to output data for and interpolates values where necessary.
inputNumericSeriesrequired
resampleConfigurationNumericResampleConfigurationrequiredThe interpolation strategy and interval at which to resample the series
NumericResampleSeriesV2#
Resamples the input series at the authored interval using forward-fill.
inputNumericSeriesrequired
intervalcompute.api.DurationrequiredInterval at which to resample.
NumericSeries#
Set type to the name of one of the other fields, and set only that field.
absAbs
negateNegate
cosCos
sinSin
tanTan
acosAcos
asinAsin
lnLn
log10Log10
sqrtSqrt
addAdd
subtractSubtract
multiplyMultiply
divideDivide
floorDivideFloorDivide
powerPower
moduloModulo
atan2Atan2
maxMaxSeries
meanMeanSeries
minMinSeries
sumSumSeries
unionNumericUnionSeries
productProductSeries
constantConstantNumericSeries
selectNewestPointsSelectNewestPointsSeries
selectNumericSelectSeries
selectNumericPropertySelectProperty
selectOldestPointsSelectOldestPointsSeries
bitAndBitAnd
bitOrBitOr
bitXorBitXor
bitShiftRightBitShiftRight
bitShiftLeftBitShiftLeft
bitTestBitTest
ifElseNumericIfElseSeries
numericAggregationNumericAggregation
countDuplicateEnumCountDuplicateSeries
cumulativeSumCumulativeSumSeries
derivativeDerivativeSeries
integralIntegralSeries
zScoreZscoreSeries
rawReference
derivedDerivedSeries
resampleNumericResampleSeries
resampleV2NumericResampleSeriesV2
nthPointDownsampleNumericNthPointDownsampleSeries
largestTriangleThreeBucketsNumericLargestTriangleThreeBucketsSeries
signalFilterSignalFilterSeries
timeDifferenceTimeDifferenceSeries
absoluteTimestampAbsoluteTimestampSeries
timeRangeFilterNumericTimeRangeFilterSeries
timeShiftNumericTimeShiftSeries
timeShiftV2NumericTimeShiftSeriesV2
unitConversionUnitConversionSeries
unitOverrideUnitOverrideSeries
valueDifferenceValueDifferenceSeries
filterTransformationNumericFilterTransformationSeries
filterWhereNumericFilterWhereSeries
thresholdFilterNumericThresholdFilterSeries
approximateFilterNumericApproximateFilterSeries
dropNanNumericNanFilter
select1dArrayIndexSelectIndexFrom1dNumericArraySeries
aggregateUnderRangesAggregateUnderRangesSeries
rangeDurationRangeDurationSeries
groupWithinRangesV2GroupWithinRangesSeriesV2
filterByExpressionFilterByExpressionSeries
scalarUdfScalarUdfSeries
enumToNumericEnumToNumericSeries
containsContainsSeries
refpropRefpropSeries
refpropV2RefpropSeriesV2
extractFromStructExtractNumericFromStructSeries
tagByIntervalsTagByIntervalsSeries
filterByTagNumericTagFilterSeries
selectTagsNumericSelectTagsSeries
toStartOfIntervalNumericToStartOfIntervalSeries
phaseUnwrapPhaseUnwrapSeries
aggregateAggregateNumericSeriesdeprecatedDeprecated: AggregateNumericSeries is deprecated. Use
numericAggregationwithaggregation.GroupByAggregationBuilderinstead.rollingOperationRollingOperationSeriesdeprecatedDeprecated: RollingOperationSeries is deprecated. Use
numericAggregationwithaggregation.RollingTimeAggregationBuilderinstead.bitOperationBitOperationSeriesdeprecatedDeprecated: BitOperationSeries is deprecated in favor of individual nodes for each operation.
channelChannelSeriesdeprecatedDeprecated: Deprecated in favor of the SelectSeries node
offsetOffsetSeriesdeprecatedDeprecated: OffsetSeries is deprecated in favor of add with a constant.
scaleScaleSeriesdeprecatedDeprecated: ScaleSeries is deprecated in favor of multiply with a constant.
arithmeticArithmeticSeriesdeprecatedDeprecated: ArithmeticSeries is deprecated in favor of individual nodes for each operation.
unaryArithmeticUnaryArithmeticSeriesdeprecatedDeprecated: UnaryArithmeticSeries is deprecated in favor of individual nodes for each operation.
binaryArithmeticBinaryArithmeticSeriesdeprecatedDeprecated: BinaryArithmeticSeries is deprecated in favor of individual nodes for each operation.
NumericStaleRangesV2#
Produces ranges where a numeric input has no data for at least a duration.
inputNumericSeriesrequired
thresholdcompute.api.DurationrequiredMinimum gap without data that produces an output range.
NumericTagFilterSeries#
Applies a tag predicate to the numeric series produced by input.
inputNumericSeriesrequired
predicateTagPredicaterequired
NumericThresholdFilterSeries#
Outputs only the values of the numeric plot value that satisfy the threshold condition.
inputNumericSeriesrequired
thresholdDoubleConstantrequired
operatorThresholdOperatorrequired
NumericTimeRangeFilterSeries#
Filters the series to points within the specified time range.
inputNumericSeriesrequired
startTimeTimestampConstantRepresents the start time (inclusive) of the time range.
endTimeTimestampConstantRepresents the end time (inclusive) of the time range.
NumericTimeShiftSeries#
inputNumericSeriesrequired
durationDurationConstantrequired
NumericTimeShiftSeriesV2#
Shifts the timestamps in the input series by the resolved duration.
inputNumericSeriesrequired
durationcompute.api.DurationrequiredDuration to shift the input series by.
NumericToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputNumericSeriesrequired
windowcompute.api.Durationrequired
NumericUnionOperation#
DEPRECATED: apply aggregations as a separate step over the unioned output.
MINCombines multiple points by taking the minimum value
MAXCombines multiple points by taking the maximum value
MEANCombines multiple points by taking the mean of the values
SUMCombines multiple points by taking the sum of the values
COUNTCombines multiple points by taking the count of the values
STANDARD_DEVIATIONCombines multiple points by taking the standard deviation of the values
ROOT_MEAN_SQUARECombines multiple points by taking the root mean square of the values
THROWThrows a DuplicateTimestamp error if two series contain points with a duplicate timestamp.
NumericUnionSeries#
Combines multiple numeric series together and outputs a single series. By default, points from the inputs are concatenated (SQL {@code UNION ALL}) and duplicate timestamps across inputs are preserved. To aggregate values that share a timestamp, do a separate aggregation step next.
inputarray ofNumericSeriesInput series to union
operationNumericUnionOperationdeprecatedThe strategy to merge points with duplicate timestamps. Deprecated: Apply aggregations as a separate step over the unioned output.
Nyquist#
Returns a complex-valued frequency response, H(f), of the input series to the output series.
inputNumericSeriesrequired
outputNumericSeriesrequired
stftOptionsStftOptions
OffsetSeries#
For every timestamp specified in the input series, offset it by a constant factor.
inputNumericSeriesrequired
scalarDoubleConstantrequiredThe constant to add to each point
OnChangeRanges#
Produces a list of ranges for each point that has a different value to the previous point. A range will have identical start and end times.
inputSeriesrequired
OrSeries#
Combines two boolean series point-wise using logical OR, producing true where either input is true and false otherwise.
leftBooleanSeriesrequired
rightBooleanSeriesrequired
OutputFormat#
ARROW_V4
ARROW_V3
LEGACY
OutputFrequencyType#
LINEARFrequency in Hertz.
ANGULARFrequency in radians per second.
NORMALIZED_LINEARNormalized frequency, in the range [0, 0.5] for real-valued signals.
NORMALIZED_ANGULARNormalized angular frequency, in the range [0, π] for real-valued signals.
OutputPhaseUnit#
RADIANS
DEGREES
OutputRangeStart#
Set type to the name of one of the other fields, and set only that field.
firstPointMatchingConditionFirstPointMatchingConditionThe first point in the output range will be the first point where the condition evaluates to true.
afterPersistenceWindowAfterPersistenceWindowThe output range will contain points where the condition has been true for at least the min duration and min points.
PaddedRanges#
Expands ranges durations by adding temporal padding to the start, end, or both sides. Note that if the input ranges contain a RangeValue, it will be dropped.
inputRangeSeriesrequired
paddingDurationConstantrequired
paddingConfigurationRangePaddingConfigurationConfiguration for how to apply padding to the ranges. Defaults to PAD_START_AND_END if not specified.
PaddedRangesV2#
Expands ranges using an authored Duration expression and a selected padding direction.
inputRangeSeriesrequired
durationcompute.api.DurationrequiredHow far to extend each range on every padded side.
paddingConfigurationRangePaddingConfigurationrequired
PagedLogPlot#
timestampsarray ofTimestamp
valuesarray ofLogValue
nextPageTokenPageTokenContinuation token for this paged result. Can only be returned if paging was requested. To retrieve the next page, repeat the same request with this value as
pageTokenand keep the pageSize sign unchanged. Returned only when this response contains exactlyabs(pageSize)points; the next response may still be empty if this page ended exactly at the result-set boundary. Empty means this response was short and there are no further points in the requested direction.
PageInfo#
Specification of a page for a series. Returns full resolution points beginning nearest to the given page token, advancing pageSize points in the time direction specified by the sign of the page size. Throws if the absolute pageSize is greater than 5,000. Paging cursors are not guaranteed to distinguish exact duplicate non-log points with the same timestamp, tags, and value. If those duplicates straddle a page boundary, later duplicates may be skipped.
pageTokenPageToken
pageSizeinteger required
PageStrategy#
Set type to the name of one of the other fields, and set only that field.
pageInfoPageInfo
PageToken#
Set type to the name of one of the other fields, and set only that field.
timestampAndIdTimestampAndId
ParameterInput#
variablesmap ofVariableNametoVariableValue
timeRangeRangeOverrides the start and end time of the compute request. If either the start or end are not present, we default back to the start/end specified in the request.
ParameterizedContext#
parameterInputsarray ofParameterInputEach parameter input provides a satisfying set of values for the parameterized compute node.
PeakRanges#
Produces a list of ranges for each point that is greater than its neighbors. Peaks at edges are discarded, and continuous, multivalue, flat peaks will return all values.
inputNumericSeriesrequired
returnsPeaksboolean deprecatedTrue if returning peaks, else troughs. Deprecated: No longer used, use returnType instead
returnTypePeakTypeOptional for backcompatibility.
minimumProminenceDoubleConstantThe minimum topographic prominence for an extrema to be returned. Prominence is the minimum vertical distance needed to travel from an extrema to one of greater magnitude.
PeakType#
PEAK
TROUGH
BOTH
PercentageThreshold#
Threshold defined as the percentage of a given value.
valueDoubleConstantrequiredAllowed spread, as a percentage of the window’s mean value.
Percentile#
The value at the specified percentile.
percentileDoubleConstantrequiredPercentile to compute, in range [0, 1]. E.g. 0.5 for median, 0.95 for p95.
Periodogram#
Returns the spectral density estimate (i.e. PSD) of the input series.
inputNumericSeriesrequired
methodPeriodogramMethodrequired
PeriodogramMethod#
WELCH_BLACKMAN
WELCH_HANN
WELCH_HAMMING
WELCH_RECT
PersistenceWindowConfiguration#
Configures how long a condition has to be true for to output a time range, and what to use as the start of the output range. For a point to be included in the output time range, both the minPoints and minDuration conditions must be satisfied.
minPointsIntegerConstantThe minimum number of points for which this condition be must satisfied to include the time range in the output. Must be non-negative. If not present, will default to 1.
minDurationDurationConstantThe minimum number of points for which this condition must be satisfied to include the time range in the output. Must be non-negative. If not present, will default to 1 nanosecond.
outputRangeStartOutputRangeStartrequiredWhich point to use as the start of the output range. Defaults to firstPointMatchingCondition if not specified.
PhaseUnwrapSeries#
Removes discontinuities from a wrapping signal (e.g. phase or heading) by adding whole multiples of period whenever the step between consecutive samples exceeds half the period. Output length equals input length.
inputNumericSeriesrequired
periodDoubleConstantrequiredThe wrapping period of the signal (e.g. 2*pi for radians, 360 for degrees). A jump between consecutive samples greater than
period/2in magnitude is corrected by adding/subtracting a whole multiple ofperiod.
PhysicalConstant#
Physical constants referenceable by name. The server resolves the symbol to its numeric value in SI units.
SPEED_OF_LIGHTSpeed of light in vacuum, 299792458 m/s (exact).
AVOGADROAvogadro constant, 6.02214076e23 mol^-1 (exact).
BOLTZMANNBoltzmann constant, 1.380649e-23 J/K (exact).
PLANCKPlanck constant, 6.62607015e-34 J*s (exact).
ELEMENTARY_CHARGEElementary charge, 1.602176634e-19 C (exact).
GAS_CONSTANTMolar gas constant, 8.31446261815324 J/(mol*K) (exact, Avogadro times Boltzmann).
STANDARD_GRAVITYStandard acceleration of gravity, 9.80665 m/s^2 (exact by convention).
STANDARD_ATMOSPHEREStandard atmosphere, 101325 Pa (exact by convention).
ABSOLUTE_ZERO_CELSIUSAbsolute zero expressed in degrees Celsius, -273.15 (exact).
GRAVITATIONAL_CONSTANTNewtonian constant of gravitation, 6.67430e-11 m^3/(kg*s^2) (CODATA 2022, measured).
STEFAN_BOLTZMANNStefan-Boltzmann constant, 5.670374419e-8 W/(m^2*K^4) (exact derived).
PinnedModuleVersionReference#
versionStringConstantrequired
Point3d#
xnumber required
ynumber required
znumber required
timestampTimestamprequired
PolynomialCurve#
degreeIntegerConstantrequiredThe highest allowable degree of the fit polynomial.
interceptDoubleConstantThe y-value at the point x (or t) = 0. If omitted, the y-intercept will also be fit to the data.
PolynomialCurveFit#
A polynomial fit of the enclosing target (y) against the chosen independent variable (x).
independentVariableCurveFitVariablerequiredThe
xaxis the target is fit against — either relative sample time or another series.degreeIntegerConstantrequiredThe highest allowable degree of the fit polynomial.
interceptDoubleConstantThe y-value at the point x (or t) = 0. If omitted, the y-intercept will also be fit to the data.
PolynomialResultDetails#
y = sum( a_i * x^i ) for i in 0…len(a)
aarray of number
Power#
Raises base to the power of exponent pointwise.
baseNumericSeriesrequiredBase values.
exponentNumericSeriesrequiredExponent values.
PowerCurve#
An empty JSON object, {}.
PowerResultDetails#
y = a * x^b
anumber required
bnumber required
ProductSeries#
For every timestamp specified in the input series, outputs a value that is the product for that timestamp across all input series. Only outputs timestamps where all input series have an entry for that timestamp, subject to interpolation.
inputsarray ofNumericSeriesInput series across which to take the pointwise product
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
PropertiesFilter#
namestring required
valuesarray of string
Property#
nameStringConstantrequired
valueStringConstantrequired
PropertyComparisonOperator#
EQ
NEQ
GT
GTE
LT
LTE
Psd#
inputNumericSeriesrequired
stftOptionsStftOptions
magnitudeScalingMagnitudeScalingThe scaling to apply to the output magnitude. Defaults to MAGNITUDE_DB_10 if not specified.
outputFrequencyTypeOutputFrequencyTypeThe type of the output frequency. Defaults to LINEAR if not specified. Changing the output frequency unit may also rescale the magnitude of the output in order to ensure the density of the output is consistent.
summarizationStrategyFrequencySummarizationStrategyStrategy to downsample the output frequency spectrum.
QuotaIntervalUsage#
durationSecondsinteger (int64) requiredLength of the quota window in seconds.
currentWindowQuotaWindowBounds of the current quota window. Usage counters reset at the window’s end.
resourcesarray ofQuotaResourceUsageUsage per limited resource. Resources without a configured limit are not reported.
QuotaResourceType#
Resource types that can be limited by the per-user compute quota.
READ_ROWS
READ_BYTES
QUERIES
ERRORS
EXECUTION_TIME
QuotaResourceUsage#
resourceQuotaResourceTyperequired
usednumber requiredAmount consumed within the current window, in the resource’s native unit (rows, bytes, query count, or seconds for EXECUTION_TIME).
limitnumber requiredThe cap for this resource in this window.
QuotaWindow#
startTimestring (date-time) required
endTimestring (date-time) required
Range#
The end represents the first timestamp that does not belong to the range. If absent, there is no known end to the range.
startTimestamp
endTimestamp
valueRangeValue
RangeAggregation#
An aggregation value representing combined aggregation metrics for data over a range.
averagenumber required
minnumber required
maxnumber required
standardDeviationnumber required
countnumber required
sumnumber required
rootMeanSquarenumber
RangeAggregationOperation#
Set type to the name of one of the other fields, and set only that field.
sumSummation
rootMeanSquareRootMeanSquare
averageAverage
minMinimum
maxMaximum
standardDeviationStandardDeviation
countCount
allEmpty
RangeDurationSeries#
Outputs a numeric series with one point per range: timestamp = range start, value = range duration.
inputRangeSeriesrequired
unboundedRangeBehaviorUnboundedRangeBehaviorrequiredHow to handle ranges with a missing start or end.
timeUnitTimeUnitThe time unit of the duration. Defaults to seconds if not specified.
RangeIntervalSource#
Intervals come from a range series. Must resolve to literal ranges.
rangesRangeSeriesrequired
tagByarray ofRangeTagSourceNon-empty ordered list of tag sources. Each contributes a tag key-value pair per range interval.
RangeMap#
startDoubleConstantInclusive start value. If not specified, the start is the prior range’s end value, or negative infinity.
endDoubleConstantExclusive end value. If not specified, the end value is the next range’s start value, or positive infinity.
outputStringConstantrequiredThe value to map to if the input value is within the range.
RangePaddingConfiguration#
PAD_START
PAD_END
PAD_START_AND_END
RangesAnchor#
Uses the start timestamp of the range at the configured zero-based index from ranges evaluated over each interval, considering only ranges whose start lies in the anchor window [start, end), or [start, +infinity) when the end is absent. The window is the run bounds for a run anchor. A range already in progress when the window opens anchors at the window start. Series in ranges that select no explicit dataset resolve against the aligned input dataset, and the computed range groups must carry the aligned runs’ runRid grouping tags.
rangesRangeSeriesrequiredThe range series evaluated per interval to locate the anchor range.
indexIntegerConstantZero-based range index after sorting. Defaults to zero and must be non-negative.
sortOrderRangeSortOrderOrdering by range start timestamp before selecting the index. Defaults to ASC.
RangeSeries#
Set type to the name of one of the other fields, and set only that field.
approximateThresholdApproximateThresholdRanges
booleanRangesBooleanRanges
thresholdRangesV2ThresholdRangesV2
durationFilterDurationFilterRanges
durationFilterV2DurationFilterRangesV2
enumFilterEnumFilterRanges
categoryFilterRangesV2CategoryFilterRangesV2
categoricalOnChangeRangesV2CategoricalOnChangeRangesV2
categoricalStaleRangesV2CategoricalStaleRangesV2
categoricalEqualityRangesV2CategoricalEqualityRangesV2
enumSeriesEqualityRangesNodeEnumSeriesEqualityRanges
eventsSearchEventsSearchRanges
intersectRangeIntersectRanges
literalRangesLiteralRanges
minMaxThresholdMinMaxThresholdRangesComputes ranges where the input time series matches a filter defined by lower and upper bounds, and an operator.
notNotRanges
onChangeOnChangeRanges
peakPeakRanges
extremaRangesV2ExtremaRangesV2
rangeNumericAggregationRangesNumericAggregation
rawReference
derivedDerivedSeries
seriesCrossoverRangesNodeSeriesCrossoverRanges
seriesEqualityRangesNodeSeriesEqualityRanges
numericEqualityRangesV2NumericEqualityRangesV2
stabilityDetectionStabilityDetectionRanges
stabilityDetectionV2StabilityDetectionRangesV2
staleRangeStaleRanges
numericStaleRangesV2NumericStaleRangesV2
thresholdThresholdingRangesComputes ranges where the input time series matches a filter defined by a single threshold and an operator.
unionRangeUnionRanges
paddedRangesPaddedRanges
paddedRangesV2PaddedRangesV2
RangesNumericAggregation#
Aggregates the values of a numeric series at each range specified by the input ranges.
rangesRangeSeriesrequired
inputNumericSeriesrequired
operationRangeAggregationOperationrequired
RangeSortOrder#
Sort order for selecting ranges. ASC selects from earliest to latest, DESC selects from latest to earliest.
ASC
DESC
RangesSummary#
A summary of the ranges returned from a SummarizeRanges request. Returned when the number of ranges found is above a threshold.
rangesSummaryarray ofRangeSummary
RangeStart#
Selects which point of a satisfied condition begins the output range.
CONDITION_START
PERSISTENCE_START
RangeSummary#
Summary of a set of ranges
rangeRangerequiredThe range representing the minimum start and maximum end times of the ranges.
subRangeCountinteger requiredThe number of ranges found within this time range.
RangeValue#
A value attached to a range. If there are no relevant data points in the range, this will be noPointsInRange for the range; otherwise, an Aggregation will be returned if this is produced by getting multiple aggregation values over a range (i.e. aggregating for all metrics over a range), and will be a double otherwise for singular values (i.e. aggregating for just the sum of data values over a range).
Set type to the name of one of the other fields, and set only that field.
doublenumber
aggregationRangeAggregation
noPointsInRangeEmpty
Reference#
namestring requiredA reference to a value not defined in the current compute scope.
RefpropProperty#
Supported properties for REFPROP calculations.
TEMPERATURE
PRESSURE
MASS_DENSITY
MASS_SPECIFIC_ENTHALPY
MASS_SPECIFIC_INTERNAL_ENERGY
MASS_SPECIFIC_ENTROPY
VISCOSITY
RefpropSeries#
Computes the output property given input properties for the substance using REFPROP. Initial implementation only expects two input properties.
inputsmap of string toNumericSeriesA map that maps a REFPROP property to its numeric series.
outputPropertyRefpropPropertyrequiredThe desired output property. This should not be one of the input properties.
substanceRefpropSubstancerequiredThe substance for REFPROP calculations.
interpolationConfigurationInterpolationConfigurationdeprecatedDeprecated: Setting interpolation on this node is deprecated.
RefpropSeriesV2#
Computes a REFPROP output property from the supplied substance and output property.
inputsmap of string toNumericSeriesMap of REFPROP property to its numeric series.
substanceRefpropSubstancerequiredThe substance for REFPROP calculations.
outputPropertyRefpropPropertyrequiredThe desired output property. This must not be one of the input properties.
RefpropSubstance#
Supported substances for REFPROP calculations
NITROGEN
OXYGEN
HELIUM
HYDROGEN
METHANE
PROPANE
BUTANE
WATER
XENON
AIR
CARBON_DIOXIDE
ARGON
CARBON_MONOXIDE
JET_A_4658
JET_A_3638
RequestInactive#
No query for this request was running at sample time; not necessarily finished.
An empty JSON object, {}.
RequestInProgress#
Summed across the request’s active queries when it fans out into more than one.
readRowsinteger (int64) required
totalRowsApproxinteger (int64) requiredMay grow while a query runs as new sources to process become known.
RequestProgress#
Set type to the name of one of the other fields, and set only that field.
inProgressRequestInProgress
inactiveRequestInactive
ResourceSearchQuery#
Predicate tree for filtering.
Set type to the name of one of the other fields, and set only that field.
propertiesPropertiesFilter
numericPropertyNumericPropertyPredicate
numericPropertyRangeNumericPropertyRangePredicateMatches resources using an inclusive numeric property range.
labelsLabelsFilter
workspaceStringConstant
andarray ofResourceSearchQuery
orarray ofResourceSearchQuery
notResourceSearchQuery
RollingOperationSeries#
DEPRECATED. Use numericAggregation with aggregation.RollingTimeAggregationBuilder instead.
inputNumericSeriesrequired
windowWindowrequired
operatorNumericAggregationOperatorrequired
RollingPointsAggregationBuilder#
Rolling point-count aggregation: for each point in the input, aggregate the current point and the preceding N - 1 points within the same tag grouping.
inputSeriesrequired
pointsIntegerConstantrequired
RollingTimeAggregationBuilder#
Rolling time-window aggregation: for each point in the input, aggregate the values within the preceding time window.
inputSeriesrequired
windowcompute.api.Durationrequired
RootMeanSquare#
The root mean square of points inside the time window.
An empty JSON object, {}.
Run#
Run reference for Dataset.run. The rid field accepts either a literal run RID or a StringConstant reference resolved from Context.
ridStringConstantrequiredResource identifier of a run
run.api.Duration#
secondsinteger (int64) required
nanosinteger (int64) required
RunChannel#
runRidStringConstantrequired
assetRidStringConstantUsed to disambiguate when multiple assets within this run contain data scopes with the same name. If not specified for a run with multiple assets, an error will be thrown.
dataScopeNameStringConstantrequiredUsed to disambiguate when multiple data scopes within this run contain channels with the same name.
channelStringConstantrequired
additionalTagsmap of string toStringConstantdeprecatedDeprecated: Use additionalTagFilters
additionalTagFiltersTagFiltersTags to filter the channel by, in addition to tag filters defined for a given Run data scope. Throws on collisions with tag keys already defined for the given Run data scope. Only returns points that match both sets of tag filters. For log series, include arg filters here in addition to tag filters.
tagsToGroupByarray of string deprecatedDeprecated: Use groupByTags instead. Throws if both tagsToGroupBy and groupByTags are specified.
groupByTagsarray ofStringConstantTags that the channel should be grouped by. If this is non-empty a grouped result will be returned with an entry for each grouping. Only one of tagsToGroupBy and groupByTags should be specified.
RunsSearchTarget#
Search runs. Each matched run expands to one grouping per data source attached to the run: asset-typed data sources contribute one grouping per data scope on the asset; dataset-typed data sources contribute one grouping per dataset. Every grouping is tagged by runRid and dataScope (the asset’s data scope name for asset-typed sources, or the run-local data source ref name for dataset-typed sources); asset-typed groupings additionally carry assetRid.
queryResourceSearchQueryrequiredPredicate tree used to filter matching runs.
RustUdfSource#
Rust source code defining the UDF entrypoint and any helper functions.
sourceCodestring requiredRust source code to transpile into WASM. The operation consuming this source defines the entrypoint signature: scalar UDFs receive one scalar per input series, while aggregation UDFs receive grouped value vectors. If several functions appear at the top level, annotate the entrypoint with
#[main].
Sampling#
Options for returning a sampled subset of raw series points.
Set type to the name of one of the other fields, and set only that field.
everyNthPerSeriesEveryNthPerSeriesSampling
hashSubsampleHashSubsampleSampling
SavedDataset#
A persisted source of data, named by its RID. Can be a catalog dataset, pipeline, connection, etc.
ridStringConstantrequiredA data source RID, given as a literal or as a variable resolved from
Context. A pipeline’s logic only accepts catalog datasets/pipelines, since it is persisted without context.
ScalarUdfSeries#
Executes user-provided scalar UDF code over aligned inputs. The function must return one output for each aligned input row, with the return type matching the series type that contains this node.
ScaleSeries#
For every timestamp specified in the input series, multiply it by a constant factor.
inputNumericSeriesrequired
scalarDoubleConstantrequiredThe constant to multiply each point by
scalarUnitstringThe units of the scalar to multiply by. If empty, the scalar is considered unit-less.
Scatter#
A scatter plot comprised of the values from one input series on the x-axis and values from another input series on the y-axis, for all points within a requested time range.
xNumericSeriesrequired
yNumericSeriesrequired
Scatter3d#
xNumericSeriesrequired
yNumericSeriesrequired
zNumericSeriesrequired
driverSeriesDriverSeries3d
ScatterCurveFit#
Fits a curve to the scatter between two series.
scatterScatterrequiredThe x and y series to fit to.
optionsScatterFitOptionsrequired
ScatterFitOptions#
minXDoubleConstantInclusive lower bound on the x values to fit to. If omitted, does not set a bound (equivalent to setting this to the minimum x value among all points in the time range).
maxXDoubleConstantInclusive upper bound on the x values to fit to. If omitted, does not set a bound (equivalent to setting this to the maximum x value among all points in the time range).
minYDoubleConstantInclusive lower bound on the y values to fit to. If omitted, does not set a bound (equivalent to setting this to the minimum y value among all points in the time range).
maxYDoubleConstantInclusive upper bound on the y values to fit to. If omitted, does not set a bound (equivalent to setting this to the maximum y value among all points in the time range).
ScatterSummarizationStrategy#
Set type to the name of one of the other fields, and set only that field.
spatialSpatialDecimateStrategy
temporalTemporalDecimateStrategy
ScatterTemporalAggregation#
MEAN
MIN
MAX
FIRST
LAST
SearchDataset#
Resolves matching assets or runs from search, creating a combined dataset tagged by source rid and data scope.
targetSearchTargetrequiredWhether to search assets or runs and with which query.
maxResultsintegerMaximum number of assets or runs returned from search. Defaults to 10000 when omitted.
SearchEventOriginType#
WORKBOOK
TEMPLATE
API
DATA_REVIEW
PROCEDURE
SearchTarget#
Set type to the name of one of the other fields, and set only that field.
assetsAssetsSearchTarget
runsRunsSearchTarget
SelectIndexFrom1dEnumArraySeries#
For each timestamp, selects a single enum value from the 1D enum array at the specified index. If the index is out of bounds for an array at a given timestamp, it is omitted.
inputEnum1dArraySeriesrequired
indexIntegerConstantrequired
SelectIndexFrom1dNumericArraySeries#
For each timestamp, selects a single numeric value from the 1D numeric array at the specified index. If the index is out of bounds for an array at a given timestamp, it is omitted.
inputNumeric1dArraySeriesrequired
indexIntegerConstantrequired
SelectNewestPointsSeries#
Select the most recent N points from the input series by timestamp.
inputNumericSeriesrequiredThe input series to select the newest points from.
numPointsIntegerConstantrequiredThe number of points to select.
SelectOldestPointsSeries#
Select the earliest N points from the input series by timestamp.
inputNumericSeriesrequiredThe input series to select the oldest points from.
numPointsIntegerConstantrequiredThe number of points to select.
SelectProperty#
Selects a typed property value from every asset or run branch resolved from dataset. Inside a WithSeriesDataset definition, dataset may be omitted to use that node’s wrapping input; it is required everywhere else. Asset branches read properties directly from their asset. Run branches read properties directly from their run, never from a backing asset or dataset. Direct saved-dataset branches are unsupported.
propertyNamestring required
datasetDataset
SelectSeries#
Selects series from a dataset (might contain multiple tag groupings). When name is provided, selects that single channel. When name is omitted, selection starts from all channels in the dataset scope; callers narrow the selection with a filterByTag predicate on the reserved NOMINAL_CHANNEL tag key and preserve per-channel identity in the response with selectTags. Providing both name and a NOMINAL_CHANNEL filter is rejected as an invalid request. Raw and derived channels can both be selected through the reserved tag filter.
nameStringConstantThe identifying series name to query
datasetDatasetThe dataset providing the data to query. May be omitted inside a
WithSeriesDatasetseries definition, in which case it defaults to that node’s wrappinginput; required everywhere else.samplingSamplingRaw-series sampling options. Supported for numeric and enum raw series.
SelectValue#
Set type to the name of one of the other fields, and set only that field.
firstPointSeries
firstValuePointSeries
firstRangeRangeSeries
lastPointSeries
lastValuePointSeries
lastRangeRangeSeries
nthRangeNthRange
SerializableError#
A SerializableError is a representation of a ServiceException that exists to send error results to clients as part of a response object when directly throwing an exception is undesirable.
namestring required
messagestring
errorInstanceIdstring required
statusCodeinteger required
paramsmap of string to string
Series#
Set type to the name of one of the other fields, and set only that field.
rawReferencedeprecatedDeprecated: use typed value of series instead.
enumEnumSeries
numericNumericSeries
logLogSeries
arrayArraySeries
structStructSeries
videoReference
SeriesCrossoverRanges#
Produces a list of zero-duration ranges at the first point where two series cross over one another
inputANumericSeriesrequired
inputBNumericSeriesrequiredThe series
inputAis compared against.
SeriesEqualityRanges#
Produces a list of ranges for which provided series are all equal (or are not all equal).
inputarray ofNumericSeries
equalityOperatorEqualityOperatorrequired
toleranceDoubleConstant
persistenceWindowConfigurationPersistenceWindowConfiguration
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
SeriesVariable#
A series selected from a dataset, bound to a variable. The series type (numeric, enum, …) is decided lazily by the node consuming the variable, matching the behaviour of channel variables.
selectSelectSeriesrequired
groupByTagsarray ofStringConstantTags that the series should be grouped by. If this is non-empty a grouped result will be returned with an entry for each grouping; otherwise all matching series are merged.
SetNegativeValuesToZero#
An empty JSON object, {}.
SetOperator#
AND
OR
SignalFilterConfiguration#
Set type to the name of one of the other fields, and set only that field.
lowPassLowPassConfiguration
highPassHighPassConfiguration
bandPassBandPassConfiguration
bandStopBandStopConfiguration
SignalFilterSeries#
Applies IIR-based signal filtering to input series. Includes low-pass, high-pass, band-pass, and band-stop filters. Currently supports variable-order bidirectional Butterworth filters, with fixed-size padding based on SciPy output.
inputNumericSeriesrequired
signalFilterConfigurationSignalFilterConfigurationrequiredFilter type and cutoff frequencies.
orderIntegerConstantrequiredOrder of filter. Must be a positive integer, and is effectively doubled for bidirectional filters.
samplingFrequencyDoubleConstantThe sampling frequency of the input series. Used to calculate normalized frequency for cutoff frequencies.
Sin#
Computes the trigonometric sine of each value (input in radians).
xNumericSeriesrequiredInput numeric series (radians).
SinglePoint#
Return type representing a single point value.
SpatialDecimateStrategy#
Decimate by spatial trees. Creates buckets by bisecting on each dimension, creating quadrants for 2d scatter and octants for 3d scatter. Continues subdividing by prioritizing larger undivided buckets until reaching the max amount of buckets.
An empty JSON object, {}.
Spectrogram#
The PSD or amplitude of the input over time, from a short-time Fourier transform of overlapping windows.
inputNumericSeriesrequiredA numeric series from a single data source. Series grouped by tags are not supported.
stftOptionsStftOptionsWindow and FFT parameters.
quantitySpectrogramQuantityWhat each cell measures. Defaults to PSD.
magnitudeScalingMagnitudeScalingHow each cell’s value is scaled. Defaults to decibels: 10·log10 of the PSD, or 20·log10 of the amplitude.
bucketingSpectrogramBucketingThe output’s time and frequency buckets, frequency band and reductions.
SpectrogramBucketing#
The output’s time and frequency buckets: at most maxTimeBuckets rows and maxFrequencyBuckets columns over the frequency band, with the values that share a row or column combined by timeReduction and frequencyReduction. Invalid values fail with InvalidExpression.
maxTimeBucketsintegerMaximum number of rows, further lowered so that rows × columns is at most 262,144. Defaults to 256.
maxFrequencyBucketsintegerMaximum number of columns. Defaults to 512.
minFrequencynumberInclusive lower bound of the band in Hz. Defaults to 0.
maxFrequencynumberExclusive upper bound of the band in Hz. Defaults to including the Nyquist frequency.
timeReductionSpectrogramReductionCombines the windows that share a row. Defaults to MEAN.
frequencyReductionSpectrogramReductionCombines the frequency bins that share a column. Defaults to MEAN.
SpectrogramPlot#
Values on a time-frequency grid. Columns are frequency buckets and rows are the time buckets that hold data, in ascending time.
frequencyCentersarray of numberCenter frequency in Hz of each column.
frequencyEdgesarray of numberColumn boundaries in Hz, one more than
frequencyCenters: columncspansfrequencyEdges[c]tofrequencyEdges[c + 1]. Columns may differ in width.rowsarray ofSpectrogramRow
SpectrogramQuantity#
What a spectrogram cell measures.
PSDPower spectral density, in the input unit squared per Hz.
AMPLITUDEPeak amplitude, in the input unit.
SpectrogramReduction#
How the values that share one output row or column are combined, before scaling.
MEANArithmetic mean.
MAXMaximum, which keeps short transients visible.
GEOMETRIC_MEANGeometric mean, which suits decibel displays with a wide dynamic range.
SpectrogramRow#
Sqrt#
Computes the square root of each value.
xNumericSeriesrequiredInput numeric series (non-negative values).
StabilityDetectionRanges#
Outputs a set of ranges where the input series is stable. For each point, the min and max are calculated over the specified lookback window, including the current point. A point is considered stable if its value does not deviate from the calculated min and the max by more than the threshold and the total number of points within the window is at least the specified amount. The threshold can be either fixed values or percentages of the value. The lookback window must be strictly positive. The minimum points threshold defaults to 2.
inputNumericSeriesrequired
windowConfigurationStabilityWindowConfigurationrequired
thresholdThresholdrequired
StabilityDetectionRangesV2#
Produces ranges where a numeric input is stable within a modern duration window.
inputNumericSeriesrequired
windowcompute.api.DurationrequiredLookback window over which the input’s spread is measured.
minPointsIntegerConstantMinimum number of points in the window. Defaults to 2.
thresholdThresholdrequired
StabilityWindowConfiguration#
minPointsIntegerConstantThe minimum number of points within the window to create a stable range. Must be non-negative. If not present, will default to 2.
durationDurationConstantrequired
StaleRanges#
Produces a list of ranges for which data does not exist for the specified duration or longer. Increases window size by the specified staleness threshold on both ends to capture edge cases of data not currently in view.
inputSeriesrequired
thresholdDurationConstantrequired
startTimestampTimestampConstantThe start timestamp of the range. If not specified, staleness will automatically use view range start.
endTimestampTimestampConstantdeprecatedDeprecated: No longer used and will be removed
StandardDeviation#
The standard deviation of points inside the time window.
An empty JSON object, {}.
StftOptions#
Options for frequency analyses that are backed by short-time Fourier transforms.
windowFftWindowWindow function type to use
windowSymmetryWindowSymmetryEither DFT_EVEN or SYMMETRIC
samplingFrequencynumberSampling frequency of the series in Hz. If absent, will calculate using the input series.
npersegintegerNumber of points per window segment.
noverlapintegerNumber of points of overlap between windows. Must be less than nperseg.
nfftintegerNumber of points to use in the FFT. Must be greater than or equal to nperseg.
detrendDetrendTypeDetrend the points in each window segment. If absent, will use the default detrend for that function.
StringConstant#
A string constant that can be a literal value or a named variable reference.
Set type to the name of one of the other fields, and set only that field.
literalstringCreate from a literal string value.
variablestringCreate from a named reference.
StringPropertyDimension#
Injects the value of a string property, under a tag key equal to the property name by default. Only supported on asset and run branches: asset branches read the asset’s properties, and run branches, including run branches backed by an asset, read the run’s properties, matching SelectProperty. Values are injected as is. A branch without the property, or whose property holds a numeric value, gets the reserved value NOMINAL_ABSENT.
propertyNameStringConstantrequiredName of the property whose value to inject. Also the default tag key.
StringSetConstant#
Set type to the name of one of the other fields, and set only that field.
literalarray of string
variablestring
StringSetConstantV2#
A set of string constants that can be a literal set or a named variable reference.
Set type to the name of one of the other fields, and set only that field.
literalarray ofStringConstantCreate from a literal set of string constants.
variablestringCreate from a named reference.
StructSeries#
Set type to the name of one of the other fields, and set only that field.
channelChannelSeries
rawReference
derivedDerivedSeries
combineCombineStructSeries
selectStructSelectSeries
extractFromStructExtractStructFromStructSeries
toStartOfIntervalStructToStartOfIntervalSeries
timeShiftStructTimeShiftSeries
filterByTagStructTagFilterSeries
selectTagsStructSelectTagsSeries
StructTagFilterSeries#
Applies a tag predicate to the struct series produced by input.
inputStructSeriesrequired
predicateTagPredicaterequired
StructTimeShiftSeries#
inputStructSeriesrequired
durationDurationConstantrequired
StructToStartOfIntervalSeries#
Snaps each point’s timestamp to the start of its enclosing fixed-size time bucket. Buckets are epoch-aligned: a point at timestamp t (nanoseconds) is rewritten to floor(t / window) * window. Values and tag groupings are preserved; aggregation of points that collide on the snapped timestamp is the responsibility of downstream nodes.
inputStructSeriesrequired
windowcompute.api.Durationrequired
Subtract#
Subtracts right from left pointwise.
leftNumericSeriesrequiredLeft-hand operand (minuend).
rightNumericSeriesrequiredRight-hand operand (subtrahend).
SummarizationStrategy#
Set type to the name of one of the other fields, and set only that field.
decimateDecimateStrategy
largestTriangleThreeBucketsLttbStrategyLargest-Triangle-Three-Buckets downsampling returns selected numeric timestamp/value points that preserve the visual shape of each group. It is distinct from fixed-width bucket aggregation.
pagePageStrategyPaging returns full resolution points for supported series types. Results include a continuation token when another request may be needed to continue in the requested direction.
truncateTruncateStrategyTruncation returns a bounded set of full-resolution points. For compute requests, it is supported for array and struct series. To retrieve full-resolution numeric series, use paging.
SummarizeCartesian#
inputCartesianrequired
boundsCartesianBounds
summarizationStrategyScatterSummarizationStrategyThe summarization strategy to use when there are more than
maxPoints. Defaults to spatial.maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesianPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
SummarizeCartesian3d#
inputCartesian3drequired
boundsCartesian3dBounds
maxPointsintegerThe maximum number of points to return in the response. If more points are found, a BucketedCartesian3dPlot will be returned. Maximum is 10,000. Defaults to 2,000 if not specified.
summarizationStrategyScatterSummarizationStrategyThe strategy to use when summarizing the series. Only spatial decimation is supported.
SummarizeMultivariate#
inputsarray ofMultivariateInputList of input series to temporally align at the raw point level, then bucket the aligned tuples together. The series with the largest tag group acts as the “driver” that determines which raw timestamps are included in the alignment. All subsequent series are aligned to the driver’s raw timestamps using the interpolation configuration. After alignment, the resulting (x, y, z, …) tuples are bucketed into time windows and aggregated.
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY (JSON).
bucketCountintegerThe number of buckets to return in the response. Maximum is 10,000. Defaults to 1,000 if not specified.
interpolationConfigurationInterpolationConfigurationControls how the N input series are aligned at the raw point level when producing multivariate buckets. When present, the server may fill forward a series value from the most recent prior raw point (bounded by the interpolation radius). This alignment happens BEFORE bucketing, ensuring that aggregated values in each bucket are computed from temporally aligned raw tuples. When absent, the default interpolation configuration is used.
SummarizeRanges#
inputRangeSeriesrequired
maxRangesintegerThe maximum number of ranges to return in the response. If more ranges are found, a RangesSummary will be returned. Defaults to 2000 if not specified.
SummarizeSeries#
Summarizes the output of a series node. The output can be a numeric, enum, log, or cartesian series. Summarization strategy should be specified.
inputSeriesrequired
outputFormatOutputFormatThe output format of the response. Defaults to LEGACY.
numericOutputFieldsarray ofNumericOutputFielddeprecatedThe fields to output from the summarization. Applies only to Arrow format numeric series. Deprecated: Use numericOutputFieldsV2 instead.
numericAggregationsmap of string toNumericAggregationOperatorAdditional numeric aggregations per decimation bucket (e.g. percentiles). Map key is the name of the column in the result.
numericOutputFieldsV2array ofNumericOutputFieldV2Numeric bucket output fields to return. Applies only to Arrow format numeric series. Defaults to MEAN when no numeric output selector is specified. Mutually exclusive with numericOutputFields and numericAggregations.
resolutioninteger (int64) deprecatedResolution of the output series specifying time interval between decimated points, in nanoseconds. Deprecated: Use summarizationStrategy instead.
bucketsinteger deprecatedNumber of points to generate in the output series. Deprecated: Use summarizationStrategy instead.
summarizationStrategySummarizationStrategyThe strategy to use when summarizing the series.
Summation#
The sum of points inside the time window.
An empty JSON object, {}.
SumSeries#
For every timestamp specified in the input series, outputs a value that is the sum for that timestamp across all input series. Only outputs timestamps where all input series have an entry for that timestamp, subject to interpolation.
inputsarray ofNumericSeriesInput series across which to take the pointwise sum
interpolationConfigurationInterpolationConfigurationdeprecatedDefaults to forward fill interpolation with a 1s interpolation radius Deprecated: Setting interpolation on this node is deprecated.
TagAnd#
Conjunction of two tag predicates (both must hold).
leftTagPredicaterequired
rightTagPredicaterequired
TagByIntervalsSeries#
Injects tags derived from interval boundaries onto a numeric series. Points within an interval get tagged; points outside all intervals are dropped. Intervals come from either events or ranges. If intervals with different tag map overlap, a data point falling in multiple intervals is duplicated into each matching output group. Overlapping intervals with equal tag maps are not allowed. Optional time shift subtracts a per-interval anchor from timestamps after matching.
inputNumericSeriesrequired
intervalsIntervalSourcerequired
timeShiftTagByIntervalsTimeShiftWhen set, shift each matched point’s timestamp by the chosen anchor for that interval.
TagByIntervalsTimeShift#
How to shift timestamps after tagging (subtract anchor from each point in the interval slice).
Set type to the name of one of the other fields, and set only that field.
intervalStartIntervalStartTimeShift
intervalEndIntervalEndTimeShift
eventTimeShiftEventTimeShift
TagFilter#
A filter on a single tag key and set of values. For an IN operator, the tag key must match at least one of the values in the set. For a NOT_IN operator, it must not match any of the values in the set.
keyStringConstantrequired
valuesarray ofStringConstant
operatorTagFilterOperatorrequired
TagFilterOperator#
IN
NOT_IN
TagFilters#
A set of tag filters to apply to a channel. Allows for combining filters on multiple tag keys, but throws if any one tag key is specified in more than one filter.
Set type to the name of one of the other fields, and set only that field.
singleTagFilter
andarray ofTagFilters
TaggedDataset#
Injects one ephemeral tag (key and value) onto the underlying dataset.
inputDatasetrequiredThe underlying dataset to tag.
keyStringConstantrequiredTag key to inject onto each series in the dataset.
valueStringConstantrequiredTag value to assign to the injected key.
TagIn#
Constrains a tag key to be in the given set of values.
keyStringConstantrequired
valuesStringSetConstantV2required
TagNotIn#
Constrains a tag key to not be in the given set of values.
keyStringConstantrequired
valuesStringSetConstantV2required
TagPredicate#
Conjunctive tag predicate for dataset filtering. Compiles to resolved TagFilters for storage and resolution-time folding against known tag assignments (e.g. TaggedDataset, search branches).
Set type to the name of one of the other fields, and set only that field.
Tan#
Computes the trigonometric tangent of each value (input in radians).
xNumericSeriesrequiredInput numeric series (radians).
TemporalDecimateStrategy#
Buckets the input by time range into equally sized buckets. The number of buckets is determined by the maxPoints parameter. Returns a CartesianPlot.
xAggregationScatterTemporalAggregationrequiredThe strategy to use for aggregating the x values in each bucket.
yAggregationScatterTemporalAggregationrequiredThe strategy to use for aggregating the y values in each bucket.
Threshold#
Set type to the name of one of the other fields, and set only that field.
absoluteAbsoluteThreshold
percentagePercentageThreshold
ThresholdingRanges#
Produces a list of ranges for which the threshold condition is satisfied.
inputNumericSeriesrequired
thresholdDoubleConstantrequired
operatorThresholdOperatorrequired
persistenceWindowConfigurationPersistenceWindowConfiguration
ThresholdOperator#
GREATER_THAN
GREATER_THAN_OR_EQUAL_TO
LESS_THAN
LESS_THAN_OR_EQUAL_TO
EQUAL_TO
NOT_EQUAL_TO
ThresholdRangesComparison#
Selects the comparison applied to a numeric threshold.
Set type to the name of one of the other fields, and set only that field.
ThresholdRangesEqualityComparison#
An equality comparison against a numeric threshold, within an optional tolerance.
thresholdDoubleConstantrequiredThe value each input point is compared against.
toleranceDoubleConstantMaximum absolute difference from the threshold still counted as equal. Defaults to zero, i.e. exact equality.
ThresholdRangesOrderedComparison#
An ordering comparison against a single numeric threshold.
thresholdDoubleConstantrequiredThe value each input point is compared against.
ThresholdRangesV2#
Produces ranges where a numeric input satisfies a threshold comparison.
inputNumericSeriesrequired
minPointsIntegerConstantMinimum number of matching points. Defaults to 1.
minDurationcompute.api.DurationMinimum matching duration. Defaults to one nanosecond.
rangeStartRangeStartSelects whether the output begins at the first match or after persistence is satisfied.
comparisonThresholdRangesComparisonrequired
TimeDifferenceSeries#
Outputs a new series where each value is the difference between the time of the current and previous points.
TimeSeriesCurveFit#
Fits a curve to a series vs its timestamps.
seriesNumericSeriesrequiredThe series to fit. Timestamps will be used as x values and data as y values. The leftmost (earliest) timestamp will be used as the value of 0, and all other timestamps will be relative to that.
optionsTimeSeriesFitOptionsrequired
TimeSeriesFitOptions#
timeUnitTimeUnitTime unit used for the timestamps to fit against. Defaults to seconds if not specified.
TimeShiftedDataset#
Transforms a dataset by adding a time offset to all its data.
inputDatasetrequiredThe underlying dataset to time-shift.
offsetcompute.api.DurationrequiredThe time shift to apply. Positive values shift data forward in time, negative values shift backward.
Timestamp#
Deprecated for new APIs. Use google.protobuf.Timestamp for absolute instants in proto APIs.
This legacy nanosecond precision timestamp type is represented by an epoch time in seconds and a nanosecond offset. The nanosecond offset is from the start of the epoch second, so must be less than 1 billion.
secondsinteger (int64) required
nanosinteger (int64) required
TimestampAndId#
timestampTimestamprequired
idstring (UUID)
TimestampConstant#
A timestamp constant that can be a literal value or a named variable reference.
Set type to the name of one of the other fields, and set only that field.
literalTimestampCreate from a literal timestamp value.
variablestringCreate from a named reference.
TimeUnit#
DAYS
HOURS
MINUTES
SECONDS
MILLISECONDS
MICROSECONDS
NANOSECONDS
TruncateStrategy#
Set type to the name of one of the other fields, and set only that field.
maxPointsToReturnintegerMaximum number of points to return before truncating, ordered by timestamp. Throws if greater than 10,000
UdfSource#
Source provider for a user-defined function.
Set type to the name of one of the other fields, and set only that field.
rustRustUdfSource
UnaryArithmeticOperation#
COSCalculates the trigonometric cosine (input in radians)
SINCalculates the trigonometric sine (input in radians)
TANCalculates the trigonometric tangent (input in radians)
ABSCalculates the absolute value
ASINCalculates the arcsine, returning radians
ACOSCalculates the arccosine, returning radians
LOGCalculates the base 10 logarithm
LNCalculates the natural logarithm (base e)
SQRTCalculates the square root
UnaryArithmeticSeries#
Applies a point-wise transformation to a series. The transformation function is applied to every individual data point.
inputNumericSeriesrequired
operationUnaryArithmeticOperationrequired
UnboundedBehavior#
Dictates how empty range bounds should be handled by the compute node. Defaults to INFINITY.
INFINITY
WINDOW_BOUND
UnboundedRangeBehavior#
How to handle ranges with a missing start or end.
Set type to the name of one of the other fields, and set only that field.
Union#
Uses the union of all input timestamps as the alignment grid.
An empty JSON object, {}.
UnionRanges#
inputsarray ofRangeSeriesThe ranges to union.
UnitComputationError#
Set type to the name of one of the other fields, and set only that field.
incompatibleUnitsOperationIncompatibleUnitOperation
unitsMissingUnitsMissing
errorSerializableError
UnitConversionSeries#
Convert the given series to a different unit.
inputNumericSeriesrequired
outputUnitstring required
UnitOperation#
UNIT_AS_EXPONENT
NON_INTEGER_AS_EXPONENT
FLOOR_DIVISION
MODULO
CROSSOVER_COMPARISON
MAX
MIN
MEAN
UNION
ADDITION
SUBTRACTION
UNIT_CONVERSION
COMPARISON
TERNARY_OPERATOR
UnitOverrideSeries#
Override the unit of the given series without changing its values. Unlike unit conversion, no compatibility with the input’s current unit is required.
inputNumericSeriesrequired
unitstringThe unit to report for the input series. If absent, the input’s unit is cleared.
UnitResult#
Set type to the name of one of the other fields, and set only that field.
successstring
noUnitAvailablearray ofUnitComputationErrorThe resulting values have no units associated. If this is because of an error, it is listed here.
UnitsMissing#
At least one input is missing a unit.
seriesRidsarray of string (RID) deprecatedDeprecated: Use channels instead.
channelsarray ofDataSourceAndChannel
Value#
A single value. The type is dictated by the returned variant
Set type to the name of one of the other fields, and set only that field.
stringValuestring
float64Valuenumber
int64Valuestring
arrayValuearray ofValue
structValueany JSON valueA JSON representation of the struct
ValueDifferenceSeries#
Calculates the first discrete difference of the input series. For each point, computes the difference between the current value and the previous value (current - previous). The first point in the input series is omitted from the output since it has no previous point to compare against.
This is equivalent to pandas DataFrame.diff() with period=1. Useful for analyzing changes between consecutive data points in time series data, such as detecting value increases or decreases.
Example: For input values [1.0, 1.0, 2.0, 2.5, 1.8], the output would be [0.0, 1.0, 0.5, -0.7] at the corresponding timestamps (the first timestamp is omitted).
inputNumericSeriesrequired
negativeValuesConfigurationNegativeValueConfigurationDefines the strategy for handling negative output values. Defaults to allowNegativeValues if not specified.
ValueMapSeries#
Maps a continuous numeric series to a discrete enum series using the specified value ranges.
inputNumericSeriesrequiredThe input series to map to an enumerated series
mappingarray ofRangeMapThe output of the first capturing range will be used. Ranges are start inclusive, end exclusive, must not overlap, and increasing from lowest to highest. Ranges can be open ended to the edge of the next or prior range. The first range can be open ended to negative infinity, and the last range can be open ended to positive infinity.
defaultStringConstantThe default value if not captured by any range. If not specified, points will be filtered.
VariableValue#
Set type to the name of one of the other fields, and set only that field.
doublenumber
computeNodeComputeNodeWithContext
durationrun.api.Duration
integerinteger
channelChannelSeriesdeprecatedDeprecated: use series instead.
derivedDerivedSeries
seriesSeriesVariable
stringstring
stringSetarray of string
timestampTimestamp
Window#
Set type to the name of one of the other fields, and set only that field.
durationDurationConstant
WindowSymmetry#
DFT_EVENGenerates dft-even/periodic window values.
SYMMETRICGenerates symmetric window values.
WithSeriesDataset#
Adds one or more derived series to the base dataset. Each entry’s definition must reference only the wrapping input. Series names must be unique within the request; a derived name replaces a same-named series from input.
inputDatasetrequiredThe base dataset to which the new series will be added.
seriesarray ofNamedSeriesThe named derived series to add.
ZscoreSeries#
Computes the z-score for each series within a group-by family. For each group at each timestamp, the output is (value - mean) / stddev, where mean and stddev are computed across all groups in the family at that timestamp, using the interpolation configuration to align values across groups. When stddev is zero at a timestamp (e.g., all groups have the same value), that data point is excluded from the output. If groupByTags is empty, all groups in the input series will be considered as a single family. This node only produces meaningful results when the input has a group by.
inputNumericSeriesrequired
groupByTagsarray ofStringConstantTags to group by for the normalization. If left empty, all groups in the input will be considered as a single family. Otherwise, inputs will be normalized separately across the groups specified by the tags.
interpolationConfigurationInterpolationConfigurationdeprecatedConfiguration for aligning values across groups at each timestamp. Defaults to forward fill interpolation with a 1s interpolation radius. Deprecated: Setting interpolation on this node is deprecated.
Page design based on Scalar, MIT License.