Skip to content

Instantly share code, notes, and snippets.

@garystafford
Last active September 8, 2021 18:35
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save garystafford/e27e28ebb4cfa0b13d644f114a4f499d to your computer and use it in GitHub Desktop.
Save garystafford/e27e28ebb4cfa0b13d644f114a4f499d to your computer and use it in GitHub Desktop.
"sources" : [ {
"description" : "KafkaV2[Subscribe[pagila.sales.spark.streaming]]",
"startOffset" : {
"pagila.sales.spark.streaming" : {
"0" : 1986
}
},
"endOffset" : {
"pagila.sales.spark.streaming" : {
"0" : 2050
}
},
"numInputRows" : 64,
"inputRowsPerSecond" : 1.0666666666666667,
"processedRowsPerSecond" : 13.772326231977619
} ],
"sink" : {
"description" : "org.apache.spark.sql.execution.streaming.ConsoleTable$@13b8bba3",
"numOutputRows" : 105
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment