kramasamy closed pull request #2930: Clean up remaining dead references to
Twitter
URL: https://github.com/apache/incubator-heron/pull/2930
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/scripts/release/release.sh b/scripts/release/release.sh
index a2a9981e2d..63f868c897 100755
--- a/scripts/release/release.sh
+++ b/scripts/release/release.sh
@@ -19,10 +19,10 @@
set -eu
# Repositories to push the release branch and the release tag.
-: ${RELEASE_REPOSITORIES:="[email protected]:twitter/heron"}
+: ${RELEASE_REPOSITORIES:="[email protected]:apache/incubator-heron"}
# Repositories to push the master branch
-: ${MASTER_REPOSITORIES:="[email protected]:twitter/heron"}
+: ${MASTER_REPOSITORIES:="[email protected]:apache/incubator-heron"}
# Name of the default editor
: ${EDITOR=vi}
diff --git a/website/content/docs/developers/scala/streamlet-api.mmark
b/website/content/docs/developers/scala/streamlet-api.mmark
index 4476567a49..c031bd6ee4 100644
--- a/website/content/docs/developers/scala/streamlet-api.mmark
+++ b/website/content/docs/developers/scala/streamlet-api.mmark
@@ -17,7 +17,7 @@ In order to use the `heron-api` library, add this to the
`dependencies` block of
```xml
<dependency>
- <groupId>com.twitter.heron</groupId>
+ <groupId>org.apache.heron</groupId>
<artifactId>heron-api</artifactId>
<version>{{< heronVersion >}}</version>
</dependency>
@@ -73,8 +73,8 @@ $ heron submit local \
Every Streamlet API topology needs to be configured using a `Config` object.
Here's an example default configuration:
```scala
-import com.twitter.heron.streamlet.Config
-import com.twitter.heron.streamlet.scala.Runner
+import org.apache.heron.streamlet.Config
+import org.apache.heron.streamlet.scala.Runner
val topologyConfig = Config.defaultConfig()
@@ -230,8 +230,8 @@ The context object available to a transform operation
provides access to:
Here's a Scala example of a transform operation in a topology where a stateful
record is kept of the number of items processed:
```scala
-import com.twitter.heron.streamlet.Context
-import com.twitter.heron.streamlet.scala.SerializableTransformer
+import org.apache.heron.streamlet.Context
+import org.apache.heron.streamlet.scala.SerializableTransformer
class CountNumberOfItems extends SerializableTransformer[String, String] {
private val numberOfItems = new AtomicLong()
@@ -253,7 +253,7 @@ class CountNumberOfItems extends
SerializableTransformer[String, String] {
This operation does a few things:
-* In the `setup` method, the
[`Context`](/api/java/com/twitter/heron/streamlet/Context.html) object is used
to access the current state (which has the semantics of a Java `Map`). The
current number of items processed is incremented by one and then saved as the
new state.
+* In the `setup` method, the
[`Context`](/api/java/org/apache/heron/streamlet/Context.html) object is used
to access the current state (which has the semantics of a Java `Map`). The
current number of items processed is incremented by one and then saved as the
new state.
* In the `transform` method, the incoming string is transformed as UpperCase
in some way and then "accepted" as the new value.
* In the `cleanup` step, the current count of items processed is logged.
@@ -272,8 +272,8 @@ builder.newSource(() => "Some string over and over");
Join operations unify two streamlets *on a key* (join operations thus require
KV streamlets). Each `KeyValue` object in a streamlet has, by definition, a
key. When a `join` operation is added to a processing graph,
```scala
-import com.twitter.heron.streamlet.{Config, KeyValue, WindowConfig}
-import com.twitter.heron.streamlet.scala.Builder
+import org.apache.heron.streamlet.{Config, KeyValue, WindowConfig}
+import org.apache.heron.streamlet.scala.Builder
val builder = Builder.newBuilder()
@@ -313,7 +313,7 @@ You can apply
[reduce](https://docs.oracle.com/javase/tutorial/collections/strea
Reduce by key and window operations produce a new streamlet of key-value
window objects (which include a key-value pair including the extracted key and
calculated value, as well as information about the window in which the
operation took place). Here's an example:
```scala
-import com.twitter.heron.streamlet.WindowConfig;
+import org.apache.heron.streamlet.WindowConfig;
val builder = Builder.newBuilder()
@@ -361,8 +361,8 @@ In this example, the supplier streamlet emits random
integers between 1 and 10.
In processing graphs like the ones you build using the Heron Streamlet API,
**sinks** are essentially the terminal points in your graph, where your
processing logic comes to an end. A processing graph can end with writing to a
database, publishing to a topic in a pub-sub messaging system, and so on. With
the Streamlet API, you can implement your own custom sinks. Here's an example:
```scala
-import com.twitter.heron.streamlet.Context
-import com.twitter.heron.streamlet.scala.Sink
+import org.apache.heron.streamlet.Context
+import org.apache.heron.streamlet.scala.Sink
class FormattedLogSink extends Sink[String] {
private var streamName: Option[String] = None
@@ -405,4 +405,4 @@ val builder = Builder.newBuilder
.newSource(() => Random.nextInt(10))
.filter(i => i % 2 == 0)
.consume(i => println(s"Even number found: $i"))
-```
\ No newline at end of file
+```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
