milenkovicm

use std::{sync::Arc, time::Instant};

use datafusion::{
    arrow::{array::RecordBatch, json::ArrayWriter},
    prelude::SessionContext,
};
use iceberg::{io::FileIO, table::StaticTable, TableIdent};
use iceberg_datafusion::IcebergTableProvider;
use lambda_runtime::{
    run, service_fn,

milenkovicm

       ssize_t read(int fd, void *buf, size_t count);

       ssize_t write(int fd, const void *buf, size_t count);

milenkovicm

Title

<Additional information about your API call. Try to use verbs that match both request type (fetching vs modifying) and plurality (one vs multiple).>

• URL

  <The URL Structure (path only, no root url)>

• Method:

milenkovicm

package flowcontrol

import scala.concurrent.duration._

import akka.actor.typed.ActorRef
import akka.actor.typed.ActorSystem
import akka.actor.typed.Behavior
import akka.actor.typed.scaladsl.Behaviors

/**

milenkovicm

Keybase proof

I hereby claim:

• I am milenkovicm on github.
• I am milenkovicm (https://keybase.io/milenkovicm) on keybase.
• I have a public key ASC4CdDn5SfSi5l8SKVKrPsz2AX9Qw2UbGDRT4rHxNdtdgo

To claim this, I am signing this object:

milenkovicm

// Spawn your futures
val fs = (1 to 100).map { i =>
  Future { Thread.sleep(i); i }
}

// Wrap all of the work up into a single
// Future
val f = Future.sequence(fs)

// Wait on it forever - i.e. until it's done

milenkovicm

Advanced Functional Programming with Scala - Notes

Copyright © 2017 Fantasyland Institute of Learning. All rights reserved.

1. Mastering Functions

A function is a mapping from one set, called a domain, to another set, called the codomain. A function associates every element in the domain with exactly one element in the codomain. In Scala, both domain and codomain are types.

val square : Int => Int = x => x * x

milenkovicm

package com.example

import javax.enterprise.event.Observes;
import javax.enterprise.inject.spi.*;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class CdiExtension implements Extension {

milenkovicm

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://java.sun.com/xml/ns/javaee"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/beans_1_0.xsd">

   <!-- Enable JCACHE interceptors -->
   <interceptors>
      <class>org.infinispan.cdi.interceptor.CacheResultInterceptor</class>
      <class>org.infinispan.cdi.interceptor.CacheRemoveEntryInterceptor</class>
      <class>org.infinispan.cdi.interceptor.CacheRemoveAllInterceptor</class>

milenkovicm

public class JBoss7TransactionManagerLookup implements TransactionManagerLookup {
   public TransactionManager getTransactionManager() throws Exception {
      InitialContext ic = new InitialContext();
      TransactionManager tm  = (TransactionManager) ic.lookup("java:jboss/TransactionManager");
      if (tm == null) throw new IllegalStateException("Couldn't find the transaction mamager in JNDI");
      return tm;
   }
}