christopheblp

import org.apache.spark.sql.SparkSession
import org.scalatest.FunSuite

case class Root(headers: Map[String, String], body: String)

class OrderByTimeStampTest extends FunSuite {

  val spark = SparkSession.builder
    .master("local[*]")
    .getOrCreate

christopheblp

package ConfigurationTest;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
import org.junit.jupiter.api.AfterAll;

christopheblp

package kafka;

import java.util.Properties;

import org.apache.kafka.clients.producer.Producer;

public class KafkaProducer {

	public static void main(String[] args) throws Exception {