This is an automated email from the ASF dual-hosted git repository.
mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git
The following commit(s) were added to refs/heads/mergebot by this push:
new 821b13b Remove extraneous type variable from StateSpec in state blog
post
new 15be8cf This closes #327
821b13b is described below
commit 821b13b2eb610e13ebe08c6268948f168c9ed41f
Author: Kenneth Knowles <k...@google.com>
AuthorDate: Wed Sep 27 09:59:59 2017 -0700
Remove extraneous type variable from StateSpec in state blog post
---
src/_posts/2017-02-13-stateful-processing.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/_posts/2017-02-13-stateful-processing.md
b/src/_posts/2017-02-13-stateful-processing.md
index fbbe76b..e8e2d41 100644
--- a/src/_posts/2017-02-13-stateful-processing.md
+++ b/src/_posts/2017-02-13-stateful-processing.md
@@ -265,7 +265,7 @@ new DoFn<KV<MyKey, MyValue>, KV<Integer, KV<MyKey,
MyValue>>>() {
// A state cell holding a single Integer per key+window
@StateId("index")
- private final StateSpec<Object, ValueState<Integer>> indexSpec =
+ private final StateSpec<ValueState<Integer>> indexSpec =
StateSpecs.value(VarIntCoder.of());
@ProcessElement
@@ -456,11 +456,11 @@ only features I have already introduced:
new DoFn<KV<UserId, Event>, KV<UserId, Prediction>>() {
@StateId("model")
- private final StateSpec<Object, ValueState<Model>> modelSpec =
+ private final StateSpec<ValueState<Model>> modelSpec =
StateSpecs.value(Model.coder());
@StateId("previousPrediction")
- private final StateSpec<Object, ValueState<Prediction>>
previousPredictionSpec =
+ private final StateSpec<ValueState<Prediction>> previousPredictionSpec =
StateSpecs.value(Prediction.coder());
@ProcessElement
--
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <commits@beam.apache.org>'].
