| Class | Description |
|---|---|
| BatchSQLTestProgram |
End-to-end test for batch SQL queries.
|
| BatchSQLTestProgram.DataGenerator |
Iterator for generated data.
|
| BatchSQLTestProgram.GeneratorTableSource |
TableSource for generated data.
|
| StreamSQLTestProgram |
End-to-end test for Stream SQL queries.
|
| StreamSQLTestProgram.Generator | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| StreamSQLTestProgram.GeneratorTableSource |
TableSource for generated data.
|
| StreamSQLTestProgram.KeyBucketAssigner |
Use first field for buckets.
|
| StreamSQLTestProgram.KillMapper |
Kills the first execution attempt of an application when it receives the second record.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.