public class IoTCloudantProcessor extends HistorianProcessor implements IoTHistorianProcessor
| Constructor and Description |
|---|
IoTCloudantProcessor() |
| Modifier and Type | Method and Description |
|---|---|
com.ibm.json.java.JSONObject |
evaluateExpression(com.ibm.json.java.JSONObject jsonData,
java.lang.String path) |
java.lang.Object |
getReadings(com.ibm.json.java.JSONObject jo,
IoTFDeviceMappingInfo mapInfo)
Map response of the external resource invocation to format accepted in AH Dash Board.
|
void |
mapReadings(com.ibm.json.java.JSONArray readings,
com.ibm.json.java.JSONObject jo,
IoTFDeviceMappingInfo mapInfo)
Map response of the external resource invocation to format accepted in AH Dash Board.
|
boolean |
pingHistorian(IoTFService srv) |
void |
processHistorianData(IoTFDeviceMappingInfo mappingInfo,
java.lang.String histURL,
URLFormatter uf,
java.lang.String endPointName,
java.lang.String iotOrg,
java.lang.String deviceType,
java.util.Date lastRun) |
com.ibm.json.java.JSONArtifact |
processResource(JSONResourceInfo resourceInfo,
MboRemote owner,
UserInfo userInfo,
int pageSize,
int currentPage,
JSONAnalyzer jsonAnalyzer)
Invoke external Resource
|
void |
syncMeterReadings(java.lang.String iotOrg,
java.lang.String deviceType,
java.lang.String instanceName,
java.util.Date lastRun) |
getPagingParamspublic IoTCloudantProcessor()
throws MXException,
java.rmi.RemoteException
MXExceptionjava.rmi.RemoteExceptionpublic void syncMeterReadings(java.lang.String iotOrg,
java.lang.String deviceType,
java.lang.String instanceName,
java.util.Date lastRun)
throws MXException,
java.rmi.RemoteException
syncMeterReadings in interface IoTHistorianProcessorMXExceptionjava.rmi.RemoteExceptionpublic void processHistorianData(IoTFDeviceMappingInfo mappingInfo, java.lang.String histURL, URLFormatter uf, java.lang.String endPointName, java.lang.String iotOrg, java.lang.String deviceType, java.util.Date lastRun) throws MXException, java.rmi.RemoteException
MXExceptionjava.rmi.RemoteExceptionpublic com.ibm.json.java.JSONArtifact processResource(JSONResourceInfo resourceInfo, MboRemote owner, UserInfo userInfo, int pageSize, int currentPage, JSONAnalyzer jsonAnalyzer) throws MXException, java.rmi.RemoteException
processResource in class HistorianProcessorpageSize - Page size if paging is usedpageNum - Current pageMXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic void mapReadings(com.ibm.json.java.JSONArray readings,
com.ibm.json.java.JSONObject jo,
IoTFDeviceMappingInfo mapInfo)
throws MXException,
java.rmi.RemoteException
ja - JSON with results of the external invocationpageSize - Page size if paging is usedpageNum - Current pageMXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic java.lang.Object getReadings(com.ibm.json.java.JSONObject jo,
IoTFDeviceMappingInfo mapInfo)
throws MXException,
java.rmi.RemoteException
ja - JSON with results of the external invocationpageSize - Page size if paging is usedpageNum - Current pageMXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic com.ibm.json.java.JSONObject evaluateExpression(com.ibm.json.java.JSONObject jsonData,
java.lang.String path)
throws MXException
MXExceptionpublic boolean pingHistorian(IoTFService srv) throws java.rmi.RemoteException, MXException
pingHistorian in class HistorianProcessorjava.rmi.RemoteExceptionMXException