Skip to content
This repository has been archived by the owner on Mar 7, 2018. It is now read-only.

Add granularity to sub-metrics, add overall metric #112

Merged
merged 1 commit into from
Aug 25, 2017
Merged

Conversation

c-w
Copy link
Contributor

@c-w c-w commented Aug 25, 2017

No description provided.

@@ -120,24 +122,24 @@ object CassandraEventsSink{
}

def aggregateEventBatch(eventDS: Dataset[Event], session: SparkSession, aggregator: FortisAggregator): Unit = {
val flattenedDF = Timer.time(Telemetry.logSinkPhase("flattenedDF", _, _, -1)) {
val flattenedDF = Timer.time(Telemetry.logSinkPhase(s"flattenedDF-${aggregator.FortisTargetTablename}", _, _, -1)) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: we're using _ for aggregate above

@c-w c-w merged commit 221c653 into master Aug 25, 2017
@c-w c-w deleted the more-logging branch August 25, 2017 21:52
@c-w c-w removed the in progress label Aug 25, 2017
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants