<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:
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, |
ssize_t read(int fd, void *buf, size_t count); | |
ssize_t write(int fd, const void *buf, size_t count); |
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 | |
/** |
// 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 |
Copyright © 2017 Fantasyland Institute of Learning. All rights reserved.
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