File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -234,7 +234,7 @@ This Spark job:
234234
235235. Navigate to *Cloudera Data Engineering* and click on *Jobs* from the side panel.
236236+
237- image::../images/cde.png[tables verify ]
237+ image::../images/cde.png[cde, width=300, height=300 ]
238238+
239239. Click on *Create Job* and enter the following values:
240240+
@@ -278,9 +278,9 @@ Example files can be found in the `assets` folder:
278278* `processed_dates.txt` — keeps track of dates that have already been processed.
279279
280280Make sure both files are available in your S3 bucket before proceeding.
281- +
281+
282282image::../images/s3_files.png[Verify files in S3 bucket]
283- +
283+
284284The DAG logic:
285285
286286* Reads a file `dates_to_run.txt` from S3 containing all interaction dates.
@@ -305,7 +305,7 @@ image::../images/create_job.png[Creating jobs]
305305* `PROCESSED_FILE` → Path to your processed dates file (example: `my-data/InteractionDate/processed_dates.txt`)
306306* `SPARK_JOB_NAME` → Name of the Spark job created in Section 7.1 (example: `CallCenterSummary`)
307307+
308- image::../images/variable_values.png[tables verify ]
308+ image::../images/variable_values.png[variable values, width=700, height=300 ]
309309+
310310.. Upload the DAG file `CallCenterSummary_Dag_job.py`
311311 (available in the assets folder).
You can’t perform that action at this time.
0 commit comments