4.0.0 org.apache.beam beam-examples-parent 0.6.0 ../pom.xml 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. jar 1.6.2 direct-runner true org.apache.beam beam-runners-direct-java runtime apex-runner org.apache.beam beam-runners-apex runtime org.apache.httpcomponents httpclient 4.3.5 runtime commons-codec commons-codec flink-runner org.apache.beam beam-runners-flink_2.10 runtime spark-runner org.apache.beam beam-runners-spark runtime org.apache.spark spark-streaming_2.10 ${spark.version} runtime org.apache.spark spark-core_2.10 ${spark.version} runtime org.slf4j jul-to-slf4j dataflow-runner org.apache.beam beam-runners-google-cloud-dataflow-java runtime jenkins-precommit false true com.esotericsoftware.kryo kryo ${apex.kryo.version} runtime org.apache.maven.plugins maven-failsafe-plugin false 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 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=org.apache.beam.runners.dataflow.testing.TestDataflowRunner" ] apex-runner-integration-tests integration-test verify WordCountIT.java all 4 [ "--project=apache-beam-testing", "--tempRoot=gs://temp-storage-for-end-to-end-tests", "--runner=org.apache.beam.runners.apex.TestApexRunner" ] disable-streaming-ITs false org.apache.maven.plugins maven-failsafe-plugin integration-test verify org.apache.beam.sdk.testing.StreamingIT org.codehaus.mojo findbugs-maven-plugin true maven-compiler-plugin org.apache.maven.plugins maven-surefire-plugin org.apache.maven.plugins maven-shade-plugin package shade ${project.artifactId}-bundled-${project.version} *:* *:* META-INF/*.SF META-INF/*.DSA META-INF/*.RSA org.apache.maven.plugins maven-jar-plugin org.jacoco jacoco-maven-plugin org.apache.maven.plugins maven-failsafe-plugin false integration-test verify ${skipDefaultIT} all 4 ${integrationTestPipelineOptions} org.apache.beam beam-sdks-java-core org.apache.beam beam-sdks-java-io-google-cloud-platform com.google.api-client google-api-client com.google.apis google-api-services-bigquery com.google.http-client google-http-client org.apache.avro avro com.google.apis google-api-services-pubsub com.google.guava guava com.google.cloud.datastore datastore-v1-proto-client com.google.cloud.datastore datastore-v1-protos joda-time joda-time org.slf4j slf4j-api org.slf4j slf4j-jdk14 runtime true org.hamcrest hamcrest-all junit junit org.apache.beam beam-runners-direct-java test org.mockito mockito-all test