Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id F02FE200B4A for ; Wed, 6 Jul 2016 02:17:10 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id EECE2160A6F; Wed, 6 Jul 2016 00:17:10 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 1B5D2160A60 for ; Wed, 6 Jul 2016 02:17:09 +0200 (CEST) Received: (qmail 52994 invoked by uid 500); 6 Jul 2016 00:17:09 -0000 Mailing-List: contact commits-help@quarks.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@quarks.incubator.apache.org Delivered-To: mailing list commits@quarks.incubator.apache.org Received: (qmail 52985 invoked by uid 99); 6 Jul 2016 00:17:09 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 06 Jul 2016 00:17:09 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id C14E1C0B7B for ; Wed, 6 Jul 2016 00:17:08 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.646 X-Spam-Level: X-Spam-Status: No, score=-4.646 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.426] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id IiBfxr4lDBNL for ; Wed, 6 Jul 2016 00:17:06 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id CC3FC5F1B3 for ; Wed, 6 Jul 2016 00:17:05 +0000 (UTC) Received: (qmail 52853 invoked by uid 99); 6 Jul 2016 00:17:04 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 06 Jul 2016 00:17:04 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 78895E01C1; Wed, 6 Jul 2016 00:17:04 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: cazen@apache.org To: commits@quarks.incubator.apache.org Date: Wed, 06 Jul 2016 00:17:04 -0000 Message-Id: <95947d54c0fb4abfa6e4e77db8553e0a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/2] incubator-quarks git commit: Fix JavaDoc syntax and remove wai-aria in table tag archived-at: Wed, 06 Jul 2016 00:17:11 -0000 Repository: incubator-quarks Updated Branches: refs/heads/master b2899a82c -> 37c823774 Fix JavaDoc syntax and remove wai-aria in table tag Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/5b94b799 Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/5b94b799 Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/5b94b799 Branch: refs/heads/master Commit: 5b94b799b4ea83c41ab8629809333a08ada10997 Parents: 91796df Author: cazen Authored: Mon Jul 4 01:56:37 2016 +0000 Committer: cazen Committed: Mon Jul 4 23:21:35 2016 +0000 ---------------------------------------------------------------------- .../java/quarks/topology/mbeans/package-info.java | 2 +- .../main/java/quarks/apps/runtime/JobMonitorApp.java | 3 ++- .../java/quarks/connectors/runtime/Connector.java | 4 ++-- .../main/java/quarks/console/server/HttpServer.java | 4 ++-- .../main/java/quarks/providers/iot/package-info.java | 4 ++-- .../src/main/java/quarks/runtime/etiao/EtiaoJob.java | 7 ++++++- .../scenarios/iotf/range/sensor/IotfRangeSensor.java | 7 ++++++- .../java/quarks/topology/spi/AbstractTStream.java | 14 ++++++-------- 8 files changed, 27 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/api/topology/src/main/java/quarks/topology/mbeans/package-info.java ---------------------------------------------------------------------- diff --git a/api/topology/src/main/java/quarks/topology/mbeans/package-info.java b/api/topology/src/main/java/quarks/topology/mbeans/package-info.java index 44bc615..c27ea11 100644 --- a/api/topology/src/main/java/quarks/topology/mbeans/package-info.java +++ b/api/topology/src/main/java/quarks/topology/mbeans/package-info.java @@ -30,7 +30,7 @@ under the License. * *

Submit an Application

* Method: {@link quarks.topology.mbeans.ApplicationServiceMXBean#submit(String, String)} - * + *
* * * http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/apps/runtime/src/main/java/quarks/apps/runtime/JobMonitorApp.java ---------------------------------------------------------------------- diff --git a/apps/runtime/src/main/java/quarks/apps/runtime/JobMonitorApp.java b/apps/runtime/src/main/java/quarks/apps/runtime/JobMonitorApp.java index 39d67c6..8eef3fd 100644 --- a/apps/runtime/src/main/java/quarks/apps/runtime/JobMonitorApp.java +++ b/apps/runtime/src/main/java/quarks/apps/runtime/JobMonitorApp.java @@ -203,7 +203,8 @@ public class JobMonitorApp { * 
      * JobEvents source --> Filter (health == unhealthy) --> Restart application
      *
- * + * @param t Topology + * */ public static void declareTopology(Topology t) { TStream jobEvents = JobEvents.source( http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/connectors/common/src/main/java/quarks/connectors/runtime/Connector.java ---------------------------------------------------------------------- diff --git a/connectors/common/src/main/java/quarks/connectors/runtime/Connector.java b/connectors/common/src/main/java/quarks/connectors/runtime/Connector.java index 8709673..213a91a 100644 --- a/connectors/common/src/main/java/quarks/connectors/runtime/Connector.java +++ b/connectors/common/src/main/java/quarks/connectors/runtime/Connector.java @@ -106,8 +106,8 @@ public abstract class Connector implements AutoCloseable, Serializable { /** * Disconnect the connector after the specified period of inactivity. - * @param idleTimeout - * @param unit + * @param idleTimeout idleTimeout(long) + * @param unit TimeUnit */ public void setIdleTimeout(long idleTimeout, TimeUnit unit) { idleManager.setIdleTimeoutMsec(unit.toMillis(idleTimeout)); http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/console/server/src/main/java/quarks/console/server/HttpServer.java ---------------------------------------------------------------------- diff --git a/console/server/src/main/java/quarks/console/server/HttpServer.java b/console/server/src/main/java/quarks/console/server/HttpServer.java index 537fbba..d80227b 100644 --- a/console/server/src/main/java/quarks/console/server/HttpServer.java +++ b/console/server/src/main/java/quarks/console/server/HttpServer.java @@ -108,7 +108,7 @@ public class HttpServer { /** * * @return a String containing the context path to the console web application - * @throws Exception + * @throws Exception on failure */ public String getConsoleContextPath() throws Exception { return HttpServerHolder.WEBAPP.getContextPath(); @@ -167,7 +167,7 @@ public class HttpServer { /** * Returns the url for the web application at the "console" context path. Localhost is always assumed * @return the url for the web application at the "console" context path. - * @throws Exception + * @throws Exception on failure */ public String getConsoleUrl() throws Exception { return new String("http://localhost" + ":" + getConsolePortNumber() + getConsoleContextPath()); http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/providers/iot/src/main/java/quarks/providers/iot/package-info.java ---------------------------------------------------------------------- diff --git a/providers/iot/src/main/java/quarks/providers/iot/package-info.java b/providers/iot/src/main/java/quarks/providers/iot/package-info.java index 333ae8d..7e6b15b 100644 --- a/providers/iot/src/main/java/quarks/providers/iot/package-info.java +++ b/providers/iot/src/main/java/quarks/providers/iot/package-info.java @@ -45,7 +45,7 @@ under the License. * including arbitrary control mbeans registered by applications. * *

Provider operations

- *
JSON Submit Application
Attribute name
+ *
* * * @@ -76,7 +76,7 @@ under the License. * * * - *
OperationCommand identifierTypeAliasMethodArguments{@code {"type":"job","alias":"Heartbeat","op":"stateChange","args":["CLOSE"]}}
+ * * */ package quarks.providers.iot; http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/runtime/etiao/src/main/java/quarks/runtime/etiao/EtiaoJob.java ---------------------------------------------------------------------- diff --git a/runtime/etiao/src/main/java/quarks/runtime/etiao/EtiaoJob.java b/runtime/etiao/src/main/java/quarks/runtime/etiao/EtiaoJob.java index c1fcbd9..85b9ec5 100644 --- a/runtime/etiao/src/main/java/quarks/runtime/etiao/EtiaoJob.java +++ b/runtime/etiao/src/main/java/quarks/runtime/etiao/EtiaoJob.java @@ -182,7 +182,12 @@ public class EtiaoJob extends AbstractGraphJob implements JobContext { /** * Complete job closing. This method can be invoked after a job close - * has been initiated. + * has been initiated. + * @param timeout the time to wait + * @param unit TimeUnit + * @throws ExecutionException if the job execution threw an ExecutionException. + * @throws InterruptedException if the job execution threw an InterruptedException. + * @throws TimeoutException if the job execution threw an TimeoutException. */ public void completeClosing(long timeout, TimeUnit unit) throws ExecutionException, InterruptedException, TimeoutException { if (unit == null) http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/samples/scenarios/src/main/java/quarks/samples/scenarios/iotf/range/sensor/IotfRangeSensor.java ---------------------------------------------------------------------- diff --git a/samples/scenarios/src/main/java/quarks/samples/scenarios/iotf/range/sensor/IotfRangeSensor.java b/samples/scenarios/src/main/java/quarks/samples/scenarios/iotf/range/sensor/IotfRangeSensor.java index 842e267..bb87e4c 100644 --- a/samples/scenarios/src/main/java/quarks/samples/scenarios/iotf/range/sensor/IotfRangeSensor.java +++ b/samples/scenarios/src/main/java/quarks/samples/scenarios/iotf/range/sensor/IotfRangeSensor.java @@ -136,6 +136,8 @@ public class IotfRangeSensor { * @param print * True if the data submitted as events should also be printed to * standard out. + * @param simulated + * boolean flag */ public static void rangeSensor(IotDevice device, boolean simulated, boolean print) { @@ -197,7 +199,10 @@ public class IotfRangeSensor { * Note to receive commands a analytic application must exist that generates * them through IBM Watson IoT Platform. *

- * + * + * @param device IoTF device + * @return JSON object includes tsms(timestamp) and payload.msg(status) + * * @see IotDevice#commands(String...) */ public static TStream displayMessages(IotDevice device) { http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/5b94b799/spi/topology/src/main/java/quarks/topology/spi/AbstractTStream.java ---------------------------------------------------------------------- diff --git a/spi/topology/src/main/java/quarks/topology/spi/AbstractTStream.java b/spi/topology/src/main/java/quarks/topology/spi/AbstractTStream.java index bc71f0a..c1dcd7f 100644 --- a/spi/topology/src/main/java/quarks/topology/spi/AbstractTStream.java +++ b/spi/topology/src/main/java/quarks/topology/spi/AbstractTStream.java @@ -31,8 +31,9 @@ import quarks.topology.Topology; /** * Abstract stream that uses the functional primitives to implement most * methods. - *

+ *

* The functional primitives are: + *

*
    *
  • {@link TStream#filter(quarks.function.Predicate)}
    • *
  • {@link TStream#map(quarks.function.Function)}
    • @@ -40,8 +41,7 @@ import quarks.topology.Topology; *
* These methods are unimplemented, thus left to the specific implementation * used to build the topology. - *

- * + * * @param * Type of the {@link Topology} implementation. * @param @@ -74,18 +74,16 @@ public abstract class AbstractTStream implements TStream< * a different object of the same type. * If {@code modifier.apply(t)} returns {@code null} then no tuple * is submitted to the returned stream for {@code t}. - * + * *

* Example of modifying a stream {@code String} values by adding the suffix '{@code extra}'. - * + *

* 
      * 
      * TStream<String> strings = ...
      * TStream<String> modifiedStrings = strings.modify(t -> t.concat("extra"));
      * 
      *
- * - *

*

* This method is equivalent to * {@code map(Function modifier}). @@ -131,7 +129,7 @@ public abstract class AbstractTStream implements TStream< * {@code other}. A stream cannot be unioned with itself, in this case * {@code this} will be returned. * - * @param other + * @param other TStream * @return A stream that is the union of {@code this} and {@code other}. */ @Override