Skip to content

Commit 557bc11

Browse files
committed
Make naming of event less confusing
1 parent 8cb1030 commit 557bc11

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

project-fortis-spark/src/main/scala/com/microsoft/partnercatalyst/fortis/spark/Pipeline.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -155,9 +155,9 @@ object Pipeline {
155155
event.copy(analysis = event.analysis.copy(summary = summary))
156156
}
157157

158-
def logFilter(isFiltered: Boolean, filterName: String) = {
159-
Log.logEvent(s"pipeline.filters.$filterName", Map("isFiltered" -> isFiltered.toString))
160-
isFiltered
158+
def logFilter(passedFilter: Boolean, filterName: String) = {
159+
Log.logEvent(s"pipeline.filters.$filterName", Map("passedFilter" -> passedFilter.toString))
160+
passedFilter
161161
}
162162

163163
// Configure analysis pipeline

project-fortis-spark/src/main/scala/com/microsoft/partnercatalyst/fortis/spark/sources/streamfactories/TwitterStreamFactory.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -78,16 +78,16 @@ class TwitterStreamFactory(configurationManager: ConfigurationManager) extends S
7878
}
7979

8080
if (!isOriginalTweet(status)) {
81-
Log.logEvent("pipeline.filters.isRetweet", Map("isFiltered" -> "false"))
81+
Log.logEvent("pipeline.filters.isRetweet", Map("passedFilter" -> "false"))
8282
false
8383
} else {
8484
if (trustedSourceScreenNames.isEmpty) {
8585
true
8686
} else {
8787
val screenName = status.getUser.getScreenName.toLowerCase
88-
val isFiltered = trustedSourceScreenNames.contains(screenName)
89-
Log.logEvent("pipeline.filters.isTrustedSource", Map("isFiltered" -> isFiltered.toString, "screenName" -> screenName))
90-
isFiltered
88+
val passedFilter = trustedSourceScreenNames.contains(screenName)
89+
Log.logEvent("pipeline.filters.isTrustedSource", Map("passedFilter" -> passedFilter.toString, "screenName" -> screenName))
90+
passedFilter
9191
}
9292
}
9393
})

0 commit comments

Comments
 (0)