This is an automated email from the ASF dual-hosted git repository.
gomm pushed a change to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from e4c427c [hotfix] add updated run configs
new bf01f58 Refactored and reorganized offloading
new 77edacb Merge branch 'edge-extensions' of
https://github.com/apache/incubator-streampipes into edge-extensions
new 657b34c [WIP] Check for Hardware requirement to filter supported
entities
new d27684a Refactored and standardized offloading
new 388de91 Merge branch 'edge-extensions' of
https://github.com/apache/incubator-streampipes into edge-extensions
new 5daf569 resolve remaining merge conflicts
new 589dec6 Refactoring and added priority based offloading
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../backend/StreamPipesBackendApplication.java | 1 -
.../extensions/ExtensionsModelSubmitter.java | 24 +++--
.../standalone/init/StandaloneModelSubmitter.java | 25 +++--
.../model/node/InvocableRegistration.java | 15 +--
.../container/util/NodeControllerUtil.java | 15 +--
.../model/base/InvocableStreamPipesEntity.java | 22 +++++
.../model/message/NotificationType.java | 1 +
.../streampipes/model/pipeline/Pipeline.java | 4 +
.../offloading/OffloadingPolicyManager.java | 100 ++++++++++++++++++++
.../offloading/model/OffloadingStrategy.java | 68 ++++++++++++++
.../model/OffloadingStrategyFactory.java | 60 ++++++++++++
.../{ => model}/policies/Comparator.java | 2 +-
.../{ => model}/policies/OffloadingPolicy.java | 2 +-
.../ThresholdViolationOffloadingPolicy.java} | 22 +++--
.../property/CPULoadResourceProperty.java} | 16 +++-
.../property/FreeDiskSpaceResourceProperty.java} | 14 ++-
.../property/FreeMemoryResourceProperty.java} | 13 ++-
.../property/ResourceProperty.java} | 11 ++-
.../model/selection/CPULoadSelectionStrategy.java | 17 ++--
.../model/selection/PrioritySelectionStrategy.java | 69 ++++++++++++++
.../selection/RandomSelectionStrategy.java} | 20 ++--
.../selection/SelectionStrategy.java} | 10 +-
.../management/pe/InvocableElementManager.java | 31 ++++---
.../management/resource/ResourceManager.java | 24 ++---
.../management/resource/utils/FileSystemType.java | 3 +-
.../management/resource/utils/ResourceChecker.java | 82 +++++++++++++++++
.../management/resource/utils/ResourceUtils.java | 2 +
.../monitor/resource/ClusterResourceMonitor.java | 20 ++++
.../migration/MigrationPipelineGenerator.java | 102 +++++++++++++++++----
.../migration/PipelineElementOffloadHandler.java | 5 +-
ui/src/app/core-model/gen/streampipes-model.ts | 12 ++-
.../save-pipeline/save-pipeline.component.ts | 11 +++
32 files changed, 685 insertions(+), 138 deletions(-)
create mode 100644
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/OffloadingPolicyManager.java
create mode 100644
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/model/OffloadingStrategy.java
create mode 100644
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/model/OffloadingStrategyFactory.java
copy
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{
=> model}/policies/Comparator.java (97%)
rename
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{
=> model}/policies/OffloadingPolicy.java (97%)
rename
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/MultiOccurrenceThresholdViolationPolicy.java
=> model/policies/ThresholdViolationOffloadingPolicy.java} (75%)
copy
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/SingleOccurrenceThresholdViolationPolicy.java
=> model/property/CPULoadResourceProperty.java} (74%)
copy
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/SingleOccurrenceThresholdViolationPolicy.java
=> model/property/FreeDiskSpaceResourceProperty.java} (74%)
rename
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/SingleOccurrenceThresholdViolationPolicy.java
=> model/property/FreeMemoryResourceProperty.java} (74%)
copy
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/Comparator.java
=> model/property/ResourceProperty.java} (82%)
copy
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/PipelineElement.java
=>
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/model/selection/CPULoadSelectionStrategy.java
(64%)
create mode 100644
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/model/selection/PrioritySelectionStrategy.java
rename
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{AutoOffloadingManager.java
=> model/selection/RandomSelectionStrategy.java} (68%)
rename
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/offloading/{policies/Comparator.java
=> model/selection/SelectionStrategy.java} (83%)
create mode 100644
streampipes-node-controller/src/main/java/org/apache/streampipes/node/controller/management/resource/utils/ResourceChecker.java
