Skip to content

Instantly share code, notes, and snippets.

View xdralex's full-sized avatar

Alexander Demidko xdralex

  • San Francisco / London
View GitHub Profile

Conditions

Two Storm supervisors running in a 3-node configuration: one "head" node (nimbus) and two worker nodes. Each supervisor node runs a supervisor under supervision.

Topology

Multi-lang topology using Python and our streamparse library. Works fine when running on a single machine. Spout reads off Kafka and inserts tuples into

package kstreams_demo
import java.lang.{Integer => JInt}
import java.util.Properties
import kstreams_demo.converters._
import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord}
import org.apache.kafka.common.serialization.Serdes
import org.apache.kafka.streams.kstream._
import org.apache.kafka.streams.kstream.internals.TimeWindow
@xdralex
xdralex / fluence.cla
Last active February 17, 2018 13:41
Fluence CLA
Thank you for your interest in Fluence Labs projects.
In order to clarify the intellectual property license
granted with Contributions from any person or entity, Fluence Labs
must have a Contributor License Agreement ("CLA") on file that has
been signed by each Contributor, indicating agreement to the license
terms below. This license is for your protection as a Contributor as
well as the protection of Fluence Labs and its users; it does not
change your rights to use your own Contributions for any other purpose.
This contribution license is based on the Apache Contribution License
@xdralex
xdralex / checklist.md
Created April 19, 2021 13:39
ML/DL/CS Checklist

Deep Learning

concepts

  • forward and backward propagation
  • vanishing gradient
  • image convolution operation
  • feature map, filter/kernel
  • receptive field
  • embedding
  • translation invariance