Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- dataIn.collect.map(println(_))
- gives: note 8 hello worlds 9 this is a test
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"}
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"}
- dataIn.map(x => (vectorAggregators.key(x), x)).collect.map(println(_)) gives: (checkout line 31)
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (hello world,{"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- (this is a test,{"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
- dataIn.groupBy(vectorAggregators.key).map(x => x._2).collect.map(println(_))
- gives this: note 7 hello worlds 10 this is a test
- CompactBuffer(
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "hello world"})
- CompactBuffer(
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424852578493, "isActive": true, "insertedPeriod": 123, "message": "this is a test"},
- {"memberId": 12345, "transactionTime": 1424420578493, "isActive": false, "insertedPeriod": 123, "message": "this is a test"})
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement