Skip to content

Instantly share code, notes, and snippets.

@juri96

juri96/PipelineSteps.kt

Created November 15, 2019 13:51
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 juri96/9e8656695fbb5a092981e3188f7e3abb to your computer and use it in GitHub Desktop.
Save juri96/9e8656695fbb5a092981e3188f7e3abb to your computer and use it in GitHub Desktop.
Download ZIP
Raw
PipelineSteps.kt
private const val headers = """"No","year","month","day","hour","PM2.5","PM10","SO2","NO2","CO","O3","TEMP","PRES","DEWP","RAIN","wd","WSPM","station""""
fun filterHeaderRow(): Filter<String> = Filter.by(ProcessFunction<String, Boolean> {
!it.startsWith(headers)
})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment