You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by nw...@apache.org on 2020/02/21 09:19:26 UTC
[incubator-heron] branch master updated (1c59862 -> f0b6e1b)
This is an automated email from the ASF dual-hosted git repository.
nwang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git.
from 1c59862 Update README for Java 11 (#3464)
add f0b6e1b Make log/sink/consume Streamlet component support setName and setNumPartitions (#3459)
No new revisions were added by this update.
Summary of changes:
.../examples/streamlet/StreamletCloneTopology.java | 6 +-
.../scala/ScalaClassicalMusicTopology.scala | 1 +
.../scala/ScalaIntegerProcessingTopology.scala | 2 +
.../java/org/apache/heron/streamlet/Streamlet.java | 8 +-
.../org/apache/heron/streamlet/StreamletBase.java | 60 ++++++
.../apache/heron/streamlet/impl/BuilderImpl.java | 2 +-
.../heron/streamlet/impl/StreamletBaseImpl.java | 224 +++++++++++++++++++++
.../apache/heron/streamlet/impl/StreamletImpl.java | 162 ++-------------
.../heron/streamlet/impl/StreamletShadow.java | 6 +-
.../impl/streamlets/ConsumerStreamlet.java | 3 +-
.../streamlet/impl/streamlets/LogStreamlet.java | 3 +-
.../streamlet/impl/streamlets/SinkStreamlet.java | 3 +-
.../apache/heron/streamlet/scala/Streamlet.scala | 22 +-
.../heron/streamlet/scala/StreamletBase.scala | 58 ++++++
.../streamlet/scala/impl/StreamletBaseImpl.scala | 71 +++++++
.../heron/streamlet/scala/impl/StreamletImpl.scala | 40 ++--
.../heron/streamlet/impl/StreamletImplTest.java | 10 +-
17 files changed, 472 insertions(+), 209 deletions(-)
create mode 100644 heron/api/src/java/org/apache/heron/streamlet/StreamletBase.java
create mode 100644 heron/api/src/java/org/apache/heron/streamlet/impl/StreamletBaseImpl.java
create mode 100644 heron/api/src/scala/org/apache/heron/streamlet/scala/StreamletBase.scala
create mode 100644 heron/api/src/scala/org/apache/heron/streamlet/scala/impl/StreamletBaseImpl.scala