Datasets

Pump telemetry

pump_telemetry_dataset

18 columns

One row per pump and timestamp

Declared column types and units for pump_telemetry_dataset; schema only, no sample records.

plantDimension	production_lineDimension	pumpDimension	timestampDimension	discharge_pressureRaw	flow_rateRaw	bearing_temperatureRaw	vibration_rmsRaw	motor_powerRaw	recommended_flow_rateFeature	recommended_discharge_pressureFeature	energy_cost_scoreFeature	convergedFeature	pressure_flow_efficiencyFeature	bearing_temperature_deltaFeature	vibration_deltaFeature	pump_health_scoreFeature	operating_point_recommendationFeature
string	string	string	datetime	float · bar	float · m3/h	float · C	float · mm/s	float · kW	float · m3/h	float · bar	float	boolean	float	float · C	float · mm/s	float	object

Dataset details

Pump process and condition readings sampled at one-minute intervals.

Filtering

Development telemetry selected by the read function

Logical order (not a physical row-order guarantee)

• $dimensions.timestamp asc

Mappings

read · read_pump_telemetry write · write_pump_telemetry

Pump

pump_dataset

5 columns

One row per pump

Declared column types and units for pump_dataset; schema only, no sample records.

plantDimension	production_lineDimension	pumpDimension	bearing_temperature_maxFeature	health_signal_normalizedFeature
string	string	string	float · C	float

Dataset details

One row per pump with collapsed condition information.

Filtering

Telemetry available to the source dataset

Mappings

collapse · bearing_temperature_by_pump

Input dataset inferred from bound features · Group by entity dimensions: ["plant", "production_line", "pump"]

maximum({"dataset": "$datasets.pump_telemetry_dataset.dataframe", "dimensions": ["$dimensions.plant.id", "$dimensions.production_line.id", "$dimensions.pump.id"], "feature": "$features.bearing_temperature", "output": "$features.bearing_temperature_max.id"})