Alfresco
Talks about Alfresco API usage
Friday, May 10, 2024
Download file from sharepoint site
›
package com.tgt.ding.sp.reader ; import java.io.FileOutputStream ; import java.io.IOException ; import java.io.InputStream ; import java.net...
Saturday, April 13, 2024
Spark consumer avro topic
›
./spark-shell --packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.5.1,\ org.apache.spark:spark-avro_2.12:3.5.1,\ io.confluent:kafka-sch...
Friday, May 26, 2023
Kafka sink using spark java - in cdap
›
//With the kafka sink cannot set the StringSerializer DataFrameWriter < Row > dataFrameWriter = keyValueDataSet .selectExpr( "C...
Wednesday, May 17, 2023
Kafka push from spark dataframe using java api
›
public SparkSession getSparkSession () { if ( sparkSession == null ) { sparkSession = SparkSession . builder () ...
Tuesday, December 13, 2022
Array of structs
›
scala> import spark.implicits._ import spark.implicits._ scala> import org.apache.spark.sql.types._ import org.apache.spark.sql.types...
Thursday, December 8, 2022
UnionByName with the empty dataframe
›
import spark.implicits._ import org.apache.spark.sql.types. import org.apache.spark.sql._ val data = Seq (("James" , "Sales...
Tuesday, November 29, 2022
Writing empty dataframe spark
›
import spark.implicits._ val data=Seq() val columns = Seq("firstname","lastname","country","state")...
›
Home
View web version