beam-examples-parent org.apache.beam 2.2.0 4.0.0 beam-examples-java Apache Beam :: Examples :: Java Apache Beam SDK provides a simple, Java-based interface for processing virtually any size data. This artifact includes all Apache Beam Java SDK examples. org.jacoco jacoco-maven-plugin maven-failsafe-plugin integration-test verify ${skipDefaultIT} all 4 ${integrationTestPipelineOptions} false direct-runner org.apache.beam beam-runners-direct-java 2.2.0 runtime osx osx-x86_64 x86_64 apex-runner org.apache.beam beam-runners-apex runtime servlet-api javax.servlet org.apache.httpcomponents httpclient 4.3.5 runtime commons-codec commons-codec flink-runner org.apache.beam beam-runners-flink_2.10 runtime servlet-api javax.servlet spark-runner org.apache.beam beam-runners-spark runtime org.apache.beam beam-sdks-java-io-hadoop-file-system runtime org.apache.spark spark-streaming_2.10 runtime org.apache.spark spark-core_2.10 runtime jul-to-slf4j org.slf4j dataflow-runner org.apache.beam beam-runners-google-cloud-dataflow-java runtime jenkins-precommit maven-failsafe-plugin direct-runner-integration-tests integration-test verify WordCountIT.java WindowedWordCountIT.java all 4 [ "--project=apache-beam-testing", "--tempLocation=gs://temp-storage-for-end-to-end-tests", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=org.apache.beam.runners.direct.DirectRunner" ] flink-runner-integration-tests integration-test verify WordCountIT.java WindowedWordCountIT.java all 4 [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=org.apache.beam.runners.flink.TestFlinkRunner" ] spark-runner-integration-tests integration-test verify WordCountIT.java [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=org.apache.beam.runners.spark.TestSparkRunner" ] dataflow-runner-integration-tests integration-test verify WordCountIT.java WindowedWordCountIT.java all 4 [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=TestDataflowRunner" ] dataflow-runner-integration-tests-streaming integration-test verify WordCountIT.java WindowedWordCountIT.java all 4 [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=TestDataflowRunner", "--streaming=true" ] apex-runner-integration-tests integration-test verify WordCountIT.java WindowedWordCountIT.java none 4 [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=org.apache.beam.runners.apex.TestApexRunner" ] false com.esotericsoftware.kryo kryo ${apex.kryo.version} runtime true false disable-streaming-ITs maven-failsafe-plugin integration-test verify org.apache.beam.sdk.testing.StreamingIT org.apache.beam beam-sdks-java-core 2.2.0 compile org.apache.beam beam-sdks-java-extensions-google-cloud-platform-core 2.2.0 compile org.apache.beam beam-sdks-java-io-google-cloud-platform 2.2.0 compile com.google.api-client google-api-client 1.22.0 compile guava-jdk5 com.google.guava com.google.apis google-api-services-bigquery v2-rev355-1.22.0 compile guava-jdk5 com.google.guava com.google.code.findbugs jsr305 3.0.1 compile com.google.http-client google-http-client 1.22.0 compile guava-jdk5 com.google.guava com.google.cloud.bigdataoss util 1.4.5 compile com.google.auth google-auth-library-oauth2-http 0.7.1 compile guava-jdk5 com.google.guava com.google.auth google-auth-library-credentials 0.7.1 compile org.apache.avro avro 1.8.2 compile com.google.apis google-api-services-pubsub v1-rev10-1.22.0 compile guava-jdk5 com.google.guava com.google.cloud.datastore datastore-v1-proto-client 1.4.0 compile com.google.cloud.datastore datastore-v1-protos 1.3.0 compile joda-time joda-time 2.4 compile org.slf4j slf4j-api 1.7.25 compile org.slf4j slf4j-jdk14 1.7.25 runtime true org.hamcrest hamcrest-all 1.3 test junit junit 4.12 test hamcrest-core org.hamcrest org.apache.beam beam-runners-direct-java 2.2.0 runtime org.apache.beam beam-sdks-java-io-google-cloud-platform 2.2.0 tests test org.mockito mockito-all 1.9.5 test