This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
object FarmConsumer { | |
val processedMessages: Cache[String, JBoolean] = CacheBuilder | |
.newBuilder() | |
.maximumSize(10000) | |
.build() | |
} | |
class FarmConsumer() extends Processor[GrowerKey, FarmWithGrower] { | |
import FarmConsumer._ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
final case class FarmWithGrower(farm: FarmMessage, grower: Option[GrowerMessage]) | |
def topology(): Topology = { | |
val builder = new StreamsBuilder | |
val growers: KStream[GrowerKey, GrowerMessage] = builder.stream[GrowerKey, GrowerMessage]("growers") | |
val farms: KStream[FarmKey, FarmMessage] = builder.stream[FarmKey, FarmMessage]("farms") | |
farms | |
.flatMap[GrowerKey, FarmMessage] { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
create table growers ( | |
id uuid primary key not null | |
); | |
create table farm ( | |
id uuid primary key not null, | |
grower_id uuid not null references growers(id) | |
); | |
create table fields ( |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package org.miker | |
import org.apache.commons.math3.stat.descriptive.SummaryStatistics | |
import vegas._ | |
import scala.collection.mutable | |
object SmoothedZscore extends App { | |
val y = List(1d, 1d, 1.1d, 1d, 0.9d, 1d, 1d, 1.1d, 1d, 0.9d, 1d, 1.1d, 1d, 1d, 0.9d, 1d, 1d, 1.1d, 1d, 1d, | |
1d, 1d, 1.1d, 0.9d, 1d, 1.1d, 1d, 1d, 0.9d, 1d, 1.1d, 1d, 1d, 1.1d, 1d, 0.8d, 0.9d, 1d, 1.2d, 0.9d, 1d, |