This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 15a3eb0 Merge pull request #10381: [BEAM-8962] Add option to disable
the metric container accumulator
add 74f20d8 [BEAM-5495] Add possibility of scanning the classpath without
URLClassLoader
add 22332f8 [BEAM-5495] Enable injecting custom resources detection
algorithms.
add 9629ff6 [BEAM-5495] Move PipelineResources to
org.apache.beam.runners.core.construction.resources package
add 5a87503 [BEAM-5495] Remove unneded and deprecated code
add 7e5a885 [BEAM-5495] Use ClassGraph to detect classpath resources
add e4a3594 Merge pull request #10268: [BEAM-5495] Adapt
PipelineResources to be compatible with Java 11
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +
runners/core-construction-java/build.gradle | 2 +
.../ClasspathScanningResourcesDetector.java | 51 ++++++++
.../{ => resources}/PipelineResources.java | 53 ++++-----
.../resources/PipelineResourcesDetector.java | 12 +-
.../PipelineResourcesDetectorAbstractFactory.java | 7 +-
.../resources/PipelineResourcesOptions.java | 77 ++++++++++++
.../{renderer => resources}/package-info.java | 2 +-
.../ClasspathScanningResourcesDetectorTest.java | 129 +++++++++++++++++++++
.../{ => resources}/PipelineResourcesTest.java | 60 +++++-----
.../apache/beam/runners/flink/FlinkJobInvoker.java | 5 +-
.../flink/FlinkPipelineExecutionEnvironment.java | 2 +-
.../beam/runners/flink/FlinkPipelineRunner.java | 5 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 4 +-
.../beam/runners/dataflow/DataflowRunner.java | 6 +-
.../jobsubmission/PortablePipelineJarCreator.java | 10 +-
.../beam/runners/portability/PortableRunner.java | 5 +-
.../beam/runners/spark/SparkPipelineOptions.java | 2 +-
.../beam/runners/spark/SparkPipelineRunner.java | 5 +-
.../org/apache/beam/runners/spark/SparkRunner.java | 4 +-
.../SparkStructuredStreamingRunner.java | 5 +-
.../translation/PipelineTranslator.java | 2 +-
22 files changed, 355 insertions(+), 95 deletions(-)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/ClasspathScanningResourcesDetector.java
rename
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/{
=> resources}/PipelineResources.java (74%)
copy
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkPolicy.java
=>
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesDetector.java
(74%)
copy learning/katas/java/IO/Built-in IOs/Built-in
IOs/test/org/apache/beam/learning/katas/io/builtinios/TaskTest.java =>
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesDetectorAbstractFactory.java
(77%)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesOptions.java
copy
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/{renderer
=> resources}/package-info.java (93%)
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/resources/ClasspathScanningResourcesDetectorTest.java
rename
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/{
=> resources}/PipelineResourcesTest.java (65%)
