Hungsiro506

next_xid = 1
active_xids = set()
records = []

def new_transaction():
    global next_xid
    next_xid += 1
    active_xids.add(next_xid)
    return Transaction(next_xid)

Hungsiro506

// Purpose:
// - Ensures that a resource is deterministically disposed of once it goes out of scope
// - Use this pattern when working with resources that should be closed or managed after use
//
// The benefit of this pattern is that it frees the developer from the responsibility of
// explicitly managing resources

import scala.io.Source
import java.io._
 

Hungsiro506

Title file

Hungsiro506

      case class SomeEvent(value: Long)

      val events = Source
        .tick(0 seconds, 250 millis, "")
        .zipWithIndex
        .map { case (_, l) =>
            SomeEvent(l)
        }

      val group = Flow[SomeEvent].groupedWithin(100, 500 millis) // +/- 2 events per group

Hungsiro506

class HyperLogLogStoreUDAF extends UserDefinedAggregateFunction {

  override def inputSchema = new StructType()
    .add("stringInput", BinaryType)

  override def update(buffer: MutableAggregationBuffer, input: Row) = {
    // This input Row only has a single column storing the input value in String (or other Binary data).
    // We only update the buffer when the input value is not null.
    if (!input.isNullAt(0)) {
      if (buffer.isNullAt(0)) {