wantTenFields: `3389224,2,2014-03-26 00:26:15,2014-03-26 00:28:38,N,1,-73.950431823730469,40.792251586914063,-73.938949584960937,40.794425964355469,1,0.84,4.5,0.5,0.5,1,0,,,6.5,1,1,75,74,green,0.00,0.0,0.0,36,24,11.86,1267,168,1,M...

    examples/jars/spark-examples*.jar 10
```

The job should produce an output as shown below. Note the value of pi in the output.

```
17/03/22 23:21:10 INFO DAGScheduler: Job 0 finished: reduce at SparkPi.scala:38, took 1.302805 s
Pi is roughly 3.1445191445191445
```

Job status can also be viewed in a browser by navigating to the YARN ResourceManager Web UI and clicking on job history server information.

### **4.2 WordCount**

	_ = x[ErrMissingSecurityHeader-33]
	_ = x[ErrNoSuchBucket-34]
	_ = x[ErrNoSuchBucketPolicy-35]
	_ = x[ErrNoSuchBucketLifecycle-36]
	_ = x[ErrNoSuchLifecycleConfiguration-37]
	_ = x[ErrInvalidLifecycleWithObjectLock-38]
	_ = x[ErrNoSuchBucketSSEConfig-39]
	_ = x[ErrNoSuchCORSConfiguration-40]
	_ = x[ErrNoSuchWebsiteConfiguration-41]
	_ = x[ErrReplicationConfigurationNotFoundError-42]
	_ = x[ErrRemoteDestinationNotFoundError-43]

IfNotPresent imagePullSecrets: [] # - name: "image-pull-secret" ## Set default image, imageTag, and imagePullPolicy for the `mc` (the minio ## client used to create a default bucket). ## mcImage: repository: quay.io/minio/mc tag: RELEASE.2021-12-16T23-38-39Z pullPolicy: IfNotPresent ## minio mode, i.e. standalone or distributed or gateway. mode: distributed ## other supported values are "standalone", "gateway" ## Additional labels to include with deployment or statefulset additionalLabels: [] ## Additional...

          "logBase": 1,
          "show": false
        }
      ],
      "yaxis": {
        "align": false
      }
    }
  ],
  "refresh": "",
  "schemaVersion": 38,
  "style": "dark",
  "tags": [
    "minio"
  ],
  "templating": {
    "list": [
      {
        "current": {},
        "datasource": {
          "type": "prometheus",

```

## Publish MinIO events MQTT

Install an MQTT Broker from [here](https://mosquitto.org/).

### Step 1: Add MQTT endpoint to MinIO

          "logBase": 1,
          "show": false
        }
      ],
      "yaxis": {
        "align": false
      }
    }
  ],
  "refresh": "",
  "schemaVersion": 38,
  "style": "dark",
  "tags": [
    "minio"
  ],
  "templating": {
    "list": [
      {
        "current": {},
        "datasource": {
          "type": "prometheus",

	_ = x[DeleteType-2]
	_ = x[LegacyType-3]
	_ = x[lastVersionType-4]
}

const _VersionType_name = "invalidVersionTypeObjectTypeDeleteTypeLegacyTypelastVersionType"

var _VersionType_index = [...]uint8{0, 18, 28, 38, 48, 63}

func (i VersionType) String() string {
	if i >= VersionType(len(_VersionType_index)-1) {
		return "VersionType(" + strconv.FormatInt(int64(i), 10) + ")"
	}

Elmhurst-Maspeth 4109 536 10 4 Queens 001000 4001000 I QN53 Woodhaven 4111 3389427 2 2014-03-31 00:38:15 2014-03-31 00:41:38 N 1 -73.891403198242188 40.746574401855469 -73.894004821777344 40.739082336425781 1 0.74 4.5 0.5 0.5 0 0 5.5 2 1 83 83 green 0.16 0.0 0.0 56 36 8.28 1294 265 4 Queens 026500 4026500 E QN50 Elmhurst-Maspeth 4109 670 489 4 Queens 048900 4048900 E QN50 Elmhurst-Maspeth 4109 3389428 1 2014-03-23 02:38:39 2014-03-23 02:50:26 N 1 -73.892295837402344 40.747013092041016 -73.850883483886719 40.74090576171875...

	_ = x[HandlerLoadPolicy-32]
	_ = x[HandlerLoadPolicyMapping-33]
	_ = x[HandlerDeleteServiceAccount-34]
	_ = x[HandlerLoadServiceAccount-35]
	_ = x[HandlerDeleteUser-36]
	_ = x[HandlerLoadUser-37]
	_ = x[HandlerLoadGroup-38]
	_ = x[HandlerHealBucket-39]
	_ = x[HandlerMakeBucket-40]
	_ = x[HandlerHeadBucket-41]
	_ = x[HandlerDeleteBucket-42]
	_ = x[HandlerGetMetrics-43]
	_ = x[HandlerGetResourceMetrics-44]
	_ = x[HandlerGetMemInfo-45]