| Class | Description |
|---|---|
| BlockingIncrementingMapFunction |
A map function that increments values by one.
|
| DataSetAllroundTestProgram |
Program to test a large chunk of DataSet API operators and primitives:
Map, FlatMap, Filter
GroupReduce, Reduce
Join
CoGroup
BulkIteration
Different key definitions (position, name, KeySelector)
|
| DataSetFineGrainedRecoveryTestProgram |
Program to test fine grained recovery.
|
| Generator |
InputFormat that generates a deterministic DataSet of Tuple2(String, Integer)
String: key, can be repeated.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.