You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/01/25 00:29:29 UTC
[21/50] storm git commit: update package names in javadoc
update package names in javadoc
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0411ddd0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0411ddd0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0411ddd0
Branch: refs/heads/1.x-branch
Commit: 0411ddd07808ea735358717eb37dd4d74cd5cc1c
Parents: ad75f19
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Jan 20 12:25:35 2016 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Jan 20 12:25:35 2016 -0500
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/trident/Stream.java | 2 +-
.../jvm/org/apache/storm/trident/operation/Assembly.java | 8 ++++----
.../org/apache/storm/trident/operation/BaseOperation.java | 2 +-
.../src/jvm/org/apache/storm/trident/operation/Filter.java | 6 +++---
.../jvm/org/apache/storm/trident/operation/Function.java | 9 +++++----
.../jvm/org/apache/storm/trident/operation/Operation.java | 2 +-
.../apache/storm/trident/operation/TridentCollector.java | 6 +++---
.../org/apache/storm/trident/operation/builtin/FirstN.java | 2 +-
8 files changed, 19 insertions(+), 18 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/Stream.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/Stream.java b/storm-core/src/jvm/org/apache/storm/trident/Stream.java
index c680828..50b3c59 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/Stream.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/Stream.java
@@ -234,7 +234,7 @@ public class Stream implements IAggregatableStream {
* ## Repartitioning Operation
*
* This method takes in a custom partitioning function that implements
- * {@link backtype.storm.grouping.CustomStreamGrouping}
+ * {@link org.apache.storm.grouping.CustomStreamGrouping}
*
* @param grouping
* @return
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/Assembly.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/Assembly.java b/storm-core/src/jvm/org/apache/storm/trident/operation/Assembly.java
index a09c86f..c74a968 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/Assembly.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/Assembly.java
@@ -21,7 +21,7 @@ import org.apache.storm.trident.Stream;
/**
- * The `Assembly` interface provides a means to encapsulate logic applied to a {@link storm.trident.Stream}.
+ * The `Assembly` interface provides a means to encapsulate logic applied to a {@link org.apache.storm.trident.Stream}.
*
* Usage:
*
@@ -30,13 +30,13 @@ import org.apache.storm.trident.Stream;
* Stream assemblyStream = mystream.applyAssembly(myAssembly);
* ```
*
- * @see storm.trident.Stream
- * @see storm.trident.operation.builtin.FirstN
+ * @see org.apache.storm.trident.Stream
+ * @see org.apache.storm.trident.operation.builtin.FirstN
*
*/
public interface Assembly {
/**
- * Applies the `Assembly` to a given {@link storm.trident.Stream}
+ * Applies the `Assembly` to a given {@link org.apache.storm.trident.Stream}
*
* @param input
* @return
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/BaseOperation.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/BaseOperation.java b/storm-core/src/jvm/org/apache/storm/trident/operation/BaseOperation.java
index f900955..f1cf809 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/BaseOperation.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/BaseOperation.java
@@ -20,7 +20,7 @@ package org.apache.storm.trident.operation;
import java.util.Map;
/**
- * Convenience implementation of the {@link storm.trident.operation.Operation} interface.
+ * Convenience implementation of the {@link org.apache.storm.trident.operation.Operation} interface.
*
* Provides no-op implementations of the `prepare()` and `cleanup()` methods.
*/
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/Filter.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/Filter.java b/storm-core/src/jvm/org/apache/storm/trident/operation/Filter.java
index d971cef..7673ca2 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/Filter.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/Filter.java
@@ -29,12 +29,12 @@ import java.util.Map;
*
* ### Configuration
* If your `Filter` implementation has configuration requirements, you will typically want to extend
- * {@link storm.trident.operation.BaseFilter} and override the
- * {@link storm.trident.operation.Operation#prepare(Map, TridentOperationContext)} method to perform your custom
+ * {@link org.apache.storm.trident.operation.BaseFilter} and override the
+ * {@link org.apache.storm.trident.operation.Operation#prepare(Map, TridentOperationContext)} method to perform your custom
* initialization.
*
- * @see storm.trident.Stream
+ * @see org.apache.storm.trident.Stream
*/
public interface Filter extends EachOperation {
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/Function.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/Function.java b/storm-core/src/jvm/org/apache/storm/trident/operation/Function.java
index 110a7df..b33a440 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/Function.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/Function.java
@@ -68,15 +68,16 @@ import java.util.Map;
*
* ### Configuration
* If your `Function` implementation has configuration requirements, you will typically want to extend
- * {@link storm.trident.operation.BaseFunction} and override the
- * {@link storm.trident.operation.Operation#prepare(Map, TridentOperationContext)} method to perform your custom
+ * {@link org.apache.storm.trident.operation.BaseFunction} and override the
+ * {@link org.apache.storm.trident.operation.Operation#prepare(Map, TridentOperationContext)} method to perform your custom
* initialization.
*
* ### Performance Considerations
* Because Trident Functions perform logic on individual tuples -- as opposed to batches -- it is advisable
* to avoid expensive operations such as database operations in a Function, if possible. For data store interactions
- * it is better to use a {@link storm.trident.state.State} or {@link storm.trident.state.QueryFunction} implementation
- * since Trident states operate on batch partitions and can perform bulk updates to a database.
+ * it is better to use a {@link org.apache.storm.trident.state.State} or
+ * {@link org.apache.storm.trident.state.QueryFunction} implementation since Trident states operate on batch partitions
+ * and can perform bulk updates to a database.
*
*
*/
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/Operation.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/Operation.java b/storm-core/src/jvm/org/apache/storm/trident/operation/Operation.java
index 3318273..3c87fe9 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/Operation.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/Operation.java
@@ -34,7 +34,7 @@ public interface Operation extends Serializable {
* @param context the operation context which provides information such as the number of partitions in the stream,
* and the current partition index. It also provides methods for registering operation-specific
* metrics.
- * @see storm.trident.operation.TridentOperationContext
+ * @see org.apache.storm.trident.operation.TridentOperationContext
*/
void prepare(Map conf, TridentOperationContext context);
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/TridentCollector.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/TridentCollector.java b/storm-core/src/jvm/org/apache/storm/trident/operation/TridentCollector.java
index 4989e35..7392c9c 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/TridentCollector.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/TridentCollector.java
@@ -31,8 +31,8 @@ import java.util.List;
* ```java
* collector.emit(new Values("a", "b", "c"));
* ```
- * @see storm.trident.Stream
- * @see backtype.storm.tuple.Values
+ * @see org.apache.storm.trident.Stream
+ * @see org.apache.storm.tuple.Values
*/
public interface TridentCollector {
/**
@@ -45,7 +45,7 @@ public interface TridentCollector {
* Reports an error. The corresponding stack trace will be visible in the Storm UI.
*
* Note that calling this method does not alter the processing of a batch. To explicitly fail a batch and trigger
- * a replay, components should throw {@link backtype.storm.topology.FailedException}.
+ * a replay, components should throw {@link org.apache.storm.topology.FailedException}.
* @param t The instance of the error (Throwable) being reported.
*/
void reportError(Throwable t);
http://git-wip-us.apache.org/repos/asf/storm/blob/0411ddd0/storm-core/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java b/storm-core/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java
index e361b41..5db6f9d 100644
--- a/storm-core/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java
+++ b/storm-core/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java
@@ -30,7 +30,7 @@ import org.apache.storm.trident.tuple.TridentTuple;
/**
*
- * An {@link storm.trident.operation.Assembly} implementation
+ * An {@link org.apache.storm.trident.operation.Assembly} implementation
*
*/
public class FirstN implements Assembly {