arkadius

minio:
 image: minio/minio:RELEASE.2024-06-26T01-06-18Z
 hostname: minio
 networks:
   - nussknacker-iceberg-net
 environment:
   MINIO_ROOT_USER: admin
   MINIO_ROOT_PASSWORD: password
   MINIO_DOMAIN: minio
   MINIO_REGION_NAME: us-east-1

arkadius

batch {
 deploymentConfig: {
   type: "flinkStreaming"
   restUrl: ${FLINK_REST_URL}
 }
 modelConfig: {
   classPath: [
     "model/defaultModel.jar", "components/flink/flinkBase.jar", "components/flink-table/",
     "model/flinkExecutor.jar", "flink-dropwizard-metrics-deps/", "components/flink/extra/"
   ]

arkadius

CREATE CATALOG nessie_catalog WITH (
  'type'='iceberg',
  'catalog-impl'='org.apache.iceberg.nessie.NessieCatalog',
  'io-impl'='org.apache.iceberg.aws.s3.S3FileIO',
  'uri'='http://nessie:19120/api/v2',
  'warehouse' = 's3://warehouse',
  's3.endpoint'='http://minio:9000'
);

arkadius

#!/bin/bash

host=$1
password=`awk "/#Password/ && inhost { print \\\$2 } /Host/ { inhost=0 } /Host $host/ { inhost=1 }" ~/.ssh/config`

if [[ -z "$password" ]]; then
  /usr/bin/ssh $*
else
  sshpass -p $password /usr/bin/ssh $*
fi

arkadius

Sentiment: {
  "docSentiment": {
    "score": -0.222224,
    "type": "negative"
  },
  "language": "english",
  "totalTransactions": 1
}
Entities: {
  "entities": [

arkadius

import akka.actor.{Actor, ActorSystem, Props, Stash}

import scala.concurrent._

object AsyncRestart extends App {

  val system = ActorSystem()

  val actor = system.actorOf(Props(new AsyncRestartActor))

arkadius

class A()
class B(val a: A)
class C(val b: B)

implicit def aToB(a: A) = new B(a)

implicit def sthConvertibleToBToC[T <% B](t: T): C = new C(t)
def doSthWithC[T <% C](t: T) = t.b

doSthWithC(new A)

arkadius

Keybase proof

I hereby claim:

• I am arkadius on github.
• I am arkadius (https://keybase.io/arkadius) on keybase.
• I have a public key whose fingerprint is F2F2 22AD E13A EAC9 6349 9E22 C406 0852 104F 9B5A

To claim this, I am signing this object:

arkadius

  it should "do round-trip" in {
    forAll(initialBoardAndChangesGenerator) {
      case InitialBoardAndChanges(initialBoard, changes) =>
        lazy val boardAndEventsStream: Stream[(BoardState, Seq[TaskEvent])] =
          (initialBoard, Nil) #::
            (boardAndEventsStream zip changes).map {
              case ((prevBoard, events), changedBoard) =>
                val newAddedEvents = prevBoard.diff(changedBoard)
                (changedBoard, newAddedEvents)
            }

arkadius

app.controller("ProjectCtrl", ['$scope', 'historySvc', function ($scope, historySvc) {
  (...)

  var refreshChart = function () {
    historySvc.getHistory($scope.selectedSprint.id).then(function (history) {
      $scope.history = history;
    });
  };

  (...)