Return-Path: X-Original-To: apmail-apex-commits-archive@minotaur.apache.org Delivered-To: apmail-apex-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 43C9A18FFC for ; Tue, 3 Nov 2015 02:27:23 +0000 (UTC) Received: (qmail 61880 invoked by uid 500); 3 Nov 2015 02:27:23 -0000 Delivered-To: apmail-apex-commits-archive@apex.apache.org Received: (qmail 61833 invoked by uid 500); 3 Nov 2015 02:27:23 -0000 Mailing-List: contact commits-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list commits@apex.incubator.apache.org Received: (qmail 61824 invoked by uid 99); 3 Nov 2015 02:27:23 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 03 Nov 2015 02:27:23 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id B2DAF18027B for ; Tue, 3 Nov 2015 02:27:22 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.771 X-Spam-Level: * X-Spam-Status: No, score=1.771 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id FB4LYwGl4v_R for ; Tue, 3 Nov 2015 02:27:13 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with SMTP id B04BD259A4 for ; Tue, 3 Nov 2015 02:27:06 +0000 (UTC) Received: (qmail 58779 invoked by uid 99); 3 Nov 2015 02:27:03 -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; Tue, 03 Nov 2015 02:27:03 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D0603E0AB2; Tue, 3 Nov 2015 02:27:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: thw@apache.org To: commits@apex.incubator.apache.org Date: Tue, 03 Nov 2015 02:27:36 -0000 Message-Id: <1756258e140143eda3b95e8ad3704a7d@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [35/50] [abbrv] incubator-apex-core git commit: Fix EOL Fix EOL Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/b527b301 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/b527b301 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/b527b301 Branch: refs/heads/master Commit: b527b301a29b05a747f6ce1b43f852c8a4d894f5 Parents: 979a0ef Author: MalharJenkins Authored: Tue Oct 20 19:54:58 2015 -0700 Committer: Vlad Rozov Committed: Tue Oct 20 19:54:58 2015 -0700 ---------------------------------------------------------------------- .../datatorrent/common/util/package-info.java | 38 +++--- .../com/datatorrent/stram/cli/package-info.java | 66 ++++----- .../datatorrent/stram/engine/package-info.java | 94 ++++++------- .../com/datatorrent/stram/package-info.java | 54 ++++---- .../datatorrent/stram/stream/package-info.java | 136 +++++++++---------- .../datatorrent/stram/util/package-info.java | 64 ++++----- .../datatorrent/stram/webapp/package-info.java | 76 +++++------ 7 files changed, 264 insertions(+), 264 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/common/src/main/java/com/datatorrent/common/util/package-info.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/com/datatorrent/common/util/package-info.java b/common/src/main/java/com/datatorrent/common/util/package-info.java index 41134d0..5bfc38f 100644 --- a/common/src/main/java/com/datatorrent/common/util/package-info.java +++ b/common/src/main/java/com/datatorrent/common/util/package-info.java @@ -1,22 +1,22 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ /** * Shared utilities */ -package com.datatorrent.common.util; +package com.datatorrent.common.util; http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/cli/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/cli/package-info.java b/engine/src/main/java/com/datatorrent/stram/cli/package-info.java index 116366b..05b45e2 100644 --- a/engine/src/main/java/com/datatorrent/stram/cli/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/cli/package-info.java @@ -1,33 +1,33 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * - * com.datatorrent.stram.cli package deals with code for command line interface for the streaming platform

- *
- * The cli code wraps the webservices layer (com.datatorrent.stream.webapp) and thus accesses the dag - * via one single point. All webservice calls for streaming data go through to the stram.
- *
- * The com.datatorrent.stram.cli package consists of
- * {@link com.datatorrent.stram.cli.DTCli}: Provides command line interface for a streaming application on hadoop (yarn)
- *
- * - */ -package com.datatorrent.stram.cli; - - +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * + * com.datatorrent.stram.cli package deals with code for command line interface for the streaming platform

+ *
+ * The cli code wraps the webservices layer (com.datatorrent.stream.webapp) and thus accesses the dag + * via one single point. All webservice calls for streaming data go through to the stram.
+ *
+ * The com.datatorrent.stram.cli package consists of
+ * {@link com.datatorrent.stram.cli.DTCli}: Provides command line interface for a streaming application on hadoop (yarn)
+ *
+ * + */ +package com.datatorrent.stram.cli; + + http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/engine/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/engine/package-info.java b/engine/src/main/java/com/datatorrent/stram/engine/package-info.java index e7c1d6e..fdad92f 100644 --- a/engine/src/main/java/com/datatorrent/stram/engine/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/engine/package-info.java @@ -1,47 +1,47 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * Execution layer for data operators, tuple processing, serialization, streams, window boundaries etc.

- *
- *
- * The streaming platform would take care of the following for you
(TBD, add "How it will")
- * - Standard partitioning (round robin, sticky key). You can add your own partitioning.
- * - End of window statistics collection in terms of number of tuples, bandwidth, I/O etc
- * - Ensuring the the emitted tuple reaches the downstream operators
- * - Queueing tuples and retaining them till all future downstream operators have consumed it
- *
- *
- * There are pre-defined library operators that you can use: see ...
- * Examples are in the following packages
-

    -
  • Algorithmic: A set of algorithmic operators
    • -
  • Input-Output: A set of operators for Input-Output from Hadoop. Consists of adapters to various message buses
    • -
  • Log Collection: A set of operators for log collection
    • -
  • Arithmetic: A set of arithmetic operators
    • -
  • Stream: A set of operators for stream operations
    • -
  • Testbench: A set of operators for testing your dag, operators
    • -
  • Utilities: A set of utility classes
    • -
- *
- * - */ - -package com.datatorrent.stram.engine; - - +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * Execution layer for data operators, tuple processing, serialization, streams, window boundaries etc.

+ *
+ *
+ * The streaming platform would take care of the following for you
(TBD, add "How it will")
+ * - Standard partitioning (round robin, sticky key). You can add your own partitioning.
+ * - End of window statistics collection in terms of number of tuples, bandwidth, I/O etc
+ * - Ensuring the the emitted tuple reaches the downstream operators
+ * - Queueing tuples and retaining them till all future downstream operators have consumed it
+ *
+ *
+ * There are pre-defined library operators that you can use: see ...
+ * Examples are in the following packages
+

    +
  • Algorithmic: A set of algorithmic operators
    • +
  • Input-Output: A set of operators for Input-Output from Hadoop. Consists of adapters to various message buses
    • +
  • Log Collection: A set of operators for log collection
    • +
  • Arithmetic: A set of arithmetic operators
    • +
  • Stream: A set of operators for stream operations
    • +
  • Testbench: A set of operators for testing your dag, operators
    • +
  • Utilities: A set of utility classes
    • +
+ *
+ * + */ + +package com.datatorrent.stram.engine; + + http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/package-info.java b/engine/src/main/java/com/datatorrent/stram/package-info.java index 3e23940..eb337d6 100644 --- a/engine/src/main/java/com/datatorrent/stram/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/package-info.java @@ -1,27 +1,27 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * com.datatorrent.stram package contains all code for streaming application master

- *
- * The application master is also called STRAM
- * (TBD - To explain all functionality)
- * - */ - -package com.datatorrent.stram; +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * com.datatorrent.stram package contains all code for streaming application master

+ *
+ * The application master is also called STRAM
+ * (TBD - To explain all functionality)
+ * + */ + +package com.datatorrent.stram; http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/stream/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/stream/package-info.java b/engine/src/main/java/com/datatorrent/stram/stream/package-info.java index e83d345..58fd326 100644 --- a/engine/src/main/java/com/datatorrent/stram/stream/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/stream/package-info.java @@ -1,68 +1,68 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * - * com.datatorrent.stream package contains all code related to various implementations of Stream interface

- *
- * A stream is a logical unit of a dag that defines the connection between - * a node and list of listener operators. Stream has the following properties in Malhar's streaming platform
- * - One writer node
- * - Any number of listener operators
- * - Context as defined by the properties specified in the dag
- * A stream definition in the dag is a logical definition. Multiple logical listerner operators means that the emitted tuple - * would reach each of them. Partitioning is done when a single - * logical listener node partitions into multilpe physical operators. This may happen due to initial user - * specification, or dynamic run time constraint enforcement. In such a scenerio the logical stream gets partitioned - * into physical streams. Each physical stream would retain the - * characteristics of the logical node (one writer, multiple readers, and context).
- *
- * The streams included in com.datatorrent.stream include
- *
- *
Buffer Server Streams
- * {@link com.datatorrent.stream.BufferServerInputStream}: extends {@link com.datatorrent.stream.SocketInputStream}, - * takes data from buffer server into the node. Every logical stream will have at least two such - * objects ({@link com.datatorrent.stream.BufferServerInputStream} - * and {@link com.datatorrent.stream.BufferServerOutputStream}). If the logical stream gets partitioned - * into physical streams then each of these physical streams will have these objects. Inlined version of - * a logical stream does not go through the buffer server and hence would not have - * {@link com.datatorrent.stream.BufferServerInputStream} and {@link com.datatorrent.stream.BufferServerOutputStream} objects
- * {@link com.datatorrent.stream.BufferServerOutputStream}: extends {@link com.datatorrent.stream.SocketOutputStream} - * and in conjunction with {@link com.datatorrent.stream.BufferServerInputStream} forms a complete stream - * in a node->buffer server->node path
- *
Inline Stream (Within a Hadoop Container)
- * {@link com.datatorrent.stream.InlineStream}: Streams data between two operators in inline mode. This implementation of - * {@link com.datatorrent.engine.Stream} and {{@link com.datatorrent.api.Sink} - * interface does not have connection to BufferServer and cannot be persisted.
- * - * {@link com.datatorrent.stream.MuxStream}:
- * {@link com.datatorrent.stream.PartitionAwareSink}:
- * - *
Socket Interface Streams
- * {@link com.datatorrent.stream.SocketInputStream}: Implements {@link com.datatorrent.engine.Stream} interface and provides - * basic stream connection for a node to read from a socket. Users can use this class if they want to directly connect to - * a outside socket
- * {@link com.datatorrent.stream.SocketOutputStream}: Implements {@link com.datatorrent.engine.Stream} interface and provides - * basic stream connection for a node to write to a socket. Most likely users would not use it to write to a socket by themselves. - * Would be used in adapters and via {@link com.datatorrent.stream.BufferServerOutputStream}
- *
- * - */ - -package com.datatorrent.stram.stream; - +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * + * com.datatorrent.stream package contains all code related to various implementations of Stream interface

+ *
+ * A stream is a logical unit of a dag that defines the connection between + * a node and list of listener operators. Stream has the following properties in Malhar's streaming platform
+ * - One writer node
+ * - Any number of listener operators
+ * - Context as defined by the properties specified in the dag
+ * A stream definition in the dag is a logical definition. Multiple logical listerner operators means that the emitted tuple + * would reach each of them. Partitioning is done when a single + * logical listener node partitions into multilpe physical operators. This may happen due to initial user + * specification, or dynamic run time constraint enforcement. In such a scenerio the logical stream gets partitioned + * into physical streams. Each physical stream would retain the + * characteristics of the logical node (one writer, multiple readers, and context).
+ *
+ * The streams included in com.datatorrent.stream include
+ *
+ *
Buffer Server Streams
+ * {@link com.datatorrent.stream.BufferServerInputStream}: extends {@link com.datatorrent.stream.SocketInputStream}, + * takes data from buffer server into the node. Every logical stream will have at least two such + * objects ({@link com.datatorrent.stream.BufferServerInputStream} + * and {@link com.datatorrent.stream.BufferServerOutputStream}). If the logical stream gets partitioned + * into physical streams then each of these physical streams will have these objects. Inlined version of + * a logical stream does not go through the buffer server and hence would not have + * {@link com.datatorrent.stream.BufferServerInputStream} and {@link com.datatorrent.stream.BufferServerOutputStream} objects
+ * {@link com.datatorrent.stream.BufferServerOutputStream}: extends {@link com.datatorrent.stream.SocketOutputStream} + * and in conjunction with {@link com.datatorrent.stream.BufferServerInputStream} forms a complete stream + * in a node->buffer server->node path
+ *
Inline Stream (Within a Hadoop Container)
+ * {@link com.datatorrent.stream.InlineStream}: Streams data between two operators in inline mode. This implementation of + * {@link com.datatorrent.engine.Stream} and {{@link com.datatorrent.api.Sink} + * interface does not have connection to BufferServer and cannot be persisted.
+ * + * {@link com.datatorrent.stream.MuxStream}:
+ * {@link com.datatorrent.stream.PartitionAwareSink}:
+ * + *
Socket Interface Streams
+ * {@link com.datatorrent.stream.SocketInputStream}: Implements {@link com.datatorrent.engine.Stream} interface and provides + * basic stream connection for a node to read from a socket. Users can use this class if they want to directly connect to + * a outside socket
+ * {@link com.datatorrent.stream.SocketOutputStream}: Implements {@link com.datatorrent.engine.Stream} interface and provides + * basic stream connection for a node to write to a socket. Most likely users would not use it to write to a socket by themselves. + * Would be used in adapters and via {@link com.datatorrent.stream.BufferServerOutputStream}
+ *
+ * + */ + +package com.datatorrent.stram.stream; + http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/util/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/util/package-info.java b/engine/src/main/java/com/datatorrent/stram/util/package-info.java index a5e1d50..200bf98 100644 --- a/engine/src/main/java/com/datatorrent/stram/util/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/util/package-info.java @@ -1,32 +1,32 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * - * com.datatorrent.util package consists of utilities classes that Malhar provides

- *
- * The current utilities include
- * {@link com.datatorrent.util.CircularBuffer}: Takes a class T and provides a circular buffer
- * {@link com.datatorrent.util.ScheduledExecutorService}:
- * {@link com.datatorrent.util.ScheduledThreadPoolExecutor}:
- * {@link com.datatorrent.util.StablePriorityQueue}: Implements a priority queue (Queue) and is mainly used to queue tuples
- *
- */ - -package com.datatorrent.stram.util; - +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * + * com.datatorrent.util package consists of utilities classes that Malhar provides

+ *
+ * The current utilities include
+ * {@link com.datatorrent.util.CircularBuffer}: Takes a class T and provides a circular buffer
+ * {@link com.datatorrent.util.ScheduledExecutorService}:
+ * {@link com.datatorrent.util.ScheduledThreadPoolExecutor}:
+ * {@link com.datatorrent.util.StablePriorityQueue}: Implements a priority queue (Queue) and is mainly used to queue tuples
+ *
+ */ + +package com.datatorrent.stram.util; + http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b527b301/engine/src/main/java/com/datatorrent/stram/webapp/package-info.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/package-info.java b/engine/src/main/java/com/datatorrent/stram/webapp/package-info.java index a3d18bf..947f262 100644 --- a/engine/src/main/java/com/datatorrent/stram/webapp/package-info.java +++ b/engine/src/main/java/com/datatorrent/stram/webapp/package-info.java @@ -1,38 +1,38 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * - * com.datatorrent.stram.webapp package is the web service layer of Malhar's streaming platform

- *
- * The webservices layer interacts with the streaming application master (stram). The internals of Hadoop are taken care - * off and an common set of functionality is provided for all streaming related runtime data.
- *
- * The webservices layer consists of the following data:
- * {@link com.datatorrent.stram.webapp.AppInfo}: Provides application level data like user, appId, elapsed time, etc.
- * {@link com.datatorrent.stram.webapp.OperatorInfo}: Provides data on the operator. This includes throughput, container id etc.
- * {@link com.datatorrent.stram.webapp.OperatorsInfo}: Provides data on all the operators of the data.
- * {@link com.datatorrent.stram.webapp.StramWebApp}: TBD
- * {@link com.datatorrent.stram.webapp.StramWebServices}: TBD
- * Access and Authoriation: TBD
- *
- * - */ - -package com.datatorrent.stram.webapp; - +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/** + * + * com.datatorrent.stram.webapp package is the web service layer of Malhar's streaming platform

+ *
+ * The webservices layer interacts with the streaming application master (stram). The internals of Hadoop are taken care + * off and an common set of functionality is provided for all streaming related runtime data.
+ *
+ * The webservices layer consists of the following data:
+ * {@link com.datatorrent.stram.webapp.AppInfo}: Provides application level data like user, appId, elapsed time, etc.
+ * {@link com.datatorrent.stram.webapp.OperatorInfo}: Provides data on the operator. This includes throughput, container id etc.
+ * {@link com.datatorrent.stram.webapp.OperatorsInfo}: Provides data on all the operators of the data.
+ * {@link com.datatorrent.stram.webapp.StramWebApp}: TBD
+ * {@link com.datatorrent.stram.webapp.StramWebServices}: TBD
+ * Access and Authoriation: TBD
+ *
+ * + */ + +package com.datatorrent.stram.webapp; +