checkpoint (baru bisa jalanin spark tapi blm bisa jalanin DAG yg ada spark nya)
Showing
- Dockerfile.temp 14 additions, 0 deletionsDockerfile.temp
- airflow/airflow-webserver.pid 1 addition, 1 deletionairflow/airflow-webserver.pid
- airflow/airflow.db 0 additions, 0 deletionsairflow/airflow.db
- airflow/dags/__pycache__/pyspark_dag.cpython-312.pyc 0 additions, 0 deletionsairflow/dags/__pycache__/pyspark_dag.cpython-312.pyc
- airflow/dags/__pycache__/pyspark_functions.cpython-312.pyc 0 additions, 0 deletionsairflow/dags/__pycache__/pyspark_functions.cpython-312.pyc
- airflow/dags/__pycache__/test_dag.cpython-312.pyc 0 additions, 0 deletionsairflow/dags/__pycache__/test_dag.cpython-312.pyc
- airflow/dags/__pycache__/welcome_dag.cpython-312.pyc 0 additions, 0 deletionsairflow/dags/__pycache__/welcome_dag.cpython-312.pyc
- airflow/dags/test_dag.py 23 additions, 0 deletionsairflow/dags/test_dag.py
- airflow/standalone_admin_password.txt 1 addition, 1 deletionairflow/standalone_admin_password.txt
- docker-compose.yml 53 additions, 4 deletionsdocker-compose.yml
- pre-process.ipynb 0 additions, 22 deletionspre-process.ipynb
- requirements.txt 2 additions, 1 deletionrequirements.txt
- workspace/input.txt 2 additions, 0 deletionsworkspace/input.txt
- workspace/wordcount.py 59 additions, 0 deletionsworkspace/wordcount.py
Please register or sign in to comment