io.flinkspector.datastream
io.flinkspector.datastream.functions
io.flinkspector.datastream.input
io.flinkspector.datastream.input.time