public class BucketingSinkTestProgram extends Object
Contains a simple stateful job that emits into buckets per key.
The stream is bounded and will complete after about a minute. The result is always constant.
Parameters: -outputPath Sets the path to where the result data is written.
Modifier and Type | Class and Description |
---|---|
static class |
BucketingSinkTestProgram.Generator
Data-generating source function.
|
static class |
BucketingSinkTestProgram.KeyBucketer
Use first field for buckets.
|
static class |
BucketingSinkTestProgram.SubtractingMapper
Subtracts the timestamp of the previous element from the current element.
|
Constructor and Description |
---|
BucketingSinkTestProgram() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.