You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/07/11 19:41:43 UTC
[1/2] incubator-beam git commit: StateTable: simplify with
HashBasedTable.create()
Repository: incubator-beam
Updated Branches:
refs/heads/master 77d928210 -> 1c5858b86
StateTable: simplify with HashBasedTable.create()
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/59f7e3dd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/59f7e3dd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/59f7e3dd
Branch: refs/heads/master
Commit: 59f7e3ddee1887e046ab3dbc4f3cf469c4ba36d9
Parents: 77d9282
Author: Dan Halperin <dh...@google.com>
Authored: Mon Jul 11 10:03:29 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Jul 11 10:03:29 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/util/state/StateTable.java | 12 ++----------
1 file changed, 2 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/59f7e3dd/sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateTable.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateTable.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateTable.java
index 650ebb0..2ae6516 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateTable.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateTable.java
@@ -19,11 +19,9 @@ package org.apache.beam.sdk.util.state;
import org.apache.beam.sdk.util.state.StateTag.StateBinder;
-import com.google.common.base.Supplier;
+import com.google.common.collect.HashBasedTable;
import com.google.common.collect.Table;
-import com.google.common.collect.Tables;
-import java.util.HashMap;
import java.util.Map;
import java.util.Set;
@@ -33,13 +31,7 @@ import java.util.Set;
public abstract class StateTable<K> {
private final Table<StateNamespace, StateTag<? super K, ?>, State> stateTable =
- Tables.newCustomTable(new HashMap<StateNamespace, Map<StateTag<? super K, ?>, State>>(),
- new Supplier<Map<StateTag<? super K, ?>, State>>() {
- @Override
- public Map<StateTag<? super K, ?>, State> get() {
- return new HashMap<>();
- }
- });
+ HashBasedTable.create();
/**
* Gets the {@link State} in the specified {@link StateNamespace} with the specified {@link
[2/2] incubator-beam git commit: Closes #623
Posted by dh...@apache.org.
Closes #623
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1c5858b8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1c5858b8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1c5858b8
Branch: refs/heads/master
Commit: 1c5858b8697268bea462bf13aecde8400e14728f
Parents: 77d9282 59f7e3d
Author: Dan Halperin <dh...@google.com>
Authored: Mon Jul 11 12:41:31 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Jul 11 12:41:31 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/util/state/StateTable.java | 12 ++----------
1 file changed, 2 insertions(+), 10 deletions(-)
----------------------------------------------------------------------