You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by dj...@apache.org on 2016/03/29 18:10:57 UTC
[1/5] incubator-quarks git commit: Merge pull request #2 from
apache/master
Repository: incubator-quarks
Updated Branches:
refs/heads/master 0b58e1531 -> 21c23c8f1
Merge pull request #2 from apache/master
merge
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/08a3ff38
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/08a3ff38
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/08a3ff38
Branch: refs/heads/master
Commit: 08a3ff38f9282b96d05ef87103be5a28f15df027
Parents: 98e1b88 eb91531
Author: Cazen Lee <Ca...@korea.com>
Authored: Tue Mar 22 14:00:09 2016 +0900
Committer: Cazen Lee <Ca...@korea.com>
Committed: Tue Mar 22 14:00:09 2016 +0900
----------------------------------------------------------------------
.../src/main/java/quarks/execution/Job.java | 71 ++++++--
.../java/quarks/execution/mbeans/JobMXBean.java | 111 +++++++++----
.../quarks/connectors/mqtt/iot/MqttDevice.java | 3 +-
.../wsclient/javax/websocket/KeystorePath.java | 21 +--
.../test/providers/direct/DirectJobTest.java | 29 +++-
.../java/quarks/runtime/etiao/EtiaoJob.java | 8 +
.../java/quarks/runtime/etiao/Executable.java | 1 +
.../runtime/etiao/mbeans/EtiaoJobBean.java | 12 +-
.../runtime/jobregistry/JobRegistryTest.java | 161 +++++++++++++++++++
.../samples/apps/ApplicationUtilities.java | 4 +-
.../java/quarks/samples/apps/JsonTuples.java | 83 ----------
.../samples/apps/sensorAnalytics/Sensor1.java | 37 +++--
.../topology/DevelopmentSampleJobMXBean.java | 8 +-
.../samples/topology/JobEventsSample.java | 20 ++-
.../graph/spi/execution/AbstractGraphJob.java | 24 ++-
.../topology/spi/graph/ConnectorStream.java | 3 -
16 files changed, 422 insertions(+), 174 deletions(-)
----------------------------------------------------------------------
[3/5] incubator-quarks git commit: Merge pull request #4 from
apache/master
Posted by dj...@apache.org.
Merge pull request #4 from apache/master
merge
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/33321a03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/33321a03
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/33321a03
Branch: refs/heads/master
Commit: 33321a033770ed3f85ccfda77e324539b9e2c0c8
Parents: db6ddfc 0b58e15
Author: Cazen Lee <Ca...@korea.com>
Authored: Sun Mar 27 14:20:06 2016 +0900
Committer: Cazen Lee <Ca...@korea.com>
Committed: Sun Mar 27 14:20:06 2016 +0900
----------------------------------------------------------------------
.../javax/websocket/WebSocketClientTest.java | 37 +-
.../runtime/jobregistry/JobRegistryTest.java | 18 +
samples/.classpath | 1 +
.../samples/apps/ApplicationUtilities.java | 2 +-
.../main/java/quarks/samples/apps/Range.java | 446 ++++++++++---------
.../quarks/test/samples/apps/RangeTest.java | 328 ++++++++++++++
6 files changed, 615 insertions(+), 217 deletions(-)
----------------------------------------------------------------------
[4/5] incubator-quarks git commit: Add License and README files to
META-INF
Posted by dj...@apache.org.
Add License and README files to META-INF
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/c99271ad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/c99271ad
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/c99271ad
Branch: refs/heads/master
Commit: c99271adf2f3e9066e76944999d5e04d33b1d073
Parents: 33321a0
Author: Cazen <magic12#>
Authored: Tue Mar 29 14:30:49 2016 +0900
Committer: Cazen <Ca...@korea.com>
Committed: Tue Mar 29 20:54:27 2016 +0900
----------------------------------------------------------------------
common-build.xml | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/c99271ad/common-build.xml
----------------------------------------------------------------------
diff --git a/common-build.xml b/common-build.xml
index 6fff38d..842b152 100644
--- a/common-build.xml
+++ b/common-build.xml
@@ -137,7 +137,9 @@
</target>
<target name="jar" depends="compile">
-
+ <mkdir dir="${classes}/META-INF"/>
+ <copy file="${quarks.dir}/LICENSE" tofile="${classes}/META-INF/LICENSE.txt"/>
+ <copy file="${quarks.dir}/NOTICE" tofile="${classes}/META-INF/NOTICE.txt"/>
<manifestclasspath property="jar.classpath" jarfile="${jar}"
maxParentLevels="5">
<classpath refid="compile.classpath"/>
[2/5] incubator-quarks git commit: Merge pull request #3 from
apache/master
Posted by dj...@apache.org.
Merge pull request #3 from apache/master
merge
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/db6ddfc7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/db6ddfc7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/db6ddfc7
Branch: refs/heads/master
Commit: db6ddfc761155570197999c3a0084f437a575655
Parents: 08a3ff3 d074ba1
Author: Cazen Lee <Ca...@korea.com>
Authored: Wed Mar 23 08:40:58 2016 +0900
Committer: Cazen Lee <Ca...@korea.com>
Committed: Wed Mar 23 08:40:58 2016 +0900
----------------------------------------------------------------------
DEVELOPMENT.md | 12 +++--
NOTICE | 8 ++++
README.md | 12 +++--
.../analytics/math3/json/JsonAnalytics.java | 18 +++++++-
.../math3/json/JsonUnivariateAggregate.java | 18 +++++++-
.../math3/json/JsonUnivariateAggregator.java | 18 +++++++-
.../analytics/math3/json/package-info.java | 18 +++++++-
.../math3/stat/JsonStorelessStatistic.java | 18 +++++++-
.../quarks/analytics/math3/stat/Statistic.java | 18 +++++++-
.../analytics/math3/stat/package-info.java | 18 +++++++-
.../test/analytics/math3/StatisticsTest.java | 18 +++++++-
.../java/quarks/analytics/sensors/Deadband.java | 18 +++++++-
.../java/quarks/analytics/sensors/Filters.java | 18 +++++++-
.../quarks/analytics/sensors/package-info.java | 18 +++++++-
.../test/analytics/sensors/FiltersTest.java | 18 +++++++-
.../quarks/android/hardware/SensorStreams.java | 18 +++++++-
.../hardware/runtime/SensorChangeEvents.java | 18 +++++++-
.../hardware/runtime/SensorSourceSetup.java | 18 +++++++-
.../quarks/android/oplet/RunOnUIThread.java | 18 +++++++-
.../android/topology/ActivityStreams.java | 18 +++++++-
.../java/quarks/execution/DirectSubmitter.java | 18 +++++++-
.../src/main/java/quarks/execution/Job.java | 18 +++++++-
.../main/java/quarks/execution/Submitter.java | 18 +++++++-
.../java/quarks/execution/mbeans/JobMXBean.java | 18 +++++++-
.../quarks/execution/mbeans/package-info.java | 18 +++++++-
.../java/quarks/execution/package-info.java | 18 +++++++-
.../execution/services/ControlService.java | 18 +++++++-
.../execution/services/RuntimeServices.java | 18 +++++++-
.../execution/services/ServiceContainer.java | 18 +++++++-
.../quarks/execution/services/package-info.java | 18 +++++++-
.../quarks/test/execution/ControlsTest.java | 18 +++++++-
.../main/java/quarks/function/BiConsumer.java | 18 +++++++-
.../main/java/quarks/function/BiFunction.java | 18 +++++++-
.../src/main/java/quarks/function/Consumer.java | 18 +++++++-
.../src/main/java/quarks/function/Function.java | 18 +++++++-
.../main/java/quarks/function/Functions.java | 18 +++++++-
.../main/java/quarks/function/Predicate.java | 18 +++++++-
.../src/main/java/quarks/function/Supplier.java | 18 +++++++-
.../java/quarks/function/ToDoubleFunction.java | 18 +++++++-
.../java/quarks/function/ToIntFunction.java | 18 +++++++-
.../java/quarks/function/UnaryOperator.java | 18 +++++++-
.../java/quarks/function/WrappedFunction.java | 18 +++++++-
.../main/java/quarks/function/package-info.java | 18 +++++++-
.../quarks/test/function/FunctionsTest.java | 18 +++++++-
.../src/main/java/quarks/graph/Connector.java | 18 +++++++-
api/graph/src/main/java/quarks/graph/Edge.java | 18 +++++++-
api/graph/src/main/java/quarks/graph/Graph.java | 18 +++++++-
.../src/main/java/quarks/graph/Vertex.java | 18 +++++++-
.../main/java/quarks/graph/package-info.java | 18 +++++++-
.../quarks/test/graph/GraphAbstractTest.java | 18 +++++++-
.../test/java/quarks/test/graph/GraphTest.java | 18 +++++++-
.../src/main/java/quarks/oplet/JobContext.java | 18 +++++++-
api/oplet/src/main/java/quarks/oplet/Oplet.java | 18 +++++++-
.../main/java/quarks/oplet/OpletContext.java | 18 +++++++-
.../java/quarks/oplet/core/AbstractOplet.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/FanOut.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Peek.java | 18 +++++++-
.../java/quarks/oplet/core/PeriodicSource.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Pipe.java | 18 +++++++-
.../java/quarks/oplet/core/ProcessSource.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Sink.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Source.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Split.java | 18 +++++++-
.../src/main/java/quarks/oplet/core/Union.java | 18 +++++++-
.../oplet/core/mbeans/PeriodicMXBean.java | 18 +++++++-
.../quarks/oplet/core/mbeans/package-info.java | 18 +++++++-
.../java/quarks/oplet/core/package-info.java | 18 +++++++-
.../java/quarks/oplet/functional/Events.java | 18 +++++++-
.../java/quarks/oplet/functional/Filter.java | 18 +++++++-
.../java/quarks/oplet/functional/FlatMap.java | 18 +++++++-
.../main/java/quarks/oplet/functional/Map.java | 18 +++++++-
.../main/java/quarks/oplet/functional/Peek.java | 18 +++++++-
.../functional/SupplierPeriodicSource.java | 18 +++++++-
.../quarks/oplet/functional/SupplierSource.java | 18 +++++++-
.../quarks/oplet/functional/package-info.java | 18 +++++++-
.../main/java/quarks/oplet/package-info.java | 18 +++++++-
.../java/quarks/oplet/plumbing/Isolate.java | 18 +++++++-
.../quarks/oplet/plumbing/PressureReliever.java | 18 +++++++-
.../quarks/oplet/plumbing/UnorderedIsolate.java | 18 +++++++-
.../quarks/oplet/plumbing/package-info.java | 18 +++++++-
.../java/quarks/oplet/window/Aggregate.java | 18 +++++++-
.../java/quarks/oplet/window/package-info.java | 18 +++++++-
.../test/oplet/functional/FilterTest.java | 18 +++++++-
.../quarks/test/oplet/operators/PipeTest.java | 18 +++++++-
.../src/main/java/quarks/topology/TSink.java | 18 +++++++-
.../src/main/java/quarks/topology/TStream.java | 18 +++++++-
.../src/main/java/quarks/topology/TWindow.java | 18 +++++++-
.../src/main/java/quarks/topology/Topology.java | 18 +++++++-
.../java/quarks/topology/TopologyElement.java | 18 +++++++-
.../java/quarks/topology/TopologyProvider.java | 18 +++++++-
.../java/quarks/topology/doc-files/sources.html | 20 ++++++--
.../quarks/topology/json/JsonFunctions.java | 18 +++++++-
.../java/quarks/topology/json/package-info.java | 18 +++++++-
.../main/java/quarks/topology/package-info.java | 18 +++++++-
.../topology/plumbing/PlumbingStreams.java | 18 +++++++-
.../quarks/topology/plumbing/package-info.java | 18 +++++++-
.../java/quarks/topology/tester/Condition.java | 18 +++++++-
.../java/quarks/topology/tester/Tester.java | 18 +++++++-
.../quarks/topology/tester/package-info.java | 18 +++++++-
.../quarks/test/topology/JsonFunctionsTest.java | 18 +++++++-
.../java/quarks/test/topology/PlumbingTest.java | 18 +++++++-
.../java/quarks/test/topology/TStreamTest.java | 18 +++++++-
.../java/quarks/test/topology/TWindowTest.java | 18 +++++++-
.../test/topology/TopologyAbstractTest.java | 18 +++++++-
.../test/topology/TopologyElementTest.java | 18 +++++++-
.../java/quarks/test/topology/TopologyTest.java | 18 +++++++-
.../quarks/test/topology/TopologyTestSetup.java | 18 +++++++-
.../src/main/java/quarks/window/Partition.java | 18 +++++++-
.../main/java/quarks/window/PartitionImpl.java | 18 +++++++-
.../java/quarks/window/PartitionedState.java | 18 +++++++-
.../src/main/java/quarks/window/Policies.java | 18 +++++++-
.../src/main/java/quarks/window/Window.java | 18 +++++++-
.../src/main/java/quarks/window/WindowImpl.java | 18 +++++++-
.../src/main/java/quarks/window/Windows.java | 18 +++++++-
.../main/java/quarks/window/package-info.java | 18 +++++++-
.../test/java/quarks/test/window/StateTest.java | 18 +++++++-
.../java/quarks/test/window/WindowTest.java | 18 +++++++-
build.xml | 6 +--
.../quarks/connectors/runtime/Connector.java | 18 +++++++-
.../quarks/connectors/runtime/IdleManager.java | 18 +++++++-
.../connectors/common/ConnectorTestBase.java | 18 +++++++-
.../quarks/connectors/file/FileStreams.java | 18 +++++++-
.../connectors/file/FileWriterCycleConfig.java | 18 +++++++-
.../connectors/file/FileWriterFlushConfig.java | 18 +++++++-
.../connectors/file/FileWriterPolicy.java | 18 +++++++-
.../file/FileWriterRetentionConfig.java | 18 +++++++-
.../quarks/connectors/file/package-info.java | 18 +++++++-
.../file/runtime/AbstractWriterFile.java | 18 +++++++-
.../file/runtime/DirectoryWatcher.java | 18 +++++++-
.../connectors/file/runtime/FileConnector.java | 18 +++++++-
.../file/runtime/IFileWriterPolicy.java | 18 +++++++-
.../file/runtime/StringWriterFile.java | 18 +++++++-
.../connectors/file/runtime/TextFileReader.java | 18 +++++++-
.../connectors/file/runtime/TextFileWriter.java | 18 +++++++-
.../test/connectors/file/FileStreamsTest.java | 18 +++++++-
.../file/FileStreamsTextFileWriterTest.java | 18 +++++++-
.../quarks/connectors/http/HttpClients.java | 18 +++++++-
.../quarks/connectors/http/HttpResponders.java | 18 +++++++-
.../quarks/connectors/http/HttpStreams.java | 18 +++++++-
.../quarks/connectors/http/package-info.java | 18 +++++++-
.../connectors/http/runtime/HttpRequester.java | 18 +++++++-
.../quarks/test/connectors/http/HttpTest.java | 18 +++++++-
.../java/quarks/connectors/iot/IotDevice.java | 18 +++++++-
.../main/java/quarks/connectors/iot/QoS.java | 18 +++++++-
.../quarks/connectors/iot/package-info.java | 18 +++++++-
.../quarks/test/connectors/iot/QoSTest.java | 18 +++++++-
.../java/quarks/connectors/iotf/IotfDevice.java | 18 +++++++-
.../quarks/connectors/iotf/package-info.java | 18 +++++++-
.../connectors/iotf/runtime/IotfConnector.java | 18 +++++++-
.../iotf/runtime/IotfDeviceCommands.java | 18 +++++++-
.../iotf/runtime/IotfDeviceEventsFixed.java | 18 +++++++-
.../iotf/runtime/IotfDeviceEventsFunction.java | 18 +++++++-
.../impl/QuarksSslContainerProviderImpl.java | 18 +++++++-
.../javax/websocket/impl/package-info.java | 18 +++++++-
.../quarks/connectors/jdbc/CheckedFunction.java | 18 +++++++-
.../quarks/connectors/jdbc/CheckedSupplier.java | 18 +++++++-
.../quarks/connectors/jdbc/JdbcStreams.java | 18 +++++++-
.../quarks/connectors/jdbc/ParameterSetter.java | 18 +++++++-
.../quarks/connectors/jdbc/ResultsHandler.java | 18 +++++++-
.../connectors/jdbc/StatementSupplier.java | 18 +++++++-
.../quarks/connectors/jdbc/package-info.java | 18 +++++++-
.../connectors/jdbc/runtime/JdbcConnector.java | 18 +++++++-
.../connectors/jdbc/runtime/JdbcStatement.java | 18 +++++++-
.../test/connectors/jdbc/JdbcStreamsTest.java | 18 +++++++-
.../quarks/connectors/kafka/KafkaConsumer.java | 18 +++++++-
.../quarks/connectors/kafka/KafkaProducer.java | 18 +++++++-
.../quarks/connectors/kafka/package-info.java | 18 +++++++-
.../kafka/runtime/KafkaConnector.java | 18 +++++++-
.../kafka/runtime/KafkaConsumerConnector.java | 18 +++++++-
.../kafka/runtime/KafkaProducerConnector.java | 18 +++++++-
.../kafka/runtime/KafkaPublisher.java | 18 +++++++-
.../kafka/runtime/KafkaSubscriber.java | 18 +++++++-
.../kafka/KafkaStreamsTestManual.java | 18 +++++++-
.../java/quarks/connectors/mqtt/MqttConfig.java | 18 +++++++-
.../quarks/connectors/mqtt/MqttStreams.java | 18 +++++++-
.../quarks/connectors/mqtt/iot/MqttDevice.java | 18 +++++++-
.../connectors/mqtt/iot/package-info.java | 18 +++++++-
.../quarks/connectors/mqtt/package-info.java | 18 +++++++-
.../connectors/mqtt/runtime/MqttConnector.java | 18 +++++++-
.../connectors/mqtt/runtime/MqttPublisher.java | 18 +++++++-
.../connectors/mqtt/runtime/MqttSubscriber.java | 18 +++++++-
.../connectors/mqtt/MqttStreamsTestManual.java | 18 +++++++-
.../connectors/pubsub/PublishSubscribe.java | 18 +++++++-
.../connectors/pubsub/oplets/Publish.java | 18 +++++++-
.../connectors/pubsub/oplets/package-info.java | 18 +++++++-
.../quarks/connectors/pubsub/package-info.java | 18 +++++++-
.../pubsub/service/ProviderPubSub.java | 18 +++++++-
.../pubsub/service/PublishSubscribeService.java | 18 +++++++-
.../connectors/pubsub/service/TopicHandler.java | 18 +++++++-
.../connectors/pubsub/service/package-info.java | 18 +++++++-
.../test/connectors/pubsub/PubSubTest.java | 18 +++++++-
.../websocket/QuarksSslContainerProvider.java | 18 +++++++-
.../quarks/javax/websocket/package-info.java | 18 +++++++-
.../quarks/connectors/serial/SerialDevice.java | 18 +++++++-
.../quarks/connectors/serial/package-info.java | 18 +++++++-
.../javax/websocket/Jsr356WebSocketClient.java | 18 +++++++-
.../wsclient/javax/websocket/package-info.java | 18 +++++++-
.../runtime/WebSocketClientBinaryReceiver.java | 18 +++++++-
.../runtime/WebSocketClientBinarySender.java | 18 +++++++-
.../runtime/WebSocketClientConnector.java | 18 +++++++-
.../runtime/WebSocketClientReceiver.java | 18 +++++++-
.../runtime/WebSocketClientSender.java | 18 +++++++-
.../wsclient/javax/websocket/KeystorePath.java | 24 ++++++++--
.../javax/websocket/WebSocketClientTest.java | 18 +++++++-
.../javax/websocket/WebSocketServerEcho.java | 18 +++++++-
.../connectors/wsclient/WebSocketClient.java | 18 +++++++-
.../connectors/wsclient/package-info.java | 18 +++++++-
.../java/quarks/console/server/HttpServer.java | 18 +++++++-
.../java/quarks/console/server/ServerUtil.java | 18 +++++++-
.../test/console/server/HttpServerTest.java | 18 +++++++-
.../test/console/server/ServerUtilTest.java | 18 +++++++-
.../console/servlets/ConsoleJobServlet.java | 18 +++++++-
.../console/servlets/ConsoleMetricsServlet.java | 18 +++++++-
.../quarks/console/servlets/ConsoleServlet.java | 18 +++++++-
.../java/quarks/console/servlets/JobUtil.java | 18 +++++++-
.../quarks/console/servlets/MetricsGson.java | 18 +++++++-
.../quarks/console/servlets/MetricsUtil.java | 18 +++++++-
.../servlets/webapp_content/js/streamtags.js | 18 +++++++-
.../development/DevelopmentProvider.java | 18 +++++++-
.../providers/development/package-info.java | 18 +++++++-
.../providers/dev/DevelopmentTestSetup.java | 18 +++++++-
.../dev/topology/DevelopmentPlumbingTest.java | 18 +++++++-
.../dev/topology/DevelopmentTStreamTest.java | 18 +++++++-
.../dev/topology/DevelopmentTopologyTest.java | 18 +++++++-
.../dev/topology/DevelopmentWindowTest.java | 18 +++++++-
.../quarks/providers/direct/DirectProvider.java | 18 +++++++-
.../quarks/providers/direct/DirectTester.java | 18 +++++++-
.../quarks/providers/direct/DirectTopology.java | 18 +++++++-
.../quarks/providers/direct/package-info.java | 18 +++++++-
.../test/providers/direct/DirectJobTest.java | 18 +++++++-
.../test/providers/direct/DirectTestSetup.java | 18 +++++++-
.../DirectMetricObjectNameFactoryTest.java | 18 +++++++-
.../metrics/DirectMetricsEverywhereTest.java | 18 +++++++-
.../direct/metrics/DirectMetricsOffTest.java | 18 +++++++-
.../direct/metrics/DirectMetricsOnTest.java | 18 +++++++-
.../direct/topology/DirectPlumbingTest.java | 18 +++++++-
.../direct/topology/DirectTStreamTest.java | 18 +++++++-
.../direct/topology/DirectTopologyTest.java | 18 +++++++-
.../direct/topology/DirectWindowTest.java | 18 +++++++-
quarks_overview.html | 7 ++-
.../quarks/runtime/etiao/AbstractContext.java | 18 +++++++-
.../java/quarks/runtime/etiao/EtiaoJob.java | 18 +++++++-
.../java/quarks/runtime/etiao/Executable.java | 18 +++++++-
.../java/quarks/runtime/etiao/Invocation.java | 18 +++++++-
.../quarks/runtime/etiao/InvocationContext.java | 18 +++++++-
.../quarks/runtime/etiao/SettableForwarder.java | 18 +++++++-
.../runtime/etiao/ThreadFactoryTracker.java | 18 +++++++-
.../etiao/TrackingScheduledExecutor.java | 18 +++++++-
.../quarks/runtime/etiao/graph/DirectGraph.java | 18 +++++++-
.../runtime/etiao/graph/EtiaoConnector.java | 18 +++++++-
.../runtime/etiao/graph/ExecutableVertex.java | 18 +++++++-
.../java/quarks/runtime/etiao/graph/Target.java | 18 +++++++-
.../runtime/etiao/graph/model/EdgeType.java | 18 +++++++-
.../runtime/etiao/graph/model/GraphType.java | 18 +++++++-
.../runtime/etiao/graph/model/IdMapper.java | 18 +++++++-
.../etiao/graph/model/InvocationType.java | 18 +++++++-
.../runtime/etiao/graph/model/VertexType.java | 18 +++++++-
.../runtime/etiao/mbeans/EtiaoJobBean.java | 18 +++++++-
.../java/quarks/runtime/etiao/package-info.java | 18 +++++++-
.../test/runtime/etiao/EtiaoGraphTest.java | 18 +++++++-
.../runtime/jmxcontrol/JMXControlService.java | 18 +++++++-
.../jmxcontrol/JMXControlServiceTest.java | 18 +++++++-
.../runtime/jsoncontrol/JsonControlService.java | 18 +++++++-
.../runtime/jsoncontrol/package-info.java | 18 +++++++-
.../jsoncontrol/JsonControlServiceTest.java | 18 +++++++-
.../samples/apps/AbstractApplication.java | 18 +++++++-
.../samples/apps/ApplicationUtilities.java | 18 +++++++-
.../java/quarks/samples/apps/JsonTuples.java | 18 +++++++-
.../main/java/quarks/samples/apps/Range.java | 18 +++++++-
.../samples/apps/TopologyProviderFactory.java | 18 +++++++-
.../apps/mqtt/AbstractMqttApplication.java | 18 +++++++-
.../samples/apps/mqtt/DeviceCommsApp.java | 18 +++++++-
.../quarks/samples/apps/mqtt/package-info.java | 18 +++++++-
.../java/quarks/samples/apps/package-info.java | 18 +++++++-
.../samples/apps/sensorAnalytics/Sensor1.java | 18 +++++++-
.../SensorAnalyticsApplication.java | 18 +++++++-
.../apps/sensorAnalytics/package-info.java | 18 +++++++-
.../quarks/samples/connectors/MsgSupplier.java | 18 +++++++-
.../java/quarks/samples/connectors/Options.java | 18 +++++++-
.../java/quarks/samples/connectors/Util.java | 18 +++++++-
.../samples/connectors/file/FileReaderApp.java | 18 +++++++-
.../samples/connectors/file/FileWriterApp.java | 18 +++++++-
.../samples/connectors/file/package-info.java | 18 +++++++-
.../samples/connectors/iotf/IotfQuickstart.java | 18 +++++++-
.../samples/connectors/iotf/IotfSensors.java | 18 +++++++-
.../samples/connectors/iotf/package-info.java | 18 +++++++-
.../quarks/samples/connectors/jdbc/DbUtils.java | 18 +++++++-
.../quarks/samples/connectors/jdbc/Person.java | 18 +++++++-
.../samples/connectors/jdbc/PersonData.java | 18 +++++++-
.../samples/connectors/jdbc/PersonId.java | 18 +++++++-
.../connectors/jdbc/SimpleReaderApp.java | 18 +++++++-
.../connectors/jdbc/SimpleWriterApp.java | 18 +++++++-
.../samples/connectors/jdbc/package-info.java | 18 +++++++-
.../samples/connectors/kafka/KafkaClient.java | 18 +++++++-
.../samples/connectors/kafka/PublisherApp.java | 18 +++++++-
.../quarks/samples/connectors/kafka/Runner.java | 18 +++++++-
.../connectors/kafka/SimplePublisherApp.java | 18 +++++++-
.../connectors/kafka/SimpleSubscriberApp.java | 18 +++++++-
.../samples/connectors/kafka/SubscriberApp.java | 18 +++++++-
.../samples/connectors/kafka/package-info.java | 18 +++++++-
.../samples/connectors/mqtt/MqttClient.java | 18 +++++++-
.../samples/connectors/mqtt/PublisherApp.java | 18 +++++++-
.../quarks/samples/connectors/mqtt/Runner.java | 18 +++++++-
.../connectors/mqtt/SimplePublisherApp.java | 18 +++++++-
.../connectors/mqtt/SimpleSubscriberApp.java | 18 +++++++-
.../samples/connectors/mqtt/SubscriberApp.java | 18 +++++++-
.../samples/connectors/mqtt/package-info.java | 18 +++++++-
.../quarks/samples/connectors/package-info.java | 18 +++++++-
.../samples/console/ConsoleWaterDetector.java | 18 +++++++-
.../samples/console/HttpServerSample.java | 18 +++++++-
.../quarks/samples/console/package-info.java | 18 +++++++-
.../CombiningStreamsProcessingResults.java | 48 +++++++++-----------
.../topology/DevelopmentMetricsSample.java | 18 +++++++-
.../samples/topology/DevelopmentSample.java | 18 +++++++-
.../topology/DevelopmentSampleJobMXBean.java | 18 +++++++-
.../quarks/samples/topology/HelloWorld.java | 18 +++++++-
.../quarks/samples/topology/JobExecution.java | 18 +++++++-
.../quarks/samples/topology/PeriodicSource.java | 18 +++++++-
.../samples/topology/SensorsAggregates.java | 18 +++++++-
.../samples/topology/SimpleFilterTransform.java | 18 +++++++-
.../quarks/samples/topology/StreamTags.java | 18 +++++++-
.../quarks/samples/topology/package-info.java | 18 +++++++-
.../metrics/PeriodicSourceWithMetrics.java | 18 +++++++-
.../samples/utils/metrics/SplitWithMetrics.java | 18 +++++++-
.../utils/sensor/PeriodicRandomSensor.java | 18 +++++++-
.../samples/utils/sensor/SimulatedSensors.java | 18 +++++++-
.../java/quarks/graph/spi/AbstractGraph.java | 18 +++++++-
.../java/quarks/graph/spi/AbstractVertex.java | 18 +++++++-
.../main/java/quarks/graph/spi/DirectEdge.java | 18 +++++++-
.../graph/spi/execution/AbstractGraphJob.java | 18 +++++++-
.../quarks/topology/spi/AbstractTStream.java | 18 +++++++-
.../quarks/topology/spi/AbstractTopology.java | 18 +++++++-
.../topology/spi/AbstractTopologyProvider.java | 18 +++++++-
.../topology/spi/functions/EndlessSupplier.java | 18 +++++++-
.../topology/spi/graph/ConnectorSink.java | 18 +++++++-
.../topology/spi/graph/ConnectorStream.java | 18 +++++++-
.../topology/spi/graph/GraphTopology.java | 18 +++++++-
.../quarks/topology/spi/graph/TWindowImpl.java | 18 +++++++-
.../topology/spi/tester/AbstractTester.java | 18 +++++++-
.../test/topology/spi/AbstractTStreamTest.java | 18 +++++++-
.../src/main/java/quarks/test/svt/MyClass1.java | 18 +++++++-
.../src/main/java/quarks/test/svt/MyClass2.java | 18 +++++++-
.../java/quarks/test/svt/TopologyTestBasic.java | 18 +++++++-
.../quarks/metrics/MetricObjectNameFactory.java | 18 +++++++-
.../src/main/java/quarks/metrics/Metrics.java | 18 +++++++-
.../main/java/quarks/metrics/MetricsSetup.java | 18 +++++++-
.../java/quarks/metrics/oplets/CounterOp.java | 18 +++++++-
.../java/quarks/metrics/oplets/RateMeter.java | 18 +++++++-
.../oplets/SingleMetricAbstractOplet.java | 18 +++++++-
.../main/java/quarks/metrics/package-info.java | 18 +++++++-
.../metrics/MetricObjectNameFactoryTest.java | 18 +++++++-
.../quarks/test/metrics/MetricsBaseTest.java | 18 +++++++-
.../quarks/test/metrics/MetricsCommonTest.java | 18 +++++++-
.../metrics/MetricsConsoleReporterTest.java | 18 +++++++-
.../test/metrics/MetricsEverywhereTest.java | 18 +++++++-
.../quarks/test/metrics/MetricsOffTest.java | 18 +++++++-
.../java/quarks/test/metrics/MetricsOnTest.java | 18 +++++++-
.../test/metrics/WriteOnlyMetricRegistry.java | 18 +++++++-
358 files changed, 5689 insertions(+), 748 deletions(-)
----------------------------------------------------------------------
[5/5] incubator-quarks git commit: Modify LICENSE.txt to LICENSE(typo)
Posted by dj...@apache.org.
Modify LICENSE.txt to LICENSE(typo)
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/21c23c8f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/21c23c8f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/21c23c8f
Branch: refs/heads/master
Commit: 21c23c8f10a761cec4bd3f8454d24f340c6ef04f
Parents: c99271a
Author: Cazen <Ca...@korea.com>
Authored: Tue Mar 29 22:21:49 2016 +0900
Committer: Cazen <Ca...@korea.com>
Committed: Tue Mar 29 22:21:49 2016 +0900
----------------------------------------------------------------------
common-build.xml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/21c23c8f/common-build.xml
----------------------------------------------------------------------
diff --git a/common-build.xml b/common-build.xml
index 842b152..19f6118 100644
--- a/common-build.xml
+++ b/common-build.xml
@@ -138,8 +138,8 @@
<target name="jar" depends="compile">
<mkdir dir="${classes}/META-INF"/>
- <copy file="${quarks.dir}/LICENSE" tofile="${classes}/META-INF/LICENSE.txt"/>
- <copy file="${quarks.dir}/NOTICE" tofile="${classes}/META-INF/NOTICE.txt"/>
+ <copy file="${quarks.dir}/LICENSE" tofile="${classes}/META-INF/LICENSE"/>
+ <copy file="${quarks.dir}/NOTICE" tofile="${classes}/META-INF/NOTICE"/>
<manifestclasspath property="jar.classpath" jarfile="${jar}"
maxParentLevels="5">
<classpath refid="compile.classpath"/>