Github user gatorsmile commented on a diff in the pull request:

    https://github.com/apache/spark/pull/19169#discussion_r146420815
  
    --- Diff: 
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/CurrentUser.scala
 ---
    @@ -0,0 +1,47 @@
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more
    + * contributor license agreements.  See the NOTICE file distributed with
    + * this work for additional information regarding copyright ownership.
    + * The ASF licenses this file to You under the Apache License, Version 2.0
    + * (the "License"); you may not use this file except in compliance with
    + * the License.  You may obtain a copy of the License at
    + *
    + *    http://www.apache.org/licenses/LICENSE-2.0
    + *
    + * Unless required by applicable law or agreed to in writing, software
    + * distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    + * See the License for the specific language governing permissions and
    + * limitations under the License.
    + */
    +
    +package org.apache.spark.sql.catalyst.expressions
    +
    +import org.apache.spark.SparkContext
    +import org.apache.spark.sql.catalyst.InternalRow
    +import org.apache.spark.sql.catalyst.expressions.codegen.CodegenFallback
    +import org.apache.spark.sql.types.{DataType, StringType}
    +
    +/**
    + * Return the user executing the current query.
    + *
    + * There is no code generation since this expression should get constant 
folded by the optimizer.
    + */
    +@ExpressionDescription(
    +  usage = """
    +    _FUNC_() - Returns the current user executing the query.
    +  """,
    +  since = "2.3.0")
    +case class CurrentUser() extends LeafExpression with CodegenFallback {
    +  override def foldable: Boolean = true
    +  override def nullable: Boolean = false
    +  override def dataType: DataType = StringType
    +
    +  /** Returns the result of evaluating this expression on a given input 
Row */
    +  override def eval(input: InternalRow): Any = {
    +    SparkContext.getActive.map(_.sparkUser).getOrElse("")
    --- End diff --
    
    So far, it is not in our plan.


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to