How can I explore a stream in Flink interactively? Spark has the concept of take/head to extract the first n elements of a dataframe / table.
Is something similar available in Flink for a stream like:
val serializer = new JSONKeyValueDeserializationSchema(false)
val stream = senv.addSource(
new FlinkKafkaConsumer(
"tweets-raw-json",
serializer,
properties
).setStartFromEarliest() // TODO experiment with different start values
)
stream.head/take
does not seem to be implemented.
