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) |
getPagingParams
public IoTCloudantProcessor() throws MXException, java.rmi.RemoteException
MXException
java.rmi.RemoteException
public 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 IoTHistorianProcessor
MXException
java.rmi.RemoteException
public 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
MXException
java.rmi.RemoteException
public 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 HistorianProcessor
pageSize
- 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
MXException
public boolean pingHistorian(IoTFService srv) throws java.rmi.RemoteException, MXException
pingHistorian
in class HistorianProcessor
java.rmi.RemoteException
MXException