{ "topologyName": "HL7", "config": "{\"topology.workers\":1,\"topology.acker.executors\":1,\"topology.message.timeout.secs\":30,\"clustersSecurityConfig\":[{}]}", "sources": [{ "id": 11, "topologyId": 1, "topologyComponentBundleId": 1, "versionId": 7, "name": "KAFKA-1", "description": "", "config": { "properties": { "cluster": "3", "consumerGroupId": "sampatientreader", "retryDelayPeriodMs": 2, "maximumUncommittedOffsets": 10000000, "maxRecordsPerPoll": "500", "maximumRetries": 2147483647, "parallelism": 1, "emitNullTuples": false, "partitionRefreshPeriodMs": 2000, "securityProtocol": "PLAINTEXT", "bootstrapServers": "princeton-1225-1-0.field.hortonworks.com:6667", "kafkaServiceName": "", "retryDelayMaximumMs": 10000, "fetchMaximumBytesPerPartition": "1048576", "firstPollOffsetStrategy": "UNCOMMITTED_EARLIEST", "sslTruststoreType": "JKS", "clusters": "princeton", "fetchMinimumBytes": "1", "consumerStartupDelayMs": 60000, "sslKeystoreType": "JKS", "sslTrustManagerAlgo": "PKIX", "retryInitialDelayMs": 0, "sslKeyManagerAlgo": "SunX509", "sslProtocol": "TLS", "topic": "patientdata", "pollTimeoutMs": 200, "offsetCommitPeriodMs": 30000 } }, "outputStreams": [{ "id": 8, "versionId": 7, "streamId": "kafka_stream_11", "description": null, "topologyId": 1, "fields": [{ "name": "PID_SSNNumberPatient", "type": "INTEGER", "optional": false }, { "name": "email", "type": "STRING", "optional": false }, { "name": "gender", "type": "STRING", "optional": false }, { "name": "ip_address", "type": "STRING", "optional": false }, { "name": "drug_provider", "type": "STRING", "optional": false }, { "name": "icd9", "type": "STRING", "optional": false }, { "name": "icd9_description", "type": "STRING", "optional": false }, { "name": "icd9P_proc", "type": "STRING", "optional": false }, { "name": "icd9_proc_description", "type": "STRING", "optional": false }, { "name": "user_agent", "type": "STRING", "optional": false }, { "name": "drug_used", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508943522012 }, { "id": 1, "topologyId": 1, "topologyComponentBundleId": 1, "versionId": 7, "name": "KAFKA", "description": "", "config": { "properties": { "cluster": "3", "consumerGroupId": "client1simple", "retryDelayPeriodMs": 2, "maximumUncommittedOffsets": 10000000, "maxRecordsPerPoll": "500", "maximumRetries": 2147483647, "parallelism": 1, "emitNullTuples": false, "partitionRefreshPeriodMs": 2000, "securityProtocol": "PLAINTEXT", "bootstrapServers": "princeton-1225-1-0.field.hortonworks.com:6667", "kafkaServiceName": "", "retryDelayMaximumMs": 10000, "fetchMaximumBytesPerPartition": "1048576", "firstPollOffsetStrategy": "UNCOMMITTED_EARLIEST", "sslTruststoreType": "JKS", "clusters": "princeton", "fetchMinimumBytes": "1", "consumerStartupDelayMs": 60000, "sslKeystoreType": "JKS", "sslTrustManagerAlgo": "PKIX", "retryInitialDelayMs": 0, "sslKeyManagerAlgo": "SunX509", "sslProtocol": "TLS", "topic": "simple", "pollTimeoutMs": 200, "offsetCommitPeriodMs": 30000 } }, "outputStreams": [{ "id": 1, "versionId": 7, "streamId": "kafka_stream_1", "description": null, "topologyId": 1, "fields": [{ "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508943521989 }], "sinks": [{ "id": 6, "topologyId": 1, "topologyComponentBundleId": 10, "versionId": 7, "name": "HDFS", "description": "", "config": { "properties": { "fsUrl": "hdfs://princeton-1225-1-0.field.hortonworks.com:8020", "outputFields": ["MSH_SendingApplication_NamespaceID", "OBR_1_FillerOrderNumber_EntityIdentifier", "PID_PatientAccountNumber_ID", "MSH_MessageType_MessageType", "PID_Sex", "OBX_1_Units_NameOfCodingSystem", "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "PID_PatientName_GivenName", "OBX_1_Units_Identifier", "OBR_1_OrderingProvider_MiddleInitialOrName", "PID_PatientIDInternalID_ID", "OBX_1_ValueType", "OBX_1_Units_Text", "MSH_FieldSeparator", "OBX_1_SetIDOBX", "OBR_1_PlacerOrderNumber_EntityIdentifier", "OBR_1_SetIDObservationRequest", "OBR_1_OrderingProvider_GivenName", "OBR_1_ScheduledDateTime", "OBX_1_ObservationValue", "OBX_1_NatureOfAbnormalTest", "OBR_1_ResultsRptStatusChngDateTime", "OBR_1_ObservationDateTime", "MSH_VersionID", "MSH_EncodingCharacters", "OBR_1_ResultStatus", "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "MSH_MessageType_TriggerEvent", "OBR_1_PlacerOrderNumber_NamespaceID", "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "OBR_1_OrderingProvider_IDNumber", "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "PID_PatientName_FamilyName", "OBX_1_ObservationSubID", "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "PID_DateOfBirth", "MSH_ProcessingID_ProcessingID", "MSH_ReceivingApplication_NamespaceID", "OBR_1_UniversalServiceIdentifier_Text", "OBX_1_ObservationIdentifier_Text", "OBX_1_ObservationIdentifier_Identifier", "OBX_1_ReferencesRange", "PID_SSNNumberPatient", "MSH_MessageControlID", "OBX_1_UserDefinedAccessChecks", "OBR_1_UniversalServiceIdentifier_Identifier", "OBR_1_OrderingProvider_FamilyName"], "cluster": "3", "path": "/hl7sam", "extension": ".txt", "rotationPolicy": { "sizeBasedRotation": { "rotationSize": 1, "rotationSizeUnit": "KB" } }, "prefix": "", "parallelism": 1, "countPolicyValue": 1, "clusters": "princeton" } }, "timestamp": 1508974439083 }, { "id": 15, "topologyId": 1, "topologyComponentBundleId": 16, "versionId": 7, "name": "DRUID-1", "description": "", "config": { "properties": { "cluster": "3", "clusterReplication": 1, "segmentGranularity": "HOUR", "indexRetryPeriod": "PT10M", "maxBatchSize": 2000, "maxPendingBatches": 5, "discoveryPath": "/druid/discovery", "clusterPartitions": 1, "windowPeriod": "PT10M", "aggregatorList": [], "tranquilityZKconnect": "princeton-1225-1-0.field.hortonworks.com:2181", "discardStreamId": "DRUID-DISCARD-STREAM-ID", "indexService": "druid/overlord", "blockOnFull": true, "timestampField": "processingTime", "lingerMillis": 0, "queryGranularity": "MINUTE", "dataSource": "patientboth", "clusters": "princeton", "dimensions": ["PID_SSNNumberPatient", "icd9", "drug_used", "user_agent", "icd9_proc_description", "icd9P_proc", "drug_provider", "gender", "icd9_description", "email", "ip_address", "MSH_MessageControlID", "MSH_ReceivingApplication_NamespaceID", "OBR_1_UniversalServiceIdentifier_Text", "PID_PatientAccountNumber_ID", "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "PID_DateOfBirth", "OBX_1_ReferencesRange", "MSH_MessageType_MessageType", "OBX_1_Units_NameOfCodingSystem", "PID_PatientName_GivenName", "OBX_1_ObservationSubID", "OBR_1_PlacerOrderNumber_NamespaceID", "OBR_1_ScheduledDateTime", "OBX_1_ObservationIdentifier_Identifier", "OBR_1_OrderingProvider_GivenName", "OBR_1_SetIDObservationRequest", "OBR_1_ResultsRptStatusChngDateTime", "OBR_1_PlacerOrderNumber_EntityIdentifier", "OBX_1_NatureOfAbnormalTest", "OBX_1_Units_Text", "OBR_1_ObservationDateTime", "PID_PatientName_FamilyName", "OBX_1_Units_Identifier", "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "OBX_1_ObservationIdentifier_Text", "OBX_1_UserDefinedAccessChecks", "MSH_SendingApplication_NamespaceID", "OBR_1_FillerOrderNumber_EntityIdentifier", "PID_Sex", "OBR_1_OrderingProvider_IDNumber", "OBR_1_OrderingProvider_MiddleInitialOrName", "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "MSH_MessageType_TriggerEvent", "OBX_1_ValueType", "PID_PatientIDInternalID_ID", "MSH_FieldSeparator", "OBX_1_SetIDOBX", "MSH_VersionID", "MSH_EncodingCharacters", "OBX_1_ObservationValue", "OBR_1_UniversalServiceIdentifier_Identifier", "OBR_1_ResultStatus", "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "MSH_ProcessingID_ProcessingID", "OBR_1_OrderingProvider_FamilyName"] } }, "timestamp": 1508974439083 }, { "id": 14, "topologyId": 1, "topologyComponentBundleId": 18, "versionId": 7, "name": "KAFKA-2", "description": "", "config": { "properties": { "cluster": "3", "parallelism": 1, "compressionType": "none", "keySerializer": "ByteArray", "timeout": "30000", "securityProtocol": "PLAINTEXT", "bootstrapServers": "princeton-1225-1-0.field.hortonworks.com:6667", "metadataMaxAge": "300000", "kafkaServiceName": "", "sslTruststoreType": "JKS", "requestTimeout": "30000", "clusters": "princeton", "metadataFetchTimeout": "60000", "clientId": "", "maxRequestSize": "1048576", "reconnectBackoff": "50", "blocKOnBufferFull": true, "sendBufferSize": "131072", "sslKeystoreType": "JKS", "lingerTime": "0", "sslTrustManagerAlgo": "PKIX", "retryBackoff": "100", "sslKeyManagerAlgo": "SunX509", "maxInflighRequests": "5", "async": true, "retries": "0", "bufferMemory": "33554432", "receiveBufferSize": "32768", "fireAndForget": false, "ackMode": "Leader", "sslProtocol": "TLS", "topic": "patientboth", "batchSize": "16384", "maxConnectionIdle": "540000", "maxBlock": "60000" } }, "timestamp": 1508974439083 }, { "id": 4, "topologyId": 1, "topologyComponentBundleId": 12, "versionId": 7, "name": "NOTIFICATION", "description": "", "config": { "properties": { "notifierName": "Email Notifier", "parallelism": 1, "className": "com.hortonworks.streamline.streams.notifiers.EmailNotifier", "fieldValues": { "contentType": "text/plain", "from": "tim@sparkdeveloper.com", "to": "tim@sparkdeveloper.com", "subject": "SAM HL7 Data", "body": " ${OBX_1_UserDefinedAccessChecks} \n${OBR_1_OrderingProvider_FamilyName}\n${MSH_MessageControlID}\n${MSH_SendingApplication_NamespaceID}\n${MSH_ProcessingID_ProcessingID}\n${PID_SSNNumberPatient} <- use atlas to mask\n${OBR_1_FillerOrderNumber_EntityIdentifier}\n${PID_PatientAccountNumber_ID}\nPID_DateOfBirth = ${PID_DateOfBirth}\nPID_Sex = ${PID_Sex}\nOBX_1_ReferencesRange=${OBX_1_ReferencesRange}\nOBX_1_Units_NameOfCodingSystem=${OBX_1_Units_NameOfCodingSystem}\nOBR_1_ResultStatus=${OBR_1_ResultStatus}\nOBR_1_ScheduledDateTime=${OBR_1_ScheduledDateTime}" }, "notificationStoreClassName": "", "jarFileName": "notifiers-7441adfa-8ebc-438c-ba73-d017a676ae20.jar", "properties": { "ssl": false, "starttls": false, "debug": true, "protocol": "smtp", "auth": false, "username": "nifi@dataflowdeveloper.com", "password": "test", "host": "smtp.agilemobiledeveloper.com", "port": 587 } } }, "timestamp": 1508974439083 }, { "id": 5, "topologyId": 1, "topologyComponentBundleId": 16, "versionId": 7, "name": "DRUID", "description": "", "config": { "properties": { "cluster": "3", "clusterReplication": 1, "segmentGranularity": "HOUR", "indexRetryPeriod": "PT10M", "maxBatchSize": 2000, "maxPendingBatches": 5, "discoveryPath": "/druid/discovery", "clusterPartitions": 1, "windowPeriod": "PT10M", "aggregatorList": [], "tranquilityZKconnect": "princeton-1225-1-0.field.hortonworks.com:2181", "discardStreamId": "DRUID-DISCARD-STREAM-ID", "indexService": "druid/overlord", "blockOnFull": true, "timestampField": "processingTime", "lingerMillis": 0, "queryGranularity": "MINUTE", "dataSource": "hl7oru", "clusters": "princeton", "dimensions": ["OBX_1_UserDefinedAccessChecks", "OBR_1_OrderingProvider_FamilyName", "MSH_MessageControlID", "PID_SSNNumberPatient", "OBX_1_Units_Identifier", "MSH_VersionID", "OBR_1_OrderingProvider_GivenName", "OBX_1_NatureOfAbnormalTest", "OBR_1_OrderingProvider_MiddleInitialOrName", "PID_PatientIDInternalID_ID", "OBX_1_ValueType", "OBX_1_Units_Text", "MSH_FieldSeparator", "OBX_1_SetIDOBX", "OBR_1_ResultsRptStatusChngDateTime", "OBR_1_SetIDObservationRequest", "OBR_1_ScheduledDateTime", "OBR_1_UniversalServiceIdentifier_Identifier", "OBX_1_ObservationIdentifier_Identifier", "MSH_EncodingCharacters", "OBR_1_ResultStatus", "OBX_1_ObservationValue", "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "PID_PatientName_FamilyName", "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "OBX_1_ObservationSubID", "OBX_1_Units_NameOfCodingSystem", "OBR_1_PlacerOrderNumber_EntityIdentifier", "OBR_1_ObservationDateTime", "MSH_MessageType_TriggerEvent", "OBR_1_PlacerOrderNumber_NamespaceID", "PID_PatientName_GivenName", "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "OBR_1_OrderingProvider_IDNumber", "OBX_1_ReferencesRange", "MSH_MessageType_MessageType", "PID_Sex", "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "PID_DateOfBirth", "PID_PatientAccountNumber_ID", "OBR_1_FillerOrderNumber_EntityIdentifier", "MSH_ProcessingID_ProcessingID", "MSH_ReceivingApplication_NamespaceID", "OBR_1_UniversalServiceIdentifier_Text", "OBX_1_ObservationIdentifier_Text", "MSH_SendingApplication_NamespaceID"] } }, "timestamp": 1508974439083 }, { "id": 9, "topologyId": 1, "topologyComponentBundleId": 11, "versionId": 7, "name": "HBASE", "description": "", "config": { "properties": { "writeToWAL": true, "cluster": "3", "columnFamily": "obs", "parallelism": 1, "batchSize": 1, "clusters": "princeton", "table": "default:patient_observations" } }, "timestamp": 1508974439083 }], "processors": [{ "id": 12, "topologyId": 1, "topologyComponentBundleId": 7, "versionId": 7, "name": "JOIN", "description": "", "config": { "properties": { "joins": [{ "type": "LEFT", "stream": "kafka_stream_1", "key": "PID_SSNNumberPatient", "with": "kafka_stream_11" }], "parallelism": 1, "from": { "stream": "kafka_stream_11", "key": "PID_SSNNumberPatient" }, "outputKeys": ["kafka_stream_11:PID_SSNNumberPatient as PID_SSNNumberPatient", "icd9", "drug_used", "user_agent", "MSH_MessageControlID", "MSH_ReceivingApplication_NamespaceID", "OBR_1_UniversalServiceIdentifier_Text", "PID_PatientAccountNumber_ID", "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "PID_DateOfBirth", "OBX_1_ReferencesRange", "MSH_MessageType_MessageType", "OBX_1_Units_NameOfCodingSystem", "PID_PatientName_GivenName", "OBX_1_ObservationSubID", "OBR_1_PlacerOrderNumber_NamespaceID", "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "OBR_1_ResultStatus", "MSH_EncodingCharacters", "MSH_VersionID", "OBR_1_UniversalServiceIdentifier_Identifier", "OBR_1_ScheduledDateTime", "OBX_1_ObservationIdentifier_Identifier", "OBR_1_OrderingProvider_GivenName", "OBR_1_SetIDObservationRequest", "OBR_1_ResultsRptStatusChngDateTime", "OBR_1_PlacerOrderNumber_EntityIdentifier", "OBX_1_NatureOfAbnormalTest", "OBX_1_SetIDOBX", "MSH_FieldSeparator", "OBX_1_ObservationValue", "PID_PatientIDInternalID_ID", "OBX_1_ValueType", "OBX_1_Units_Text", "OBR_1_ObservationDateTime", "PID_PatientName_FamilyName", "MSH_MessageType_TriggerEvent", "OBX_1_Units_Identifier", "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "OBR_1_OrderingProvider_IDNumber", "PID_Sex", "OBR_1_FillerOrderNumber_EntityIdentifier", "MSH_SendingApplication_NamespaceID", "OBX_1_ObservationIdentifier_Text", "OBX_1_UserDefinedAccessChecks", "OBR_1_OrderingProvider_MiddleInitialOrName", "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "MSH_ProcessingID_ProcessingID", "icd9_proc_description", "icd9P_proc", "drug_provider", "gender", "icd9_description", "email", "OBR_1_OrderingProvider_FamilyName", "ip_address", "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName"], "window": { "windowLength": { "class": ".Window$Count", "count": 10 }, "slidingInterval": { "class": ".Window$Count", "count": 10 }, "tsField": null, "lagMs": 0 }, "outputStream": "join_processor_stream_12" } }, "outputStreams": [{ "id": 9, "versionId": 7, "streamId": "join_processor_stream_12", "description": null, "topologyId": 1, "fields": [{ "name": "PID_SSNNumberPatient", "type": "INTEGER", "optional": false }, { "name": "icd9", "type": "STRING", "optional": false }, { "name": "drug_used", "type": "STRING", "optional": false }, { "name": "user_agent", "type": "STRING", "optional": false }, { "name": "icd9_proc_description", "type": "STRING", "optional": false }, { "name": "icd9P_proc", "type": "STRING", "optional": false }, { "name": "drug_provider", "type": "STRING", "optional": false }, { "name": "gender", "type": "STRING", "optional": false }, { "name": "icd9_description", "type": "STRING", "optional": false }, { "name": "email", "type": "STRING", "optional": false }, { "name": "ip_address", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508974439083 }, { "id": 3, "topologyId": 1, "topologyComponentBundleId": 4, "versionId": 7, "name": "RULE", "description": "", "config": { "properties": { "rules": [1] } }, "outputStreams": [{ "id": 4, "versionId": 7, "streamId": "rule_transform_stream_1", "description": null, "topologyId": 1, "fields": [{ "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }, { "id": 5, "versionId": 7, "streamId": "rule_notifier_stream_1", "description": null, "topologyId": 1, "fields": [{ "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508974439083 }, { "id": 10, "topologyId": 1, "topologyComponentBundleId": 4, "versionId": 7, "name": "RULE-1", "description": "", "config": { "properties": { "rules": [2] } }, "outputStreams": [{ "id": 6, "versionId": 7, "streamId": "rule_transform_stream_2", "description": null, "topologyId": 1, "fields": [{ "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }, { "id": 7, "versionId": 7, "streamId": "rule_notifier_stream_2", "description": null, "topologyId": 1, "fields": [{ "name": "OBX_1_UserDefinedAccessChecks", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_MessageControlID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_SendingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Text", "type": "STRING", "optional": false }, { "name": "MSH_ReceivingApplication_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_ProcessingID_ProcessingID", "type": "STRING", "optional": false }, { "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBR_1_FillerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "PID_PatientAccountNumber_ID", "type": "STRING", "optional": false }, { "name": "PID_DateOfBirth", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_IDNumber", "type": "STRING", "optional": false }, { "name": "PID_Sex", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_MessageType", "type": "STRING", "optional": false }, { "name": "OBX_1_ReferencesRange", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_IDNumber", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_FamilyName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_NameOfCodingSystem", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Identifier", "type": "STRING", "optional": false }, { "name": "PID_PatientName_GivenName", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationSubID", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_NamespaceID", "type": "STRING", "optional": false }, { "name": "MSH_MessageType_TriggerEvent", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_AssigningAuthority", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultStatus", "type": "STRING", "optional": false }, { "name": "PID_PatientName_FamilyName", "type": "STRING", "optional": false }, { "name": "MSH_EncodingCharacters", "type": "STRING", "optional": false }, { "name": "MSH_VersionID", "type": "STRING", "optional": false }, { "name": "OBR_1_UniversalServiceIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_ObservationDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_ScheduledDateTime", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationIdentifier_Identifier", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_GivenName", "type": "STRING", "optional": false }, { "name": "OBR_1_SetIDObservationRequest", "type": "STRING", "optional": false }, { "name": "OBR_1_ResultsRptStatusChngDateTime", "type": "STRING", "optional": false }, { "name": "OBR_1_PlacerOrderNumber_EntityIdentifier", "type": "STRING", "optional": false }, { "name": "OBX_1_NatureOfAbnormalTest", "type": "STRING", "optional": false }, { "name": "OBX_1_SetIDOBX", "type": "STRING", "optional": false }, { "name": "MSH_FieldSeparator", "type": "STRING", "optional": false }, { "name": "PD1_PatientPrimaryCareProviderNameIDNo_MiddleInitialOrName", "type": "STRING", "optional": false }, { "name": "OBX_1_Units_Text", "type": "STRING", "optional": false }, { "name": "OBX_1_ValueType", "type": "STRING", "optional": false }, { "name": "PID_PatientIDInternalID_ID", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue", "type": "STRING", "optional": false }, { "name": "OBR_1_OrderingProvider_MiddleInitialOrName", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508974439083 }, { "id": 2, "topologyId": 1, "topologyComponentBundleId": 5, "versionId": 7, "name": "AGGREGATE", "description": "", "config": { "properties": { "rules": [1], "parallelism": 1 } }, "outputStreams": [{ "id": 2, "versionId": 7, "streamId": "window_transform_stream_2", "description": null, "topologyId": 1, "fields": [{ "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue_MAX", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }, { "id": 3, "versionId": 7, "streamId": "window_notifier_stream_2", "description": null, "topologyId": 1, "fields": [{ "name": "PID_SSNNumberPatient", "type": "STRING", "optional": false }, { "name": "OBX_1_ObservationValue_MAX", "type": "STRING", "optional": false }], "timestamp": 1508974439083 }], "timestamp": 1508974439083 }], "edges": [{ "id": 10, "versionId": 7, "topologyId": 1, "fromId": 11, "toId": 12, "streamGroupings": [{ "streamId": 8, "grouping": "FIELDS", "fields": ["PID_SSNNumberPatient"] }], "timestamp": 1508974439083 }, { "id": 1, "versionId": 7, "topologyId": 1, "fromId": 1, "toId": 2, "streamGroupings": [{ "streamId": 1, "grouping": "FIELDS", "fields": ["PID_SSNNumberPatient"] }], "timestamp": 1508974439083 }, { "id": 2, "versionId": 7, "topologyId": 1, "fromId": 1, "toId": 3, "streamGroupings": [{ "streamId": 1, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 6, "versionId": 7, "topologyId": 1, "fromId": 1, "toId": 6, "streamGroupings": [{ "streamId": 1, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 11, "versionId": 7, "topologyId": 1, "fromId": 1, "toId": 12, "streamGroupings": [{ "streamId": 1, "grouping": "FIELDS", "fields": ["PID_SSNNumberPatient"] }], "timestamp": 1508974439083 }, { "id": 13, "versionId": 7, "topologyId": 1, "fromId": 12, "toId": 14, "streamGroupings": [{ "streamId": 9, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 14, "versionId": 7, "topologyId": 1, "fromId": 12, "toId": 15, "streamGroupings": [{ "streamId": 9, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 4, "versionId": 7, "topologyId": 1, "fromId": 3, "toId": 5, "streamGroupings": [{ "streamId": 4, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 8, "versionId": 7, "topologyId": 1, "fromId": 3, "toId": 10, "streamGroupings": [{ "streamId": 4, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 9, "versionId": 7, "topologyId": 1, "fromId": 10, "toId": 4, "streamGroupings": [{ "streamId": 7, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }, { "id": 7, "versionId": 7, "topologyId": 1, "fromId": 2, "toId": 9, "streamGroupings": [{ "streamId": 2, "grouping": "SHUFFLE", "fields": null }], "timestamp": 1508974439083 }], "rules": [{ "id": 1, "versionId": 7, "topologyId": 1, "name": "test1", "description": "test1", "streams": ["kafka_stream_1"], "condition": "PID_Sex = 'M' OR PID_Sex = 'F'", "sql": "SELECT * FROM kafka_stream_1 WHERE PID_Sex = 'M' OR PID_Sex = 'F'", "actions": [{ "__type": "com.hortonworks.streamline.streams.layout.component.rule.action.TransformAction", "name": "transformAction", "outputStreams": ["rule_transform_stream_1"], "transforms": [] }], "outputStreams": ["rule_transform_stream_1", "rule_notifier_stream_1"], "timestamp": 1508974439083 }, { "id": 2, "versionId": 7, "topologyId": 1, "name": "limit", "description": "limit number of emails sent", "streams": ["rule_transform_stream_1"], "condition": "MSH_MessageControlID = 909934343434", "sql": "SELECT * FROM rule_transform_stream_1 WHERE MSH_MessageControlID = 909934343434", "actions": [{ "__type": "com.hortonworks.streamline.streams.layout.component.rule.action.NotifierAction", "name": "notifierAction", "outputStreams": ["rule_notifier_stream_2"], "notifierName": "Email Notifier", "outputFieldsAndDefaults": { "from": "tim@sparkdeveloper.com", "to": "tim@sparkdeveloper.com", "body": " ${OBX_1_UserDefinedAccessChecks} \n${OBR_1_OrderingProvider_FamilyName}\n${MSH_MessageControlID}\n${MSH_SendingApplication_NamespaceID}\n${MSH_ProcessingID_ProcessingID}\n${PID_SSNNumberPatient} <- use atlas to mask\n${OBR_1_FillerOrderNumber_EntityIdentifier}\n${PID_PatientAccountNumber_ID}\nPID_DateOfBirth = ${PID_DateOfBirth}\nPID_Sex = ${PID_Sex}\nOBX_1_ReferencesRange=${OBX_1_ReferencesRange}\nOBX_1_Units_NameOfCodingSystem=${OBX_1_Units_NameOfCodingSystem}\nOBR_1_ResultStatus=${OBR_1_ResultStatus}\nOBR_1_ScheduledDateTime=${OBR_1_ScheduledDateTime}", "contentType": "text/plain", "subject": "SAM HL7 Data" } }], "outputStreams": ["rule_transform_stream_2", "rule_notifier_stream_2"], "timestamp": 1508974439083 }], "windows": [{ "id": 1, "versionId": 7, "topologyId": 1, "name": "window_auto_generated", "description": "window description auto generated", "streams": ["kafka_stream_1"], "window": { "windowLength": { "class": ".Window$Count", "count": 11 }, "slidingInterval": { "class": ".Window$Count", "count": 11 }, "tsField": null, "lagMs": 0 }, "actions": [{ "__type": "com.hortonworks.streamline.streams.layout.component.rule.action.TransformAction", "name": "transformAction", "outputStreams": ["window_transform_stream_2"], "transforms": [] }], "projections": [{ "functionName": "MAX", "args": ["OBX_1_ObservationValue"], "outputFieldName": "OBX_1_ObservationValue_MAX" }, { "expr": "PID_SSNNumberPatient" }], "groupbykeys": ["PID_SSNNumberPatient"], "outputStreams": ["window_transform_stream_2", "window_notifier_stream_2"], "timestamp": 1508974439083 }], "branchRules": [], "bundleIdToType": { "11": "HBASE", "1": "KAFKA", "12": "NOTIFICATION", "4": "RULE", "16": "DRUID", "5": "WINDOW", "7": "JOIN", "18": "KAFKA", "10": "HDFS" }, "topologyEditorMetadata": { "topologyId": 1, "versionId": 7, "data": "{\"sources\":[{\"x\":-3.05120849609375,\"y\":325.58160400390625,\"id\":1},{\"x\":25.171905517578125,\"y\":568.0361938476562,\"id\":11}],\"processors\":[{\"x\":547.5,\"y\":152.5,\"id\":2},{\"x\":617.5,\"y\":347.5,\"id\":3},{\"x\":1238.75,\"y\":97.5,\"id\":10},{\"x\":378.2959899902344,\"y\":503.909912109375,\"id\":12}],\"sinks\":[{\"x\":1815,\"y\":172.5,\"id\":4},{\"x\":1204.83984375,\"y\":527.8359985351562,\"id\":5},{\"x\":796.64501953125,\"y\":-142.0833282470703,\"id\":6},{\"x\":986.25,\"y\":4.5,\"id\":9},{\"x\":1254.5443115234375,\"y\":730.3125,\"id\":14},{\"x\":1256.7144775390625,\"y\":1002.6649780273438,\"id\":15}],\"graphTransforms\":{\"dragCoords\":[221.54052017600884,85.79688423781715],\"zoomScale\":0.7213895789838337}}", "timestamp": 1508974439083 } }