You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/08/30 19:11:40 UTC
[5/6] beam git commit: Fixes a findbugs error in Apex runner
Fixes a findbugs error in Apex runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6590aed4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6590aed4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6590aed4
Branch: refs/heads/master
Commit: 6590aed4091a1fbff75311afc45c3d3df1b80d38
Parents: f1f3987
Author: Eugene Kirpichov <ek...@gmail.com>
Authored: Wed Aug 16 17:50:25 2017 -0700
Committer: Eugene Kirpichov <ek...@gmail.com>
Committed: Wed Aug 30 11:55:19 2017 -0700
----------------------------------------------------------------------
.../beam/runners/apex/translation/utils/ApexStateInternals.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/6590aed4/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStateInternals.java
----------------------------------------------------------------------
diff --git a/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStateInternals.java b/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStateInternals.java
index 18ea8e4..e23601d 100644
--- a/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStateInternals.java
+++ b/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStateInternals.java
@@ -431,7 +431,7 @@ public class ApexStateInternals<K> implements StateInternals {
/**
* Serializable state for internals (namespace to state tag to coded value).
*/
- private Map<Slice, Table<String, String, byte[]>> perKeyState = new HashMap<>();
+ private Map<Slice, HashBasedTable<String, String, byte[]>> perKeyState = new HashMap<>();
private final Coder<K> keyCoder;
private ApexStateInternalsFactory(Coder<K> keyCoder) {
@@ -451,7 +451,7 @@ public class ApexStateInternals<K> implements StateInternals {
} catch (CoderException e) {
throw new RuntimeException(e);
}
- Table<String, String, byte[]> stateTable = perKeyState.get(keyBytes);
+ HashBasedTable<String, String, byte[]> stateTable = perKeyState.get(keyBytes);
if (stateTable == null) {
stateTable = HashBasedTable.create();
perKeyState.put(keyBytes, stateTable);