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/07/21 13:17:55 UTC
[54/54] [abbrv] incubator-quarks git commit: Merge pull request #168
Merge pull request #168
This closes #168
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/b8617922
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/b8617922
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/b8617922
Branch: refs/heads/master
Commit: b86179228c51bb81b85f5e0d0b588f211595d8d2
Parents: 41e2837 de33ba8
Author: Dale LaBossiere <dl...@us.ibm.com>
Authored: Thu Jul 21 09:16:22 2016 -0400
Committer: Dale LaBossiere <dl...@us.ibm.com>
Committed: Thu Jul 21 09:16:22 2016 -0400
----------------------------------------------------------------------
.gitignore | 2 +-
.project | 2 +-
.travis.yml | 6 +-
DEVELOPMENT.md | 93 +-
JAVA_SUPPORT.md | 86 +-
NOTICE | 4 +-
README.md | 55 +-
analytics/math3/build.xml | 8 +-
.../analytics/math3/json/JsonAnalytics.java | 443 +++++++
.../math3/json/JsonUnivariateAggregate.java | 54 +
.../math3/json/JsonUnivariateAggregator.java | 55 +
.../analytics/math3/json/package-info.java | 24 +
.../edgent/analytics/math3/stat/JsonOLS.java | 74 ++
.../math3/stat/JsonStorelessStatistic.java | 58 +
.../edgent/analytics/math3/stat/Regression.java | 54 +
.../edgent/analytics/math3/stat/Statistic.java | 85 ++
.../analytics/math3/stat/package-info.java | 24 +
.../analytics/math3/json/JsonAnalytics.java | 444 -------
.../math3/json/JsonUnivariateAggregate.java | 54 -
.../math3/json/JsonUnivariateAggregator.java | 55 -
.../analytics/math3/json/package-info.java | 24 -
.../quarks/analytics/math3/stat/JsonOLS.java | 75 --
.../math3/stat/JsonStorelessStatistic.java | 59 -
.../quarks/analytics/math3/stat/Regression.java | 54 -
.../quarks/analytics/math3/stat/Statistic.java | 86 --
.../analytics/math3/stat/package-info.java | 24 -
.../test/analytics/math3/StatisticsTest.java | 309 +++++
.../test/analytics/math3/StatisticsTest.java | 310 -----
analytics/sensors/build.xml | 8 +-
.../edgent/analytics/sensors/Deadband.java | 87 ++
.../edgent/analytics/sensors/Deadtime.java | 99 ++
.../edgent/analytics/sensors/Filters.java | 142 ++
.../apache/edgent/analytics/sensors/Range.java | 470 +++++++
.../apache/edgent/analytics/sensors/Ranges.java | 248 ++++
.../analytics/sensors/doc-files/deadband.png | Bin 0 -> 18450 bytes
.../edgent/analytics/sensors/package-info.java | 24 +
.../java/quarks/analytics/sensors/Deadband.java | 87 --
.../java/quarks/analytics/sensors/Deadtime.java | 99 --
.../java/quarks/analytics/sensors/Filters.java | 142 --
.../java/quarks/analytics/sensors/Range.java | 470 -------
.../java/quarks/analytics/sensors/Ranges.java | 248 ----
.../analytics/sensors/doc-files/deadband.png | Bin 18450 -> 0 bytes
.../quarks/analytics/sensors/package-info.java | 24 -
.../test/analytics/sensors/FiltersTest.java | 213 +++
.../test/analytics/sensors/RangeTest.java | 461 +++++++
.../test/analytics/sensors/FiltersTest.java | 214 ---
.../test/analytics/sensors/RangeTest.java | 462 -------
android/hardware/build.xml | 6 +-
.../edgent/android/hardware/SensorStreams.java | 71 +
.../hardware/runtime/SensorChangeEvents.java | 49 +
.../hardware/runtime/SensorSourceSetup.java | 54 +
.../quarks/android/hardware/SensorStreams.java | 71 -
.../hardware/runtime/SensorChangeEvents.java | 49 -
.../hardware/runtime/SensorSourceSetup.java | 54 -
android/topology/build.xml | 6 +-
.../edgent/android/oplet/RunOnUIThread.java | 41 +
.../android/topology/ActivityStreams.java | 83 ++
.../quarks/android/oplet/RunOnUIThread.java | 41 -
.../android/topology/ActivityStreams.java | 83 --
api/execution/build.xml | 6 +-
.../org/apache/edgent/execution/Configs.java | 51 +
.../edgent/execution/DirectSubmitter.java | 44 +
.../java/org/apache/edgent/execution/Job.java | 182 +++
.../org/apache/edgent/execution/Submitter.java | 56 +
.../edgent/execution/mbeans/JobMXBean.java | 114 ++
.../edgent/execution/mbeans/PeriodMXBean.java | 62 +
.../edgent/execution/mbeans/package-info.java | 23 +
.../apache/edgent/execution/package-info.java | 23 +
.../execution/services/ControlService.java | 123 ++
.../edgent/execution/services/Controls.java | 99 ++
.../execution/services/JobRegistryService.java | 126 ++
.../execution/services/RuntimeServices.java | 74 ++
.../execution/services/ServiceContainer.java | 125 ++
.../edgent/execution/services/package-info.java | 22 +
.../src/main/java/quarks/execution/Configs.java | 51 -
.../java/quarks/execution/DirectSubmitter.java | 44 -
.../src/main/java/quarks/execution/Job.java | 182 ---
.../main/java/quarks/execution/Submitter.java | 56 -
.../java/quarks/execution/mbeans/JobMXBean.java | 114 --
.../quarks/execution/mbeans/PeriodMXBean.java | 62 -
.../quarks/execution/mbeans/package-info.java | 23 -
.../java/quarks/execution/package-info.java | 23 -
.../execution/services/ControlService.java | 123 --
.../quarks/execution/services/Controls.java | 99 --
.../execution/services/JobRegistryService.java | 126 --
.../execution/services/RuntimeServices.java | 74 --
.../execution/services/ServiceContainer.java | 125 --
.../quarks/execution/services/package-info.java | 22 -
.../edgent/test/execution/ControlsTest.java | 55 +
.../quarks/test/execution/ControlsTest.java | 56 -
api/function/build.xml | 2 +-
.../org/apache/edgent/function/BiConsumer.java | 36 +
.../org/apache/edgent/function/BiFunction.java | 39 +
.../org/apache/edgent/function/Consumer.java | 35 +
.../org/apache/edgent/function/Function.java | 46 +
.../org/apache/edgent/function/Functions.java | 409 ++++++
.../org/apache/edgent/function/Predicate.java | 36 +
.../org/apache/edgent/function/Supplier.java | 44 +
.../edgent/function/ToDoubleFunction.java | 33 +
.../apache/edgent/function/ToIntFunction.java | 35 +
.../apache/edgent/function/UnaryOperator.java | 27 +
.../apache/edgent/function/WrappedFunction.java | 79 ++
.../apache/edgent/function/package-info.java | 24 +
.../main/java/quarks/function/BiConsumer.java | 36 -
.../main/java/quarks/function/BiFunction.java | 39 -
.../src/main/java/quarks/function/Consumer.java | 35 -
.../src/main/java/quarks/function/Function.java | 46 -
.../main/java/quarks/function/Functions.java | 409 ------
.../main/java/quarks/function/Predicate.java | 36 -
.../src/main/java/quarks/function/Supplier.java | 44 -
.../java/quarks/function/ToDoubleFunction.java | 33 -
.../java/quarks/function/ToIntFunction.java | 35 -
.../java/quarks/function/UnaryOperator.java | 27 -
.../java/quarks/function/WrappedFunction.java | 79 --
.../main/java/quarks/function/package-info.java | 24 -
.../edgent/test/function/FunctionsTest.java | 276 ++++
.../quarks/test/function/FunctionsTest.java | 277 ----
api/graph/build.xml | 4 +-
.../java/org/apache/edgent/graph/Connector.java | 143 +++
.../main/java/org/apache/edgent/graph/Edge.java | 65 +
.../java/org/apache/edgent/graph/Graph.java | 111 ++
.../java/org/apache/edgent/graph/Vertex.java | 63 +
.../org/apache/edgent/graph/package-info.java | 24 +
.../src/main/java/quarks/graph/Connector.java | 143 ---
api/graph/src/main/java/quarks/graph/Edge.java | 65 -
api/graph/src/main/java/quarks/graph/Graph.java | 111 --
.../src/main/java/quarks/graph/Vertex.java | 63 -
.../main/java/quarks/graph/package-info.java | 24 -
.../edgent/test/graph/GraphAbstractTest.java | 40 +
.../org/apache/edgent/test/graph/GraphTest.java | 119 ++
.../quarks/test/graph/GraphAbstractTest.java | 41 -
.../test/java/quarks/test/graph/GraphTest.java | 120 --
api/oplet/build.xml | 8 +-
.../org/apache/edgent/oplet/JobContext.java | 36 +
.../java/org/apache/edgent/oplet/Oplet.java | 61 +
.../org/apache/edgent/oplet/OpletContext.java | 103 ++
.../apache/edgent/oplet/OutputPortContext.java | 30 +
.../apache/edgent/oplet/core/AbstractOplet.java | 36 +
.../org/apache/edgent/oplet/core/FanIn.java | 117 ++
.../org/apache/edgent/oplet/core/FanOut.java | 56 +
.../java/org/apache/edgent/oplet/core/Peek.java | 42 +
.../edgent/oplet/core/PeriodicSource.java | 113 ++
.../java/org/apache/edgent/oplet/core/Pipe.java | 67 +
.../apache/edgent/oplet/core/ProcessSource.java | 46 +
.../java/org/apache/edgent/oplet/core/Sink.java | 87 ++
.../org/apache/edgent/oplet/core/Source.java | 54 +
.../org/apache/edgent/oplet/core/Split.java | 84 ++
.../org/apache/edgent/oplet/core/Union.java | 50 +
.../edgent/oplet/core/mbeans/package-info.java | 22 +
.../apache/edgent/oplet/core/package-info.java | 22 +
.../apache/edgent/oplet/functional/Events.java | 80 ++
.../apache/edgent/oplet/functional/Filter.java | 44 +
.../apache/edgent/oplet/functional/FlatMap.java | 66 +
.../org/apache/edgent/oplet/functional/Map.java | 54 +
.../apache/edgent/oplet/functional/Peek.java | 58 +
.../functional/SupplierPeriodicSource.java | 54 +
.../edgent/oplet/functional/SupplierSource.java | 58 +
.../edgent/oplet/functional/package-info.java | 22 +
.../org/apache/edgent/oplet/package-info.java | 28 +
.../apache/edgent/oplet/plumbing/Barrier.java | 113 ++
.../apache/edgent/oplet/plumbing/Isolate.java | 97 ++
.../edgent/oplet/plumbing/PressureReliever.java | 167 +++
.../edgent/oplet/plumbing/UnorderedIsolate.java | 55 +
.../edgent/oplet/plumbing/package-info.java | 22 +
.../apache/edgent/oplet/window/Aggregate.java | 81 ++
.../edgent/oplet/window/package-info.java | 22 +
.../src/main/java/quarks/oplet/JobContext.java | 36 -
api/oplet/src/main/java/quarks/oplet/Oplet.java | 61 -
.../main/java/quarks/oplet/OpletContext.java | 103 --
.../java/quarks/oplet/OutputPortContext.java | 30 -
.../java/quarks/oplet/core/AbstractOplet.java | 36 -
.../src/main/java/quarks/oplet/core/FanIn.java | 117 --
.../src/main/java/quarks/oplet/core/FanOut.java | 56 -
.../src/main/java/quarks/oplet/core/Peek.java | 42 -
.../java/quarks/oplet/core/PeriodicSource.java | 113 --
.../src/main/java/quarks/oplet/core/Pipe.java | 67 -
.../java/quarks/oplet/core/ProcessSource.java | 46 -
.../src/main/java/quarks/oplet/core/Sink.java | 87 --
.../src/main/java/quarks/oplet/core/Source.java | 54 -
.../src/main/java/quarks/oplet/core/Split.java | 84 --
.../src/main/java/quarks/oplet/core/Union.java | 50 -
.../quarks/oplet/core/mbeans/package-info.java | 22 -
.../java/quarks/oplet/core/package-info.java | 22 -
.../java/quarks/oplet/functional/Events.java | 80 --
.../java/quarks/oplet/functional/Filter.java | 44 -
.../java/quarks/oplet/functional/FlatMap.java | 66 -
.../main/java/quarks/oplet/functional/Map.java | 54 -
.../main/java/quarks/oplet/functional/Peek.java | 58 -
.../functional/SupplierPeriodicSource.java | 54 -
.../quarks/oplet/functional/SupplierSource.java | 58 -
.../quarks/oplet/functional/package-info.java | 22 -
.../main/java/quarks/oplet/package-info.java | 28 -
.../java/quarks/oplet/plumbing/Barrier.java | 113 --
.../java/quarks/oplet/plumbing/Isolate.java | 97 --
.../quarks/oplet/plumbing/PressureReliever.java | 167 ---
.../quarks/oplet/plumbing/UnorderedIsolate.java | 55 -
.../quarks/oplet/plumbing/package-info.java | 22 -
.../java/quarks/oplet/window/Aggregate.java | 81 --
.../java/quarks/oplet/window/package-info.java | 22 -
.../test/oplet/functional/FilterTest.java | 33 +
.../edgent/test/oplet/operators/PipeTest.java | 59 +
.../test/oplet/functional/FilterTest.java | 34 -
.../quarks/test/oplet/operators/PipeTest.java | 60 -
api/topology/build.xml | 22 +-
.../java/org/apache/edgent/topology/TSink.java | 41 +
.../org/apache/edgent/topology/TStream.java | 543 ++++++++
.../org/apache/edgent/topology/TWindow.java | 120 ++
.../org/apache/edgent/topology/Topology.java | 209 +++
.../apache/edgent/topology/TopologyElement.java | 32 +
.../edgent/topology/TopologyProvider.java | 41 +
.../edgent/topology/doc-files/sources.html | 193 +++
.../edgent/topology/json/JsonFunctions.java | 72 ++
.../edgent/topology/json/package-info.java | 23 +
.../mbeans/ApplicationServiceMXBean.java | 59 +
.../edgent/topology/mbeans/package-info.java | 80 ++
.../apache/edgent/topology/package-info.java | 31 +
.../topology/plumbing/LoadBalancedSplitter.java | 90 ++
...umbingStreams-withComcurrentMapSingleOp.JAVA | 494 +++++++
.../topology/plumbing/PlumbingStreams.java | 682 ++++++++++
.../apache/edgent/topology/plumbing/Valve.java | 105 ++
.../edgent/topology/plumbing/package-info.java | 26 +
.../topology/services/ApplicationService.java | 100 ++
.../topology/services/TopologyBuilder.java | 47 +
.../edgent/topology/services/package-info.java | 23 +
.../edgent/topology/tester/Condition.java | 31 +
.../apache/edgent/topology/tester/Tester.java | 180 +++
.../edgent/topology/tester/package-info.java | 24 +
.../src/main/java/quarks/topology/TSink.java | 41 -
.../src/main/java/quarks/topology/TStream.java | 543 --------
.../src/main/java/quarks/topology/TWindow.java | 120 --
.../src/main/java/quarks/topology/Topology.java | 209 ---
.../java/quarks/topology/TopologyElement.java | 32 -
.../java/quarks/topology/TopologyProvider.java | 41 -
.../java/quarks/topology/doc-files/sources.html | 193 ---
.../quarks/topology/json/JsonFunctions.java | 72 --
.../java/quarks/topology/json/package-info.java | 23 -
.../mbeans/ApplicationServiceMXBean.java | 59 -
.../quarks/topology/mbeans/package-info.java | 80 --
.../main/java/quarks/topology/package-info.java | 31 -
.../topology/plumbing/LoadBalancedSplitter.java | 90 --
.../topology/plumbing/PlumbingStreams.java | 682 ----------
.../java/quarks/topology/plumbing/Valve.java | 105 --
.../quarks/topology/plumbing/package-info.java | 26 -
.../topology/services/ApplicationService.java | 99 --
.../topology/services/TopologyBuilder.java | 47 -
.../quarks/topology/services/package-info.java | 23 -
.../java/quarks/topology/tester/Condition.java | 31 -
.../java/quarks/topology/tester/Tester.java | 180 ---
.../quarks/topology/tester/package-info.java | 24 -
.../edgent/test/topology/JsonFunctionsTest.java | 78 ++
.../edgent/test/topology/PlumbingTest.java | 746 +++++++++++
.../edgent/test/topology/TStreamTest.java | 875 +++++++++++++
.../edgent/test/topology/TWindowTest.java | 174 +++
.../test/topology/TopologyAbstractTest.java | 107 ++
.../test/topology/TopologyElementTest.java | 37 +
.../edgent/test/topology/TopologyTest.java | 160 +++
.../edgent/test/topology/TopologyTestSetup.java | 33 +
.../topology/services/TestApplications.java | 61 +
.../quarks/test/topology/JsonFunctionsTest.java | 79 --
.../java/quarks/test/topology/PlumbingTest.java | 747 -----------
.../java/quarks/test/topology/TStreamTest.java | 876 -------------
.../java/quarks/test/topology/TWindowTest.java | 175 ---
.../test/topology/TopologyAbstractTest.java | 108 --
.../test/topology/TopologyElementTest.java | 38 -
.../java/quarks/test/topology/TopologyTest.java | 161 ---
.../quarks/test/topology/TopologyTestSetup.java | 33 -
.../topology/services/TestApplications.java | 61 -
api/window/build.xml | 4 +-
.../apache/edgent/window/InsertionTimeList.java | 134 ++
.../org/apache/edgent/window/Partition.java | 79 ++
.../org/apache/edgent/window/PartitionImpl.java | 79 ++
.../apache/edgent/window/PartitionedState.java | 80 ++
.../java/org/apache/edgent/window/Policies.java | 240 ++++
.../java/org/apache/edgent/window/Window.java | 177 +++
.../org/apache/edgent/window/WindowImpl.java | 127 ++
.../java/org/apache/edgent/window/Windows.java | 103 ++
.../org/apache/edgent/window/package-info.java | 24 +
.../java/quarks/window/InsertionTimeList.java | 134 --
.../src/main/java/quarks/window/Partition.java | 79 --
.../main/java/quarks/window/PartitionImpl.java | 79 --
.../java/quarks/window/PartitionedState.java | 80 --
.../src/main/java/quarks/window/Policies.java | 240 ----
.../src/main/java/quarks/window/Window.java | 177 ---
.../src/main/java/quarks/window/WindowImpl.java | 127 --
.../src/main/java/quarks/window/Windows.java | 103 --
.../main/java/quarks/window/package-info.java | 24 -
.../apache/edgent/test/window/StateTest.java | 101 ++
.../apache/edgent/test/window/WindowTest.java | 491 +++++++
.../test/java/quarks/test/window/StateTest.java | 102 --
.../java/quarks/test/window/WindowTest.java | 491 -------
apps/iot/build.xml | 10 +-
.../apache/edgent/apps/iot/IotDevicePubSub.java | 128 ++
.../apache/edgent/apps/iot/PubSubIotDevice.java | 124 ++
.../apache/edgent/apps/iot/package-info.java | 23 +
.../java/quarks/apps/iot/IotDevicePubSub.java | 128 --
.../java/quarks/apps/iot/PubSubIotDevice.java | 124 --
.../main/java/quarks/apps/iot/package-info.java | 23 -
.../edgent/test/apps/iot/EchoIotDevice.java | 118 ++
.../test/apps/iot/IotDevicePubSubTest.java | 87 ++
.../quarks/test/apps/iot/EchoIotDevice.java | 118 --
.../test/apps/iot/IotDevicePubSubTest.java | 88 --
apps/runtime/build.xml | 14 +-
.../edgent/apps/runtime/JobMonitorApp.java | 270 ++++
.../edgent/apps/runtime/JobMonitorAppEvent.java | 113 ++
.../edgent/apps/runtime/package-info.java | 24 +
.../java/quarks/apps/runtime/JobMonitorApp.java | 271 ----
.../quarks/apps/runtime/JobMonitorAppEvent.java | 113 --
.../java/quarks/apps/runtime/package-info.java | 24 -
.../test/apps/runtime/JobMonitorAppTest.java | 137 ++
.../test/apps/runtime/JobMonitorAppTest.java | 138 --
build.gradle | 32 +-
build.xml | 76 +-
common-build.xml | 62 +-
connectors/.classpath | 3 +-
connectors/command/build.xml | 10 +-
.../connectors/command/CommandStreams.java | 349 +++++
.../edgent/connectors/command/package-info.java | 24 +
.../command/runtime/CommandConnector.java | 103 ++
.../command/runtime/CommandReader.java | 111 ++
.../command/runtime/CommandWriter.java | 91 ++
.../command/runtime/ProcessReader.java | 98 ++
.../command/runtime/ProcessWriter.java | 66 +
.../connectors/command/CommandStreams.java | 349 -----
.../quarks/connectors/command/package-info.java | 24 -
.../command/runtime/CommandConnector.java | 103 --
.../command/runtime/CommandReader.java | 111 --
.../command/runtime/CommandWriter.java | 91 --
.../command/runtime/ProcessReader.java | 98 --
.../command/runtime/ProcessWriter.java | 66 -
.../command/CommandStreamsGlobalTest.java | 35 +
.../connectors/command/CommandStreamsTest.java | 223 ++++
.../command/CommandStreamsGlobalTest.java | 35 -
.../connectors/command/CommandStreamsTest.java | 224 ----
connectors/common/build.xml | 8 +-
.../edgent/connectors/runtime/Connector.java | 448 +++++++
.../edgent/connectors/runtime/IdleManager.java | 201 +++
.../quarks/connectors/runtime/Connector.java | 448 -------
.../quarks/connectors/runtime/IdleManager.java | 202 ---
.../connectors/common/ConnectorTestBase.java | 107 ++
.../edgent/test/connectors/common/FileUtil.java | 88 ++
.../test/connectors/common/TestRepoPath.java | 61 +
.../connectors/common/ConnectorTestBase.java | 107 --
.../quarks/test/connectors/common/FileUtil.java | 88 --
.../test/connectors/common/TestRepoPath.java | 61 -
connectors/csv/build.xml | 6 +-
.../org/apache/edgent/connectors/csv/Csv.java | 176 +++
.../edgent/connectors/csv/package-info.java | 22 +
.../main/java/quarks/connectors/csv/Csv.java | 176 ---
.../quarks/connectors/csv/package-info.java | 22 -
.../edgent/test/connectors/csv/CsvTest.java | 128 ++
.../quarks/test/connectors/csv/CsvTest.java | 129 --
connectors/edgent.javax.websocket/build.gradle | 19 +
connectors/edgent.javax.websocket/build.xml | 45 +
connectors/edgent.javax.websocket/ext/README | 1 +
.../ext/javax.websocket-api-1.0.jar | Bin 0 -> 36611 bytes
.../ext/license-eplv10-aslv20.html | 576 +++++++++
.../edgent.javax.websocket/ext/notice.html | 111 ++
.../websocket/EdgentSslContainerProvider.java | 75 ++
.../edgent/javax/websocket/package-info.java | 22 +
connectors/file/build.xml | 8 +-
.../file/CompressedFileWriterPolicy.java | 118 ++
.../edgent/connectors/file/FileStreams.java | 256 ++++
.../connectors/file/FileWriterCycleConfig.java | 164 +++
.../connectors/file/FileWriterFlushConfig.java | 151 +++
.../connectors/file/FileWriterPolicy.java | 385 ++++++
.../file/FileWriterRetentionConfig.java | 144 +++
.../edgent/connectors/file/package-info.java | 25 +
.../file/runtime/AbstractWriterFile.java | 55 +
.../file/runtime/DirectoryWatcher.java | 232 ++++
.../connectors/file/runtime/FileConnector.java | 36 +
.../file/runtime/IFileWriterPolicy.java | 168 +++
.../file/runtime/StringWriterFile.java | 72 ++
.../connectors/file/runtime/TextFileReader.java | 124 ++
.../connectors/file/runtime/TextFileWriter.java | 134 ++
.../file/CompressedFileWriterPolicy.java | 118 --
.../quarks/connectors/file/FileStreams.java | 256 ----
.../connectors/file/FileWriterCycleConfig.java | 164 ---
.../connectors/file/FileWriterFlushConfig.java | 151 ---
.../connectors/file/FileWriterPolicy.java | 386 ------
.../file/FileWriterRetentionConfig.java | 144 ---
.../quarks/connectors/file/package-info.java | 25 -
.../file/runtime/AbstractWriterFile.java | 55 -
.../file/runtime/DirectoryWatcher.java | 233 ----
.../connectors/file/runtime/FileConnector.java | 36 -
.../file/runtime/IFileWriterPolicy.java | 168 ---
.../file/runtime/StringWriterFile.java | 72 --
.../connectors/file/runtime/TextFileReader.java | 125 --
.../connectors/file/runtime/TextFileWriter.java | 135 --
.../connectors/file/FileStreamsGlobalTest.java | 35 +
.../test/connectors/file/FileStreamsTest.java | 310 +++++
.../FileStreamsTextFileWriterGlobalTest.java | 42 +
.../file/FileStreamsTextFileWriterTest.java | 944 ++++++++++++++
.../connectors/file/FileStreamsGlobalTest.java | 35 -
.../test/connectors/file/FileStreamsTest.java | 311 -----
.../FileStreamsTextFileWriterGlobalTest.java | 42 -
.../file/FileStreamsTextFileWriterTest.java | 944 --------------
connectors/http/build.xml | 8 +-
.../edgent/connectors/http/HttpClients.java | 89 ++
.../edgent/connectors/http/HttpResponders.java | 116 ++
.../edgent/connectors/http/HttpStreams.java | 309 +++++
.../edgent/connectors/http/package-info.java | 24 +
.../connectors/http/runtime/HttpRequester.java | 130 ++
.../quarks/connectors/http/HttpClients.java | 90 --
.../quarks/connectors/http/HttpResponders.java | 117 --
.../quarks/connectors/http/HttpStreams.java | 310 -----
.../quarks/connectors/http/package-info.java | 24 -
.../connectors/http/runtime/HttpRequester.java | 131 --
.../test/connectors/http/HttpGlobalTest.java | 39 +
.../edgent/test/connectors/http/HttpTest.java | 379 ++++++
.../test/connectors/http/HttpGlobalTest.java | 39 -
.../quarks/test/connectors/http/HttpTest.java | 380 ------
connectors/iot/build.xml | 8 +-
.../apache/edgent/connectors/iot/Commands.java | 42 +
.../apache/edgent/connectors/iot/Events.java | 33 +
.../apache/edgent/connectors/iot/HeartBeat.java | 99 ++
.../apache/edgent/connectors/iot/IotDevice.java | 132 ++
.../org/apache/edgent/connectors/iot/QoS.java | 63 +
.../edgent/connectors/iot/package-info.java | 60 +
.../java/quarks/connectors/iot/Commands.java | 42 -
.../main/java/quarks/connectors/iot/Events.java | 33 -
.../java/quarks/connectors/iot/HeartBeat.java | 99 --
.../java/quarks/connectors/iot/IotDevice.java | 132 --
.../main/java/quarks/connectors/iot/QoS.java | 63 -
.../quarks/connectors/iot/package-info.java | 60 -
.../edgent/test/connectors/iot/QoSTest.java | 35 +
.../quarks/test/connectors/iot/QoSTest.java | 36 -
connectors/iotf/build.xml | 10 +-
.../edgent/connectors/iotf/IotfDevice.java | 284 ++++
.../edgent/connectors/iotf/package-info.java | 26 +
.../connectors/iotf/runtime/IotfConnector.java | 106 ++
.../iotf/runtime/IotfDeviceCommands.java | 50 +
.../iotf/runtime/IotfDeviceEventsFixed.java | 46 +
.../iotf/runtime/IotfDeviceEventsFunction.java | 54 +
.../java/quarks/connectors/iotf/IotfDevice.java | 284 ----
.../quarks/connectors/iotf/package-info.java | 26 -
.../connectors/iotf/runtime/IotfConnector.java | 108 --
.../iotf/runtime/IotfDeviceCommands.java | 51 -
.../iotf/runtime/IotfDeviceEventsFixed.java | 46 -
.../iotf/runtime/IotfDeviceEventsFunction.java | 54 -
connectors/javax.websocket-client/README | 2 +-
connectors/javax.websocket-client/build.gradle | 2 +-
connectors/javax.websocket-client/build.xml | 4 +-
.../impl/EdgentSslContainerProviderImpl.java | 79 ++
.../javax/websocket/impl/package-info.java | 22 +
.../impl/QuarksSslContainerProviderImpl.java | 80 --
.../javax/websocket/impl/package-info.java | 22 -
...t.javax.websocket.EdgentSslContainerProvider | 1 +
...s.javax.websocket.QuarksSslContainerProvider | 1 -
connectors/javax.websocket-server/build.xml | 4 +-
connectors/jdbc/build.xml | 6 +-
.../edgent/connectors/jdbc/CheckedFunction.java | 36 +
.../edgent/connectors/jdbc/CheckedSupplier.java | 34 +
.../edgent/connectors/jdbc/JdbcStreams.java | 294 +++++
.../edgent/connectors/jdbc/ParameterSetter.java | 46 +
.../edgent/connectors/jdbc/ResultsHandler.java | 66 +
.../connectors/jdbc/StatementSupplier.java | 44 +
.../edgent/connectors/jdbc/package-info.java | 25 +
.../connectors/jdbc/runtime/JdbcConnector.java | 101 ++
.../connectors/jdbc/runtime/JdbcStatement.java | 141 ++
.../quarks/connectors/jdbc/CheckedFunction.java | 36 -
.../quarks/connectors/jdbc/CheckedSupplier.java | 34 -
.../quarks/connectors/jdbc/JdbcStreams.java | 294 -----
.../quarks/connectors/jdbc/ParameterSetter.java | 46 -
.../quarks/connectors/jdbc/ResultsHandler.java | 66 -
.../connectors/jdbc/StatementSupplier.java | 44 -
.../quarks/connectors/jdbc/package-info.java | 25 -
.../connectors/jdbc/runtime/JdbcConnector.java | 102 --
.../connectors/jdbc/runtime/JdbcStatement.java | 142 --
.../connectors/jdbc/JdbcStreamsGlobalTest.java | 61 +
.../test/connectors/jdbc/JdbcStreamsTest.java | 634 +++++++++
.../connectors/jdbc/JdbcStreamsGlobalTest.java | 61 -
.../test/connectors/jdbc/JdbcStreamsTest.java | 635 ---------
connectors/kafka/build.xml | 8 +-
.../edgent/connectors/kafka/KafkaConsumer.java | 199 +++
.../edgent/connectors/kafka/KafkaProducer.java | 168 +++
.../edgent/connectors/kafka/package-info.java | 30 +
.../kafka/runtime/KafkaConnector.java | 34 +
.../kafka/runtime/KafkaConsumerConnector.java | 263 ++++
.../kafka/runtime/KafkaProducerConnector.java | 61 +
.../kafka/runtime/KafkaPublisher.java | 85 ++
.../kafka/runtime/KafkaSubscriber.java | 187 +++
.../quarks/connectors/kafka/KafkaConsumer.java | 198 ---
.../quarks/connectors/kafka/KafkaProducer.java | 167 ---
.../quarks/connectors/kafka/package-info.java | 30 -
.../kafka/runtime/KafkaConnector.java | 34 -
.../kafka/runtime/KafkaConsumerConnector.java | 262 ----
.../kafka/runtime/KafkaProducerConnector.java | 62 -
.../kafka/runtime/KafkaPublisher.java | 86 --
.../kafka/runtime/KafkaSubscriber.java | 187 ---
.../kafka/KafkaStreamsGlobalTestManual.java | 36 +
.../kafka/KafkaStreamsTestManual.java | 365 ++++++
.../kafka/KafkaStreamsGlobalTestManual.java | 36 -
.../kafka/KafkaStreamsTestManual.java | 366 ------
connectors/mqtt/build.xml | 12 +-
.../edgent/connectors/mqtt/MqttConfig.java | 587 +++++++++
.../edgent/connectors/mqtt/MqttStreams.java | 221 ++++
.../edgent/connectors/mqtt/iot/MqttDevice.java | 279 ++++
.../connectors/mqtt/iot/package-info.java | 22 +
.../edgent/connectors/mqtt/package-info.java | 29 +
.../connectors/mqtt/runtime/MqttConnector.java | 180 +++
.../connectors/mqtt/runtime/MqttPublisher.java | 81 ++
.../connectors/mqtt/runtime/MqttSubscriber.java | 92 ++
.../java/quarks/connectors/mqtt/MqttConfig.java | 588 ---------
.../quarks/connectors/mqtt/MqttStreams.java | 221 ----
.../quarks/connectors/mqtt/iot/MqttDevice.java | 279 ----
.../connectors/mqtt/iot/package-info.java | 22 -
.../quarks/connectors/mqtt/package-info.java | 29 -
.../connectors/mqtt/runtime/MqttConnector.java | 181 ---
.../connectors/mqtt/runtime/MqttPublisher.java | 82 --
.../connectors/mqtt/runtime/MqttSubscriber.java | 93 --
.../test/connectors/mqtt/MqttOpenTest.java | 92 ++
.../mqtt/MqttStreamsGlobalTestManual.java | 44 +
.../connectors/mqtt/MqttStreamsTestManual.java | 1214 +++++++++++++++++
.../test/connectors/mqtt/MqttOpenTest.java | 92 --
.../mqtt/MqttStreamsGlobalTestManual.java | 44 -
.../connectors/mqtt/MqttStreamsTestManual.java | 1215 ------------------
connectors/mqtt/src/test/keystores/README | 2 +-
.../mqtt/src/test/keystores/create-all.sh | 6 +-
connectors/pubsub/build.xml | 8 +-
.../connectors/pubsub/PublishSubscribe.java | 144 +++
.../connectors/pubsub/oplets/Publish.java | 51 +
.../connectors/pubsub/oplets/package-info.java | 24 +
.../edgent/connectors/pubsub/package-info.java | 24 +
.../pubsub/service/ProviderPubSub.java | 67 +
.../pubsub/service/PublishSubscribeService.java | 68 +
.../connectors/pubsub/service/TopicHandler.java | 54 +
.../connectors/pubsub/service/package-info.java | 24 +
.../connectors/pubsub/PublishSubscribe.java | 144 ---
.../connectors/pubsub/oplets/Publish.java | 51 -
.../connectors/pubsub/oplets/package-info.java | 24 -
.../quarks/connectors/pubsub/package-info.java | 24 -
.../pubsub/service/ProviderPubSub.java | 67 -
.../pubsub/service/PublishSubscribeService.java | 68 -
.../connectors/pubsub/service/TopicHandler.java | 54 -
.../connectors/pubsub/service/package-info.java | 24 -
.../connectors/pubsub/PubSubGlobalTest.java | 32 +
.../test/connectors/pubsub/PubSubTest.java | 214 +++
.../connectors/pubsub/PubSubGlobalTest.java | 32 -
.../test/connectors/pubsub/PubSubTest.java | 215 ----
connectors/quarks.javax.websocket/build.gradle | 19 -
connectors/quarks.javax.websocket/build.xml | 45 -
connectors/quarks.javax.websocket/ext/README | 1 -
.../ext/javax.websocket-api-1.0.jar | Bin 36611 -> 0 bytes
.../ext/license-eplv10-aslv20.html | 576 ---------
.../quarks.javax.websocket/ext/notice.html | 111 --
.../websocket/QuarksSslContainerProvider.java | 75 --
.../quarks/javax/websocket/package-info.java | 22 -
connectors/serial/build.xml | 8 +-
.../edgent/connectors/serial/SerialDevice.java | 83 ++
.../edgent/connectors/serial/SerialPort.java | 44 +
.../edgent/connectors/serial/package-info.java | 24 +
.../quarks/connectors/serial/SerialDevice.java | 83 --
.../quarks/connectors/serial/SerialPort.java | 44 -
.../quarks/connectors/serial/package-info.java | 24 -
.../wsclient-javax.websocket/build.gradle | 2 +-
connectors/wsclient-javax.websocket/build.xml | 18 +-
.../javax/websocket/Jsr356WebSocketClient.java | 249 ++++
.../wsclient/javax/websocket/package-info.java | 22 +
.../runtime/WebSocketClientBinaryReceiver.java | 40 +
.../runtime/WebSocketClientBinarySender.java | 37 +
.../runtime/WebSocketClientConnector.java | 262 ++++
.../runtime/WebSocketClientReceiver.java | 59 +
.../runtime/WebSocketClientSender.java | 44 +
.../javax/websocket/Jsr356WebSocketClient.java | 249 ----
.../wsclient/javax/websocket/package-info.java | 22 -
.../runtime/WebSocketClientBinaryReceiver.java | 40 -
.../runtime/WebSocketClientBinarySender.java | 37 -
.../runtime/WebSocketClientConnector.java | 263 ----
.../runtime/WebSocketClientReceiver.java | 59 -
.../runtime/WebSocketClientSender.java | 44 -
.../websocket/WebSocketClientGlobalTest.java | 46 +
.../javax/websocket/WebSocketClientTest.java | 856 ++++++++++++
.../javax/websocket/WebSocketServerEcho.java | 241 ++++
.../websocket/WebSocketClientGlobalTest.java | 46 -
.../javax/websocket/WebSocketClientTest.java | 857 ------------
.../javax/websocket/WebSocketServerEcho.java | 242 ----
connectors/wsclient/build.xml | 8 +-
.../connectors/wsclient/WebSocketClient.java | 132 ++
.../connectors/wsclient/package-info.java | 22 +
.../connectors/wsclient/WebSocketClient.java | 132 --
.../connectors/wsclient/package-info.java | 22 -
console/server/build.xml | 4 +-
.../edgent/console/server/HttpServer.java | 175 +++
.../edgent/console/server/ServerUtil.java | 126 ++
.../java/quarks/console/server/HttpServer.java | 175 ---
.../java/quarks/console/server/ServerUtil.java | 126 --
.../test/console/server/HttpServerTest.java | 173 +++
.../test/console/server/ServerUtilTest.java | 43 +
.../test/console/server/HttpServerTest.java | 175 ---
.../test/console/server/ServerUtilTest.java | 44 -
console/servlets/build.xml | 14 +-
.../console/servlets/ConsoleJobServlet.java | 102 ++
.../console/servlets/ConsoleMetricsServlet.java | 109 ++
.../edgent/console/servlets/ConsoleServlet.java | 39 +
.../apache/edgent/console/servlets/JobUtil.java | 136 ++
.../edgent/console/servlets/MetricsGson.java | 104 ++
.../edgent/console/servlets/MetricsUtil.java | 378 ++++++
.../console/servlets/StreamScopeUtil.java | 81 ++
.../console/servlets/ConsoleJobServlet.java | 102 --
.../console/servlets/ConsoleMetricsServlet.java | 109 --
.../quarks/console/servlets/ConsoleServlet.java | 39 -
.../java/quarks/console/servlets/JobUtil.java | 136 --
.../quarks/console/servlets/MetricsGson.java | 104 --
.../quarks/console/servlets/MetricsUtil.java | 379 ------
.../console/servlets/StreamScopeUtil.java | 81 --
.../servlets/webapp_content/WEB-INF/console.xml | 6 +-
console/servlets/webapp_content/html/index.html | 6 +-
.../webapp_content/js/ext/sankey_edgent.js | 293 +++++
.../webapp_content/js/ext/sankey_quarks.js | 293 -----
console/servlets/webapp_content/js/graph.js | 36 +-
.../resources/images/small_edgent.png | Bin 0 -> 8142 bytes
.../resources/images/small_quarks.png | Bin 14274 -> 0 bytes
edgent_overview.html | 233 ++++
gradle.properties | 2 +-
platform/android/build.xml | 22 +-
platform/java7/build.xml | 168 +--
providers/development/build.xml | 12 +-
.../development/DevelopmentProvider.java | 105 ++
.../providers/development/package-info.java | 24 +
.../development/DevelopmentProvider.java | 105 --
.../providers/development/package-info.java | 24 -
.../providers/dev/DevelopmentProviderTest.java | 108 ++
.../providers/dev/DevelopmentTestSetup.java | 42 +
.../streamscope/DevelopmentStreamScopeTest.java | 131 ++
.../dev/topology/DevelopmentPlumbingTest.java | 25 +
.../dev/topology/DevelopmentTStreamTest.java | 25 +
.../dev/topology/DevelopmentTopologyTest.java | 25 +
.../dev/topology/DevelopmentWindowTest.java | 25 +
.../providers/dev/DevelopmentProviderTest.java | 109 --
.../providers/dev/DevelopmentTestSetup.java | 42 -
.../streamscope/DevelopmentStreamScopeTest.java | 132 --
.../dev/topology/DevelopmentPlumbingTest.java | 25 -
.../dev/topology/DevelopmentTStreamTest.java | 25 -
.../dev/topology/DevelopmentTopologyTest.java | 25 -
.../dev/topology/DevelopmentWindowTest.java | 25 -
providers/direct/build.gradle | 1 +
providers/direct/build.xml | 16 +-
.../edgent/providers/direct/DirectProvider.java | 89 ++
.../edgent/providers/direct/DirectTester.java | 130 ++
.../edgent/providers/direct/DirectTopology.java | 112 ++
.../edgent/providers/direct/package-info.java | 24 +
.../quarks/providers/direct/DirectProvider.java | 89 --
.../quarks/providers/direct/DirectTester.java | 130 --
.../quarks/providers/direct/DirectTopology.java | 112 --
.../quarks/providers/direct/package-info.java | 24 -
.../test/providers/direct/DirectJobTest.java | 342 +++++
.../test/providers/direct/DirectTestSetup.java | 38 +
.../direct/appservice/AppServiceTest.java | 72 ++
.../DirectMetricObjectNameFactoryTest.java | 25 +
.../metrics/DirectMetricsEverywhereTest.java | 25 +
.../direct/metrics/DirectMetricsOffTest.java | 25 +
.../direct/metrics/DirectMetricsOnTest.java | 25 +
.../providers/direct/metrics/package-info.java | 19 +
.../direct/topology/DirectPlumbingTest.java | 25 +
.../direct/topology/DirectTStreamTest.java | 25 +
.../direct/topology/DirectTopologyTest.java | 25 +
.../direct/topology/DirectWindowTest.java | 25 +
.../test/providers/direct/DirectJobTest.java | 343 -----
.../test/providers/direct/DirectTestSetup.java | 38 -
.../direct/appservice/AppServiceTest.java | 73 --
.../DirectMetricObjectNameFactoryTest.java | 25 -
.../metrics/DirectMetricsEverywhereTest.java | 25 -
.../direct/metrics/DirectMetricsOffTest.java | 25 -
.../direct/metrics/DirectMetricsOnTest.java | 25 -
.../providers/direct/metrics/package-info.java | 19 -
.../direct/topology/DirectPlumbingTest.java | 25 -
.../direct/topology/DirectTStreamTest.java | 25 -
.../direct/topology/DirectTopologyTest.java | 25 -
.../direct/topology/DirectWindowTest.java | 25 -
providers/iot/build.xml | 16 +-
.../edgent/providers/iot/IotProvider.java | 377 ++++++
.../edgent/providers/iot/package-info.java | 82 ++
.../java/quarks/providers/iot/IotProvider.java | 378 ------
.../java/quarks/providers/iot/package-info.java | 82 --
quarks_overview.html | 233 ----
runtime/appservice/build.xml | 8 +-
.../edgent/runtime/appservice/AppService.java | 214 +++
.../runtime/appservice/AppServiceControl.java | 80 ++
.../quarks/runtime/appservice/AppService.java | 215 ----
.../runtime/appservice/AppServiceControl.java | 81 --
runtime/etiao/build.xml | 10 +-
.../edgent/runtime/etiao/AbstractContext.java | 70 +
.../apache/edgent/runtime/etiao/EtiaoJob.java | 229 ++++
.../apache/edgent/runtime/etiao/Executable.java | 362 ++++++
.../apache/edgent/runtime/etiao/Invocation.java | 205 +++
.../edgent/runtime/etiao/InvocationContext.java | 88 ++
.../edgent/runtime/etiao/SettableForwarder.java | 74 ++
.../runtime/etiao/ThreadFactoryTracker.java | 200 +++
.../etiao/TrackingScheduledExecutor.java | 273 ++++
.../edgent/runtime/etiao/graph/DirectGraph.java | 86 ++
.../runtime/etiao/graph/EtiaoConnector.java | 264 ++++
.../runtime/etiao/graph/ExecutableVertex.java | 146 +++
.../edgent/runtime/etiao/graph/Target.java | 39 +
.../runtime/etiao/graph/model/EdgeType.java | 84 ++
.../runtime/etiao/graph/model/GraphType.java | 149 +++
.../runtime/etiao/graph/model/IdMapper.java | 65 +
.../etiao/graph/model/InvocationType.java | 47 +
.../runtime/etiao/graph/model/VertexType.java | 67 +
.../runtime/etiao/mbeans/EtiaoJobBean.java | 207 +++
.../edgent/runtime/etiao/package-info.java | 33 +
.../quarks/runtime/etiao/AbstractContext.java | 70 -
.../java/quarks/runtime/etiao/EtiaoJob.java | 229 ----
.../java/quarks/runtime/etiao/Executable.java | 363 ------
.../java/quarks/runtime/etiao/Invocation.java | 206 ---
.../quarks/runtime/etiao/InvocationContext.java | 88 --
.../quarks/runtime/etiao/SettableForwarder.java | 74 --
.../runtime/etiao/ThreadFactoryTracker.java | 201 ---
.../etiao/TrackingScheduledExecutor.java | 274 ----
.../quarks/runtime/etiao/graph/DirectGraph.java | 86 --
.../runtime/etiao/graph/EtiaoConnector.java | 264 ----
.../runtime/etiao/graph/ExecutableVertex.java | 146 ---
.../java/quarks/runtime/etiao/graph/Target.java | 39 -
.../runtime/etiao/graph/model/EdgeType.java | 84 --
.../runtime/etiao/graph/model/GraphType.java | 149 ---
.../runtime/etiao/graph/model/IdMapper.java | 65 -
.../etiao/graph/model/InvocationType.java | 47 -
.../runtime/etiao/graph/model/VertexType.java | 67 -
.../runtime/etiao/mbeans/EtiaoJobBean.java | 208 ---
.../java/quarks/runtime/etiao/package-info.java | 33 -
.../test/runtime/etiao/EtiaoGraphTest.java | 188 +++
.../test/runtime/etiao/EtiaoGraphTest.java | 189 ---
runtime/jmxcontrol/build.xml | 8 +-
.../runtime/jmxcontrol/JMXControlService.java | 182 +++
.../runtime/jmxcontrol/JMXControlService.java | 182 ---
.../jmxcontrol/JMXControlServiceTest.java | 135 ++
.../jmxcontrol/JMXControlServiceTest.java | 136 --
runtime/jobregistry/build.xml | 6 +-
.../edgent/runtime/jobregistry/JobEvents.java | 139 ++
.../edgent/runtime/jobregistry/JobRegistry.java | 151 +++
.../runtime/jobregistry/package-info.java | 25 +
.../quarks/runtime/jobregistry/JobEvents.java | 139 --
.../quarks/runtime/jobregistry/JobRegistry.java | 152 ---
.../runtime/jobregistry/package-info.java | 25 -
.../runtime/jobregistry/JobRegistryTest.java | 178 +++
.../runtime/jobregistry/JobRegistryTest.java | 179 ---
runtime/jsoncontrol/build.xml | 8 +-
.../runtime/jsoncontrol/ControlMBean.java | 44 +
.../runtime/jsoncontrol/JsonControlService.java | 266 ++++
.../runtime/jsoncontrol/package-info.java | 39 +
.../runtime/jsoncontrol/ControlMBean.java | 44 -
.../runtime/jsoncontrol/JsonControlService.java | 267 ----
.../runtime/jsoncontrol/package-info.java | 39 -
.../jsoncontrol/JsonControlServiceTest.java | 362 ++++++
.../jsoncontrol/JsonControlServiceTest.java | 363 ------
samples/.classpath | 2 +-
samples/apps/build.xml | 22 +-
.../samples/apps/AbstractApplication.java | 130 ++
.../samples/apps/ApplicationUtilities.java | 255 ++++
.../apache/edgent/samples/apps/JsonTuples.java | 196 +++
.../samples/apps/TopologyProviderFactory.java | 63 +
.../samples/apps/applicationTemplate.properties | 81 ++
.../apps/mqtt/AbstractMqttApplication.java | 121 ++
.../samples/apps/mqtt/DeviceCommsApp.java | 114 ++
.../edgent/samples/apps/mqtt/package-info.java | 25 +
.../edgent/samples/apps/package-info.java | 42 +
.../samples/apps/sensorAnalytics/Sensor1.java | 286 +++++
.../SensorAnalyticsApplication.java | 57 +
.../apps/sensorAnalytics/package-info.java | 164 +++
.../samples/apps/AbstractApplication.java | 131 --
.../samples/apps/ApplicationUtilities.java | 255 ----
.../java/quarks/samples/apps/JsonTuples.java | 197 ---
.../samples/apps/TopologyProviderFactory.java | 63 -
.../samples/apps/applicationTemplate.properties | 81 --
.../apps/mqtt/AbstractMqttApplication.java | 121 --
.../samples/apps/mqtt/DeviceCommsApp.java | 114 --
.../quarks/samples/apps/mqtt/package-info.java | 25 -
.../java/quarks/samples/apps/package-info.java | 42 -
.../samples/apps/sensorAnalytics/Sensor1.java | 287 -----
.../SensorAnalyticsApplication.java | 57 -
.../apps/sensorAnalytics/package-info.java | 164 ---
samples/connectors/build.xml | 22 +-
.../edgent/samples/connectors/MsgSupplier.java | 50 +
.../edgent/samples/connectors/Options.java | 98 ++
.../apache/edgent/samples/connectors/Util.java | 75 ++
.../edgent/samples/connectors/elm327/Cmd.java | 76 ++
.../samples/connectors/elm327/Elm327Cmds.java | 75 ++
.../connectors/elm327/Elm327Streams.java | 70 +
.../samples/connectors/elm327/Pids01.java | 141 ++
.../samples/connectors/elm327/package-info.java | 27 +
.../elm327/runtime/CommandExecutor.java | 118 ++
.../samples/connectors/file/FileReaderApp.java | 88 ++
.../samples/connectors/file/FileWriterApp.java | 94 ++
.../edgent/samples/connectors/file/README | 11 +
.../samples/connectors/file/package-info.java | 32 +
.../samples/connectors/iotf/IotfQuickstart.java | 86 ++
.../samples/connectors/iotf/IotfSensors.java | 163 +++
.../samples/connectors/iotf/package-info.java | 24 +
.../edgent/samples/connectors/jdbc/DbUtils.java | 140 ++
.../edgent/samples/connectors/jdbc/Person.java | 37 +
.../samples/connectors/jdbc/PersonData.java | 96 ++
.../samples/connectors/jdbc/PersonId.java | 32 +
.../connectors/jdbc/SimpleReaderApp.java | 102 ++
.../connectors/jdbc/SimpleWriterApp.java | 85 ++
.../samples/connectors/jdbc/package-info.java | 32 +
.../samples/connectors/kafka/KafkaClient.java | 144 +++
.../samples/connectors/kafka/PublisherApp.java | 81 ++
.../edgent/samples/connectors/kafka/README | 26 +
.../edgent/samples/connectors/kafka/Runner.java | 68 +
.../connectors/kafka/SimplePublisherApp.java | 99 ++
.../connectors/kafka/SimpleSubscriberApp.java | 95 ++
.../samples/connectors/kafka/SubscriberApp.java | 91 ++
.../samples/connectors/kafka/package-info.java | 35 +
.../samples/connectors/mqtt/MqttClient.java | 183 +++
.../samples/connectors/mqtt/PublisherApp.java | 74 ++
.../edgent/samples/connectors/mqtt/README | 24 +
.../edgent/samples/connectors/mqtt/Runner.java | 116 ++
.../connectors/mqtt/SimplePublisherApp.java | 98 ++
.../connectors/mqtt/SimpleSubscriberApp.java | 90 ++
.../samples/connectors/mqtt/SubscriberApp.java | 72 ++
.../samples/connectors/mqtt/package-info.java | 35 +
.../samples/connectors/obd2/Obd2Streams.java | 145 +++
.../edgent/samples/connectors/package-info.java | 22 +
.../quarks/samples/connectors/MsgSupplier.java | 50 -
.../java/quarks/samples/connectors/Options.java | 98 --
.../java/quarks/samples/connectors/Util.java | 75 --
.../quarks/samples/connectors/elm327/Cmd.java | 76 --
.../samples/connectors/elm327/Elm327Cmds.java | 75 --
.../connectors/elm327/Elm327Streams.java | 70 -
.../samples/connectors/elm327/Pids01.java | 141 --
.../samples/connectors/elm327/package-info.java | 27 -
.../elm327/runtime/CommandExecutor.java | 118 --
.../samples/connectors/file/FileReaderApp.java | 88 --
.../samples/connectors/file/FileWriterApp.java | 94 --
.../java/quarks/samples/connectors/file/README | 11 -
.../samples/connectors/file/package-info.java | 32 -
.../samples/connectors/iotf/IotfQuickstart.java | 86 --
.../samples/connectors/iotf/IotfSensors.java | 163 ---
.../samples/connectors/iotf/package-info.java | 24 -
.../quarks/samples/connectors/jdbc/DbUtils.java | 140 --
.../quarks/samples/connectors/jdbc/Person.java | 37 -
.../samples/connectors/jdbc/PersonData.java | 96 --
.../samples/connectors/jdbc/PersonId.java | 32 -
.../connectors/jdbc/SimpleReaderApp.java | 102 --
.../connectors/jdbc/SimpleWriterApp.java | 85 --
.../samples/connectors/jdbc/package-info.java | 32 -
.../samples/connectors/kafka/KafkaClient.java | 144 ---
.../samples/connectors/kafka/PublisherApp.java | 80 --
.../java/quarks/samples/connectors/kafka/README | 26 -
.../quarks/samples/connectors/kafka/Runner.java | 68 -
.../connectors/kafka/SimplePublisherApp.java | 98 --
.../connectors/kafka/SimpleSubscriberApp.java | 94 --
.../samples/connectors/kafka/SubscriberApp.java | 90 --
.../samples/connectors/kafka/package-info.java | 35 -
.../samples/connectors/mqtt/MqttClient.java | 183 ---
.../samples/connectors/mqtt/PublisherApp.java | 74 --
.../java/quarks/samples/connectors/mqtt/README | 24 -
.../quarks/samples/connectors/mqtt/Runner.java | 116 --
.../connectors/mqtt/SimplePublisherApp.java | 98 --
.../connectors/mqtt/SimpleSubscriberApp.java | 90 --
.../samples/connectors/mqtt/SubscriberApp.java | 72 --
.../samples/connectors/mqtt/package-info.java | 35 -
.../samples/connectors/obd2/Obd2Streams.java | 145 ---
.../quarks/samples/connectors/package-info.java | 22 -
samples/console/build.xml | 14 +-
.../samples/console/ConsoleWaterDetector.java | 412 ++++++
.../samples/console/HttpServerSample.java | 39 +
.../edgent/samples/console/package-info.java | 32 +
.../samples/console/ConsoleWaterDetector.java | 413 ------
.../samples/console/HttpServerSample.java | 39 -
.../quarks/samples/console/package-info.java | 32 -
samples/scenarios/build.xml | 10 +-
.../scenarios/iotf/IotfFullScenario.java | 92 ++
.../iotf/range/sensor/IotfRangeSensor.java | 219 ++++
.../scenarios/iotf/range/sensor/LED.java | 52 +
.../scenarios/iotf/range/sensor/README.md | 32 +
.../iotf/range/sensor/RangeSensor.java | 104 ++
.../iotf/range/sensor/SimulatedRangeSensor.java | 42 +
.../scenarios/iotf/range/sensor/device.cfg | 5 +
.../scenarios/iotf/IotfFullScenario.java | 92 --
.../iotf/range/sensor/IotfRangeSensor.java | 219 ----
.../scenarios/iotf/range/sensor/LED.java | 52 -
.../scenarios/iotf/range/sensor/README.md | 32 -
.../iotf/range/sensor/RangeSensor.java | 104 --
.../iotf/range/sensor/SimulatedRangeSensor.java | 42 -
.../scenarios/iotf/range/sensor/device.cfg | 5 -
samples/topology/build.xml | 12 +-
.../CombiningStreamsProcessingResults.java | 168 +++
.../topology/DevelopmentMetricsSample.java | 64 +
.../samples/topology/DevelopmentSample.java | 47 +
.../topology/DevelopmentSampleJobMXBean.java | 85 ++
.../edgent/samples/topology/HelloEdgent.java | 48 +
.../samples/topology/JobEventsSample.java | 165 +++
.../edgent/samples/topology/JobExecution.java | 124 ++
.../edgent/samples/topology/PeriodicSource.java | 65 +
.../samples/topology/SensorsAggregates.java | 114 ++
.../samples/topology/SimpleFilterTransform.java | 57 +
.../samples/topology/SplitWithEnumSample.java | 68 +
.../edgent/samples/topology/StreamTags.java | 63 +
.../samples/topology/TerminateAfterNTuples.java | 67 +
.../edgent/samples/topology/package-info.java | 24 +
.../CombiningStreamsProcessingResults.java | 168 ---
.../topology/DevelopmentMetricsSample.java | 64 -
.../samples/topology/DevelopmentSample.java | 47 -
.../topology/DevelopmentSampleJobMXBean.java | 85 --
.../quarks/samples/topology/HelloQuarks.java | 48 -
.../samples/topology/JobEventsSample.java | 165 ---
.../quarks/samples/topology/JobExecution.java | 124 --
.../quarks/samples/topology/PeriodicSource.java | 65 -
.../samples/topology/SensorsAggregates.java | 114 --
.../samples/topology/SimpleFilterTransform.java | 57 -
.../samples/topology/SplitWithEnumSample.java | 68 -
.../quarks/samples/topology/StreamTags.java | 63 -
.../samples/topology/TerminateAfterNTuples.java | 67 -
.../quarks/samples/topology/package-info.java | 24 -
samples/utils/build.xml | 12 +-
.../metrics/PeriodicSourceWithMetrics.java | 68 +
.../samples/utils/metrics/SplitWithMetrics.java | 71 +
.../utils/sensor/HeartMonitorSensor.java | 60 +
.../utils/sensor/PeriodicRandomSensor.java | 182 +++
.../utils/sensor/SimpleSimulatedSensor.java | 175 +++
.../samples/utils/sensor/SimulatedSensors.java | 88 ++
.../sensor/SimulatedTemperatureSensor.java | 107 ++
.../metrics/PeriodicSourceWithMetrics.java | 68 -
.../samples/utils/metrics/SplitWithMetrics.java | 71 -
.../utils/sensor/HeartMonitorSensor.java | 60 -
.../utils/sensor/PeriodicRandomSensor.java | 183 ---
.../utils/sensor/SimpleSimulatedSensor.java | 175 ---
.../samples/utils/sensor/SimulatedSensors.java | 88 --
.../sensor/SimulatedTemperatureSensor.java | 107 --
scripts/README | 4 +-
scripts/apps/sensorAnalytics/README | 4 +-
scripts/apps/sensorAnalytics/runDeviceComms.sh | 6 +-
.../apps/sensorAnalytics/runSensorAnalytics.sh | 6 +-
.../sensorAnalytics/sensorAnalytics.properties | 6 +-
scripts/connectors/file/README | 2 +-
scripts/connectors/file/runfilesample.sh | 8 +-
scripts/connectors/iotf/runiotfquickstart.sh | 6 +-
scripts/connectors/iotf/runiotfsensors.sh | 6 +-
scripts/connectors/jdbc/README | 2 +-
scripts/connectors/jdbc/runjdbcsample.sh | 8 +-
scripts/connectors/kafka/README | 2 +-
scripts/connectors/kafka/runkafkaclient.sh | 6 +-
scripts/connectors/kafka/runkafkasample.sh | 8 +-
scripts/connectors/mqtt/README | 2 +-
scripts/connectors/mqtt/runmqttclient.sh | 6 +-
scripts/connectors/mqtt/runmqttsample.sh | 8 +-
scripts/cron/README | 14 +-
scripts/cron/startapp.cron | 6 +-
scripts/cron/startapp.sh | 2 +-
scripts/runhelloedgent.cmd | 20 +
scripts/runhelloedgent.sh | 23 +
scripts/runhelloquarks.cmd | 20 -
scripts/runhelloquarks.sh | 23 -
scripts/runperiodicsource.cmd | 4 +-
scripts/runperiodicsource.sh | 6 +-
scripts/runsensoraggregates.cmd | 4 +-
scripts/runsensoraggregates.sh | 6 +-
scripts/runsimplefiltertransform.cmd | 4 +-
scripts/runsimplefiltertransform.sh | 6 +-
settings.gradle | 2 +-
spi/graph/build.xml | 6 +-
.../apache/edgent/graph/spi/AbstractGraph.java | 75 ++
.../apache/edgent/graph/spi/AbstractVertex.java | 36 +
.../org/apache/edgent/graph/spi/DirectEdge.java | 102 ++
.../graph/spi/execution/AbstractGraphJob.java | 84 ++
.../java/quarks/graph/spi/AbstractGraph.java | 75 --
.../java/quarks/graph/spi/AbstractVertex.java | 36 -
.../main/java/quarks/graph/spi/DirectEdge.java | 102 --
.../graph/spi/execution/AbstractGraphJob.java | 84 --
spi/topology/build.xml | 4 +-
.../edgent/topology/spi/AbstractTStream.java | 144 +++
.../edgent/topology/spi/AbstractTopology.java | 85 ++
.../topology/spi/AbstractTopologyProvider.java | 35 +
.../topology/spi/functions/EndlessSupplier.java | 65 +
.../topology/spi/graph/AbstractTWindow.java | 48 +
.../topology/spi/graph/ConnectorSink.java | 41 +
.../topology/spi/graph/ConnectorStream.java | 336 +++++
.../topology/spi/graph/GraphTopology.java | 69 +
.../edgent/topology/spi/graph/TWindowImpl.java | 74 ++
.../topology/spi/graph/TWindowTimeImpl.java | 113 ++
.../topology/spi/tester/AbstractTester.java | 84 ++
.../quarks/topology/spi/AbstractTStream.java | 144 ---
.../quarks/topology/spi/AbstractTopology.java | 85 --
.../topology/spi/AbstractTopologyProvider.java | 35 -
.../topology/spi/functions/EndlessSupplier.java | 65 -
.../topology/spi/graph/AbstractTWindow.java | 48 -
.../topology/spi/graph/ConnectorSink.java | 41 -
.../topology/spi/graph/ConnectorStream.java | 336 -----
.../topology/spi/graph/GraphTopology.java | 69 -
.../quarks/topology/spi/graph/TWindowImpl.java | 74 --
.../topology/spi/graph/TWindowTimeImpl.java | 113 --
.../topology/spi/tester/AbstractTester.java | 84 --
.../test/topology/spi/AbstractTStreamTest.java | 33 +
.../test/topology/spi/AbstractTStreamTest.java | 34 -
test/GpsObdAnalyticsApplication.properties | 2 +-
test/consoleUrl.txt | 1 +
test/fvtiot/build.xml | 10 +-
.../edgent/test/fvt/iot/IotAppServiceTest.java | 116 ++
.../edgent/test/fvt/iot/IotProviderTest.java | 238 ++++
.../apache/edgent/test/fvt/iot/IotTestApps.java | 58 +
.../quarks/test/fvt/iot/IotAppServiceTest.java | 117 --
.../quarks/test/fvt/iot/IotProviderTest.java | 239 ----
.../java/quarks/test/fvt/iot/IotTestApps.java | 58 -
test/iotfUrl.txt | 3 +
test/svt/build.gradle | 2 +-
test/svt/build.xml | 12 +-
.../org/apache/edgent/test/svt/MyClass1.java | 55 +
.../org/apache/edgent/test/svt/MyClass2.java | 66 +
.../edgent/test/svt/TopologyTestBasic.java | 392 ++++++
...eetManagementAnalyticsClientApplication.java | 68 +
.../test/svt/apps/GpsAnalyticsApplication.java | 215 ++++
.../test/svt/apps/ObdAnalyticsApplication.java | 39 +
.../svt/apps/iotf/AbstractIotfApplication.java | 116 ++
.../test/svt/utils/sensor/gps/GpsSensor.java | 70 +
.../svt/utils/sensor/gps/SimulatedGeofence.java | 36 +
.../utils/sensor/gps/SimulatedGpsSensor.java | 104 ++
.../src/main/java/quarks/test/svt/MyClass1.java | 55 -
.../src/main/java/quarks/test/svt/MyClass2.java | 66 -
.../java/quarks/test/svt/TopologyTestBasic.java | 392 ------
...eetManagementAnalyticsClientApplication.java | 68 -
.../test/svt/apps/GpsAnalyticsApplication.java | 215 ----
.../test/svt/apps/ObdAnalyticsApplication.java | 39 -
.../svt/apps/iotf/AbstractIotfApplication.java | 115 --
.../test/svt/utils/sensor/gps/GpsSensor.java | 70 -
.../svt/utils/sensor/gps/SimulatedGeofence.java | 36 -
.../utils/sensor/gps/SimulatedGpsSensor.java | 104 --
utils/metrics/build.xml | 8 +-
.../edgent/metrics/MetricObjectNameFactory.java | 136 ++
.../java/org/apache/edgent/metrics/Metrics.java | 82 ++
.../org/apache/edgent/metrics/MetricsSetup.java | 134 ++
.../apache/edgent/metrics/oplets/CounterOp.java | 49 +
.../apache/edgent/metrics/oplets/RateMeter.java | 50 +
.../oplets/SingleMetricAbstractOplet.java | 76 ++
.../org/apache/edgent/metrics/package-info.java | 28 +
.../quarks/metrics/MetricObjectNameFactory.java | 136 --
.../src/main/java/quarks/metrics/Metrics.java | 82 --
.../main/java/quarks/metrics/MetricsSetup.java | 134 --
.../java/quarks/metrics/oplets/CounterOp.java | 49 -
.../java/quarks/metrics/oplets/RateMeter.java | 50 -
.../oplets/SingleMetricAbstractOplet.java | 76 --
.../main/java/quarks/metrics/package-info.java | 28 -
.../metrics/MetricObjectNameFactoryTest.java | 113 ++
.../edgent/test/metrics/MetricsBaseTest.java | 112 ++
.../edgent/test/metrics/MetricsCommonTest.java | 153 +++
.../metrics/MetricsConsoleReporterTest.java | 139 ++
.../test/metrics/MetricsEverywhereTest.java | 373 ++++++
.../edgent/test/metrics/MetricsOffTest.java | 26 +
.../edgent/test/metrics/MetricsOnTest.java | 37 +
.../test/metrics/WriteOnlyMetricRegistry.java | 27 +
.../metrics/MetricObjectNameFactoryTest.java | 114 --
.../quarks/test/metrics/MetricsBaseTest.java | 113 --
.../quarks/test/metrics/MetricsCommonTest.java | 154 ---
.../metrics/MetricsConsoleReporterTest.java | 140 --
.../test/metrics/MetricsEverywhereTest.java | 374 ------
.../quarks/test/metrics/MetricsOffTest.java | 26 -
.../java/quarks/test/metrics/MetricsOnTest.java | 38 -
.../test/metrics/WriteOnlyMetricRegistry.java | 27 -
utils/streamscope/build.xml | 8 +-
.../apache/edgent/streamscope/StreamScope.java | 431 +++++++
.../edgent/streamscope/StreamScopeBean.java | 93 ++
.../edgent/streamscope/StreamScopeRegistry.java | 216 ++++
.../streamscope/StreamScopeRegistryBean.java | 94 ++
.../edgent/streamscope/StreamScopeSetup.java | 226 ++++
.../streamscope/mbeans/StreamScopeMXBean.java | 152 +++
.../mbeans/StreamScopeRegistryMXBean.java | 47 +
.../edgent/streamscope/mbeans/package-info.java | 24 +
.../edgent/streamscope/oplets/StreamScope.java | 72 ++
.../apache/edgent/streamscope/package-info.java | 35 +
.../java/quarks/streamscope/StreamScope.java | 431 -------
.../quarks/streamscope/StreamScopeBean.java | 93 --
.../quarks/streamscope/StreamScopeRegistry.java | 216 ----
.../streamscope/StreamScopeRegistryBean.java | 94 --
.../quarks/streamscope/StreamScopeSetup.java | 226 ----
.../streamscope/mbeans/StreamScopeMXBean.java | 152 ---
.../mbeans/StreamScopeRegistryMXBean.java | 47 -
.../quarks/streamscope/mbeans/package-info.java | 24 -
.../quarks/streamscope/oplets/StreamScope.java | 72 --
.../java/quarks/streamscope/package-info.java | 35 -
.../test/streamscope/StreamScopeTest.java | 337 +++++
.../test/streamscope/StreamScopeTest.java | 338 -----
1070 files changed, 57185 insertions(+), 56730 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/b8617922/providers/direct/build.gradle
----------------------------------------------------------------------