Path	Lines of Code
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsResourceUrlProvider.java	7
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsServiceEndpointGenerator.java	21
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/AssetConstants.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/AssetExtractor.java	29
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/AssetFetcher.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/AssetManager.java	50
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/DocumentationParser.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/ImagePathReplacer.java	24
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraph.java	8
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphBuilder.java	48
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphHelpers.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/ExtensionServiceExecutions.java	40
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionInfo.java	52
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java	37
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutor.java	27
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointGenerator.java	64
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointUtils.java	40
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachPipelineElementSubmitter.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokeHttpRequest.java	29
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokePipelineElementSubmitter.java	47
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementHttpRequest.java	46
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementSubmitter.java	40
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/CurrentPipelineElementProvider.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/PipelineElementProvider.java	7
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/StoredPipelineElementProvider.java	16
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/status/PipelineStatusManager.java	37
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/AfterInvocationTask.java	34
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/DiscoverEndpointsTask.java	54
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/PipelineExecutionTask.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/SecretEncryptionTask.java	15
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/StorePipelineStatusTask.java	50
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/SubmitRequestTask.java	24
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/UpdateGroupIdTask.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/AvailableExtensionsProvider.java	78
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionItemInstaller.java	31
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionsResourceUrlProvider.java	46
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/file/FileConstants.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/file/FileHandler.java	47
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/file/FileManager.java	116
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/function/FunctionRegistrationService.java	24
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/CoreInitialInstallationProgress.java	11
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/CoreServiceStatusManager.java	31
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineElementEndpointHealthCheck.java	24
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java	199
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/ServiceHealthCheck.java	67
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/ServiceRegistrationManager.java	69
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/info/SystemInfoProvider.java	30
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/info/VersionInfoProvider.java	9
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/GroundingBuilder.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/GroundingSelector.java	21
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineModificationGenerator.java	121
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandlerV2.java	104
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java	100
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/mapping/AbstractRequirementsSelectorGenerator.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/mapping/EmptyRequirementsSelectorGenerator.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/mapping/MappingPropertyCalculator.java	34
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/mapping/RequirementsSelectorGenerator.java	28
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/mapping/RequirementsSelectorGeneratorFactory.java	19
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/AppendOutputSchemaGenerator.java	47
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/CustomOutputSchemaGenerator.java	38
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/CustomTransformOutputSchemaGenerator.java	59
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/FixedOutputSchemaGenerator.java	27
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/ListOutputSchemaGenerator.java	36
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/OutputSchemaFactory.java	40
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/OutputSchemaGenerator.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/PropertyDuplicateRemover.java	51
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/RenameOutputSchemaGenerator.java	34
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/TransformOutputSchemaGenerator.java	151
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/UserDefinedOutputSchemaGenerator.java	27
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/AbstractMatcher.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/DatatypeMatch.java	36
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ElementVerification.java	26
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/GroundingMatch.java	28
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ListPropertyMatch.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/Matcher.java	6
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/MeasurementUnitMatch.java	16
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/NestedPropertyMatch.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/PrimitivePropertyMatch.java	34
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/PropertyMatch.java	61
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ProtocolMatch.java	19
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/SchemaMatch.java	29
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/SemanticTypeMatch.java	25
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/StreamMatch.java	33
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/AbstractPipelineValidationStep.java	16
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/ApplyGroundingStep.java	61
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/CheckCompletedStep.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/CheckCompletedVisitor.java	174
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/ComputeOutputStep.java	45
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/IPipelineValidationStep.java	12
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/PipelineValidationSteps.java	16
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/PipelineValidator.java	21
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/PrepareStep.java	28
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/SchemaValidationStep.java	39
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/SpValidationException.java	14
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/UpdateOutputStrategiesStep.java	64
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/UpdateStaticPropertiesStep.java	16
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/UpdateStaticPropertiesVisitor.java	79
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/utils/MatchingUtils.java	15
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AbstractMigrationManager.java	96
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java	19
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java	8
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/MigrationUtils.java	32
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/PipelineElementMigrationManager.java	188
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsLogProvider.java	93
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java	79
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/permission/PermissionManager.java	12
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineCacheManager.java	15
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineCanvasMetadataCacheManager.java	15
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineManager.java	97
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/CompactPipelineManagement.java	37
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/CompactPipelineConverter.java	85
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/CompactPipelineGenerator.java	7
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataProcessorPipelineElementGenerator.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataSinkPipelineElementGenerator.java	17
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataStreamPipelineElementGenerator.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/InvocablePipelineElementGenerator.java	26
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/OutputStrategyGenerator.java	68
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/PipelineElementConfigurationStep.java	46
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/ActivePipelinePreviews.java	22
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/PipelinePreview.java	134
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/recommender/AllElementsProvider.java	28
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/recommender/ElementRecommender.java	101
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/recommender/PartialPipelineGenerator.java	39
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/remote/ContainerProvidedOptionsHandler.java	34
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/runtime/DataStreamRuntimeInfoProvider.java	61
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/runtime/RateLimitedRuntimeInfoProvider.java	38
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/runtime/SpDataFormatConverter.java	13
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/selector/PropertyFinder.java	31
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/selector/PropertyRequirementSelector.java	57
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/selector/PropertySelector.java	116
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/selector/PropertySelectorGenerator.java	55
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/selector/PropertySelectorUtils.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/AutoInstallation.java	88
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/BackgroundTaskNotifier.java	4
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CouchDbInstallationStep.java	128
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/ExtensionsInstallationTask.java	62
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/InstallationConfiguration.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/InstallationStep.java	23
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/PipelineElementInstallationStep.java	32
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/SpCoreConfigurationStep.java	21
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/StreamPipesEnvChecker.java	101
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/UserRegistrationInstallationStep.java	62
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/design/DesignDocumentUtils.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/design/UserDesignDocument.java	60
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/AddDefaultPipelineTemplatesTask.java	14
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/ApplyDefaultRolesAndPrivilegesTask.java	40
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateAssetLinkTypeTask.java	56
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java	20
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/InstallationTask.java	4
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/PipelineStorageService.java	51
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/RunningPipelineElementStorage.java	8
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/AbstractTemplateHandler.java	24
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/AdapterTemplateHandler.java	19
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/CompactConfigGenerator.java	162
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/DataProcessorTemplateHandler.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/DataSinkTemplateHandler.java	10
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineElementTemplateHandler.java	18
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineElementTemplateVisitor.java	246
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/compact/CompactPipelineTemplateManagement.java	68
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/compact/MatchingStreamFinder.java	48
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/DefaultPipelineTemplateProvider.java	5
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/PersistDataLakePipelineTemplate.java	46
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/topic/WildcardTopicGenerator.java	38
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/AuthTokenUtils.java	45
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/TopicGenerator.java	11
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/AdapterVerifier.java	39
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataProcessorVerifier.java	37
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataSinkVerifier.java	37
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataStreamVerifier.java	38
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/ElementVerifier.java	169
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/StorageState.java	4
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/extractor/TypeExtractor.java	64
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationError.java	7
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationResult.java	12
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationWarning.java	7
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/AbstractVerifier.java	19
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralVerifier.java	22
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/Verifier.java	6