• AppId:
  • Example:
  • Description:
• ElementId:
  • Example:
  • Description
• InvocationId:
  • Example:
  • Description

• AdapterId:
• Tags
  • Service Group:
    • Core / Ext
  • Extension Services Group:
    • Example:
      • (spgroup:)org-apache-streampipes-pe-all-jvm (Init: SpSerrviceDefinitionBuilder.init(ID))
  • Service ID
    • • {spgroup}-{randomID}
      • org-apache-streampipes-pe-all-jvm-7Cc4bD
  • Pipeline Element / ExtensionsModule:
    • Example:

      • {appId}

      • (dprocessor:)org.apache.streampipes.processors.transformation.jvm.booloperator.logical
      • dsink:org.apache.streampipes.sinks.notifications.jvm.slack
  • Extensions Module Instance:
    • {elementId} / CouchDBId / AbstractStreamPipesEntity
    • InvocationGraphBuilder → makeElementIdentifier → "{pipelineId}-{topic}-{elementName}-{uniquePEIndex}"

Class hierarchy

• AbstractStreamPipesEntity (elementId)
  • NamedStreamPipesEntity (appId)
    • ConsumableStreamPipesEntity
      • DataProcessorDescription (Maybe delete pathName)
      • DataSinkDescription
    • SpDataStream (Maybe delete index)
      • SpDataSet (datasetInvocationId, selectedEndpointUrl)
    • InvocableStreamPipesEntity (belongsTo, correspondingPipeline, selectedEnpointUrl)
      • DataProcessorInvocation  (Maybe delete pathName, iconURL)
    • AdapterDescription
      • DataSinkInvocation
  • UnnamedStreamPipesEntity (Maybe this can be removed)