Entradas

Mostrando entradas de junio, 2025

CobolParser Para Spark

 import org.apache.spark.sql.Dataset; import org.apache.spark.sql.Row; import org.apache.spark.sql.SparkSession; import static org.apache.spark.sql.functions.*; public class CobolParser {     public static Dataset<Row> parseCobolFromLeft(SparkSession spark, String path) {         Dataset<Row> df = spark.read().text(path)             .withColumn("line_length", length(col("value")));         // Extraer campos desde la izquierda         df = df.withColumn("id",                     when(col("line_length").geq(6),                         substring(col("value"), 1, 6))                     .otherwise(lit(null)))               .withColumn("producto",           ...