Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub / PacktPublishing / Building-Big-Data-Pipelines-with-Apache-Beam
Building Big Data Pipelines with Apache Beam, published by Packt
Stars: 75
Forks: 57
Open Issues: 9
License: apache-2.0
Language: Java
Repo Size: 543 KB
Dependencies:
106
Created: over 3 years ago
Updated: about 2 months ago
Last pushed: about 1 year ago
Last synced: about 2 months ago
Files
Loading...
Readme
Loading...
Dependencies
chapter1/pom.xml
maven
chapter2/pom.xml
maven
- com.packtpub.beam:beam-util
- org.apache.beam:beam-runners-direct-java
- org.apache.beam:beam-runners-flink-1.13
- org.apache.beam:beam-sdks-java-core
- org.apache.beam:beam-sdks-java-io-kafka
- org.apache.flink:flink-streaming-java_2.12
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest
- org.junit.jupiter:junit-jupiter-api
- org.projectlombok:lombok
- org.slf4j:slf4j-log4j12
chapter3/pom.xml
maven
- com.packtpub.beam:beam-util
- javax.annotation:javax.annotation-api
- org.apache.beam:beam-runners-direct-java
- org.apache.beam:beam-runners-flink-1.13
- org.apache.beam:beam-sdks-java-core
- org.apache.beam:beam-sdks-java-io-kafka
- org.apache.flink:flink-streaming-java_2.12
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest
- org.junit.jupiter:junit-jupiter-api
- org.projectlombok:lombok
- org.slf4j:slf4j-log4j12
chapter4/pom.xml
maven
- com.packtpub.beam:beam-util
- javax.annotation:javax.annotation-api
- org.apache.beam:beam-runners-direct-java
- org.apache.beam:beam-runners-flink-1.13
- org.apache.beam:beam-sdks-java-core
- org.apache.beam:beam-sdks-java-extensions-join-library
- org.apache.beam:beam-sdks-java-io-kafka
- org.apache.flink:flink-streaming-java_2.12
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest
- org.junit.jupiter:junit-jupiter-api
- org.projectlombok:lombok
- org.slf4j:slf4j-log4j12
chapter5/pom.xml
maven
- com.packtpub.beam:beam-util
- javax.annotation:javax.annotation-api
- org.apache.beam:beam-runners-direct-java
- org.apache.beam:beam-runners-flink-1.13
- org.apache.beam:beam-sdks-java-core
- org.apache.beam:beam-sdks-java-extensions-sql
- org.apache.beam:beam-sdks-java-io-kafka
- org.apache.flink:flink-streaming-java_2.12
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest
- org.junit.jupiter:junit-jupiter-api
- org.projectlombok:lombok
- org.slf4j:slf4j-log4j12
chapter6/pom.xml
maven
- org.apache.beam:beam-sdks-java-io-expansion-service ${apache.beam.version}
chapter7/pom.xml
maven
- com.packtpub.beam:beam-util
- javax.annotation:javax.annotation-api
- org.apache.beam:beam-runners-direct-java
- org.apache.beam:beam-runners-flink-1.13
- org.apache.beam:beam-sdks-java-core
- org.apache.beam:beam-sdks-java-extensions-join-library
- org.apache.beam:beam-sdks-java-io-kafka
- org.apache.flink:flink-streaming-java_2.12
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest
- org.junit.jupiter:junit-jupiter-api
- org.junit.jupiter:junit-jupiter-params
- org.projectlombok:lombok
- org.slf4j:slf4j-log4j12
pom.xml
maven
- javax.annotation:javax.annotation-api 1.3.2 provided
- org.projectlombok:lombok 1.18.18 provided
- com.google.guava:guava 30.1-jre
- com.packtpub.beam:beam-util 1.0.0
- io.grpc:grpc-all 1.33.1
- io.grpc:grpc-context 1.33.1
- org.apache.beam:beam-runners-direct-java 2.33.0
- org.apache.beam:beam-runners-flink-1.13 2.33.0
- org.apache.beam:beam-sdks-java-core 2.33.0
- org.apache.beam:beam-sdks-java-extensions-join-library 2.33.0
- org.apache.beam:beam-sdks-java-extensions-sql 2.33.0
- org.apache.beam:beam-sdks-java-io-kafka 2.33.0
- org.apache.flink:flink-streaming-java_2.12 1.13.2
- org.apache.kafka:kafka-clients 2.7.0
- org.slf4j:slf4j-log4j12 1.7.30
- org.hamcrest:hamcrest 2.2 test
- org.junit.jupiter:junit-jupiter-api 5.7.1 test
- org.junit.jupiter:junit-jupiter-params 5.7.1 test
util/pom.xml
maven
- apache-beam ==2.33.0
- grpcio ==1.40.0
- grpcio-tools ==1.40.0
- protobuf ==3.17.3
.github/workflows/maven.yaml
actions
- actions/checkout v1 composite
- actions/setup-java v1 composite
docker/Dockerfile
docker
- packt-beam-base latest build
env/docker/flink/Dockerfile
docker
- apache/beam_java11_sdk 2.33.0 build
- apache/flink 1.13.2-scala_2.12-java11 build
- apache/beam_python3.7_sdk 2.33.0 build
env/docker/kafka/Dockerfile
docker
- openjdk 11 build