删除spark字符串列的第一个字符

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.appName("RemoveFirstChar").getOrCreate()

# 示例数据
data = [("example",), ("test",), ("hello",)]
columns = ["string_col"]

# 创建DataFrame
df = spark.createDataFrame(data, columns)

# 注册DataFrame为临时视图
df.createOrReplaceTempView("temp_table")

# 使用SQL删除第一个字符
result_df = spark.sql("SELECT substring(string_col, 2) as new_string_col FROM temp_table")

# 显示结果
result_df.show()

from pyspark.sql import SparkSession
from pyspark.sql.functions import expr

# 创建SparkSession
spark = SparkSession.builder.appName("RemoveFirstChar").getOrCreate()

# 示例数据
data = [("example",), ("test",), ("hello",)]
columns = ["string_col"]

# 创建DataFrame
df = spark.createDataFrame(data, columns)

# 使用DataFrame API删除第一个字符
result_df = df.withColumn("new_string_col", expr("substring(string_col, 2)"))

# 显示结果
result_df.show()

from pyspark.sql import SparkSession
from pyspark.sql.functions import expr, when

# 创建SparkSession
spark = SparkSession.builder.appName("RemoveFirstChar").getOrCreate()

# 示例数据
data = [("example",), ("t",), ("h",), ("",)]
columns = ["string_col"]

# 创建DataFrame
df = spark.createDataFrame(data, columns)

# 使用DataFrame API删除第一个字符，并处理空字符串情况
result_df = df.withColumn("new_string_col", 
                          when(expr("length(string_col) > 1"), expr("substring(string_col, 2)"))
                          .otherwise(expr("string_col")))

# 显示结果
result_df.show()