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/04/27 03:08:51 UTC
[19/21] incubator-beam git commit: Increase visibility in PAssert and
ZipFiles utilities
Increase visibility in PAssert and ZipFiles utilities
This is needed for package reorganization in runners/google-cloud-dataflow.
Those classes will have to move away from org.apache.beam.sdk.* packages.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c08f973c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c08f973c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c08f973c
Branch: refs/heads/master
Commit: c08f973cb5585885a2da93c66716dec87670ca30
Parents: 46f7447
Author: Davor Bonaci <da...@google.com>
Authored: Mon Apr 25 14:30:25 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Tue Apr 26 17:59:39 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/testing/PAssert.java | 8 ++++----
.../src/main/java/org/apache/beam/sdk/util/ZipFiles.java | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c08f973c/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
index f328c5b..1265acd 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
@@ -98,8 +98,8 @@ public class PAssert {
private static final Logger LOG = LoggerFactory.getLogger(PAssert.class);
- static final String SUCCESS_COUNTER = "PAssertSuccess";
- static final String FAILURE_COUNTER = "PAssertFailure";
+ public static final String SUCCESS_COUNTER = "PAssertSuccess";
+ public static final String FAILURE_COUNTER = "PAssertFailure";
private static int assertCount = 0;
@@ -576,7 +576,7 @@ public class PAssert {
* <p>This is generally useful for assertion functions that
* are serializable but whose underlying data may not have a coder.
*/
- static class OneSideInputAssert<ActualT>
+ public static class OneSideInputAssert<ActualT>
extends PTransform<PBegin, PDone> implements Serializable {
private final transient PTransform<PBegin, PCollectionView<ActualT>> createActual;
private final SerializableFunction<ActualT, Void> checkerFn;
@@ -647,7 +647,7 @@ public class PAssert {
* are not serializable, but have coders (provided
* by the underlying {@link PCollection}s).
*/
- static class TwoSideInputAssert<ActualT, ExpectedT>
+ public static class TwoSideInputAssert<ActualT, ExpectedT>
extends PTransform<PBegin, PDone> implements Serializable {
private final transient PTransform<PBegin, PCollectionView<ActualT>> createActual;
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c08f973c/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java
index 6d73027..038b9cb 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java
@@ -226,7 +226,7 @@ public final class ZipFiles {
* @throws IOException the zipping failed, e.g. because the input was not
* readable.
*/
- static void zipDirectory(
+ public static void zipDirectory(
File sourceDirectory,
OutputStream outputStream) throws IOException {
checkNotNull(sourceDirectory);