Class | Description |
---|---|
UpsertTestFileUtil |
Collection uf utility methods for reading and writing files from the
UpsertTestSink . |
UpsertTestSink<IN> |
Flink Sink to upsert test data into a file.
|
UpsertTestSinkBuilder<IN> |
Builder to construct
UpsertTestSink . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.