You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by dl...@apache.org on 2016/04/26 21:35:30 UTC
[14/14] incubator-quarks git commit: Merge pull request #86
Merge pull request #86
This closes #86
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/967697d0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/967697d0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/967697d0
Branch: refs/heads/master
Commit: 967697d051e01943c6c3641285a5683a4f366240
Parents: b9c1348 6e3ec28
Author: Dale LaBossiere <dl...@us.ibm.com>
Authored: Tue Apr 26 15:35:03 2016 -0400
Committer: Dale LaBossiere <dl...@us.ibm.com>
Committed: Tue Apr 26 15:35:03 2016 -0400
----------------------------------------------------------------------
.../quarks/execution/mbeans/PeriodMXBean.java | 59 +++++++++++++++++
.../src/main/java/quarks/graph/Connector.java | 25 +++++++-
api/graph/src/main/java/quarks/graph/Edge.java | 7 +++
.../main/java/quarks/oplet/OpletContext.java | 6 ++
.../java/quarks/oplet/OutputPortContext.java | 30 +++++++++
.../java/quarks/oplet/core/PeriodicSource.java | 24 +++++--
.../oplet/core/mbeans/PeriodicMXBean.java | 47 --------------
.../src/main/java/quarks/topology/TStream.java | 43 +++++++++++--
.../src/main/java/quarks/topology/Topology.java | 22 +++++++
.../java/quarks/test/topology/TStreamTest.java | 66 ++++++++++++++++++++
.../java/quarks/test/topology/TopologyTest.java | 59 +++++++++++++++++
providers/direct/build.xml | 1 +
.../quarks/providers/direct/DirectProvider.java | 4 ++
.../java/quarks/runtime/etiao/Invocation.java | 27 +++++++-
.../quarks/runtime/etiao/InvocationContext.java | 12 +++-
.../runtime/etiao/graph/EtiaoConnector.java | 25 ++++++++
.../runtime/etiao/graph/ExecutableVertex.java | 13 ++++
.../runtime/etiao/graph/model/EdgeType.java | 8 +++
.../runtime/jmxcontrol/JMXControlService.java | 3 +-
.../main/java/quarks/graph/spi/DirectEdge.java | 5 ++
.../topology/spi/graph/ConnectorStream.java | 19 ++++++
.../quarks/test/metrics/MetricsCommonTest.java | 6 ++
22 files changed, 450 insertions(+), 61 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/967697d0/api/graph/src/main/java/quarks/graph/Connector.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/967697d0/api/topology/src/main/java/quarks/topology/TStream.java
----------------------------------------------------------------------