This is an automated email from the ASF dual-hosted git repository.
damondouglas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from ac423af5699 Pass-through IcebergIO catalog properties (#31726)
add 631d40d0e79 Stage PrismRunner implementation and dependencies (#31794)
No new revisions were added by this update.
Summary of changes:
runners/prism/build.gradle | 1 +
.../sbe => runners/prism/java}/build.gradle | 24 ++++--
.../beam/runners/prism/PrismPipelineOptions.java | 44 +++++++++++
.../org/apache/beam/runners/prism/PrismRunner.java | 86 ++++++++++++++++++++++
.../apache/beam/runners/prism}/package-info.java | 4 +-
.../apache/beam/runners/prism/PrismRunnerTest.java | 86 ++++++++++++++++++++++
settings.gradle.kts | 1 +
7 files changed, 236 insertions(+), 10 deletions(-)
copy {sdks/java/extensions/sbe => runners/prism/java}/build.gradle (68%)
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismPipelineOptions.java
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismRunner.java
copy
{examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot
=>
runners/prism/java/src/main/java/org/apache/beam/runners/prism}/package-info.java
(90%)
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismRunnerTest.java