Skip to content

Commit

Permalink
another style fix
Browse files Browse the repository at this point in the history
  • Loading branch information
abhay-a committed Mar 21, 2019
1 parent 238da4f commit 430e0b1
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions sql/core/src/main/scala/org/apache/spark/sql/functions.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3408,7 +3408,13 @@ object functions {
NfJsonExtractArray(e.expr, lit(path).expr)
}

def cl_snapshot_extract(e: Column, clType: String, extractCriteria: String, filterCriteria: String): Column = withExpr {
ClSnapshotExtract(e.expr, lit(clType).expr, lit(extractCriteria).expr, lit(filterCriteria).expr)
def cl_snapshot_extract(e: Column,
clType: String,
extractCriteria: String,
filterCriteria: String): Column = withExpr {
ClSnapshotExtract(e.expr,
lit(clType).expr,
lit(extractCriteria).expr,
lit(filterCriteria).expr)
}
}

0 comments on commit 430e0b1

Please sign in to comment.