yatender-oktalk

1. General Background and Overview

• Probabilistic Data Structures for Web Analytics and Data Mining : A great overview of the space of probabilistic data structures and how they are used in approximation algorithm implementation.
• Models and Issues in Data Stream Systems
• Philippe Flajolet’s contribution to streaming algorithms : A presentation by Jérémie Lumbroso that visits some of the hostorical perspectives and how it all began with Flajolet
• Approximate Frequency Counts over Data Streams by Gurmeet Singh Manku & Rajeev Motwani : One of the early papers on the subject.
• [Methods for Finding Frequent Items in Data Streams](http://citeseerx.ist.psu.edu/viewdoc/download?doi=10.1.1.187.9800&rep

yatender-oktalk

‎‎​

yatender-oktalk

#!bash
# Course content

# creating the index
curl -H "Content-Type: application/json" -XPUT 127.0.0.1:9200/movies -d '
{
    "mappings": {
        "movie": {
            "properties": {
                "year": {"type": "date"}

yatender-oktalk

input {
    beats {
        type => beats
        port => 5060
    }
}

filter {
    dissect {
        mapping => {

yatender-oktalk

def application do
  [
    extra_applications: [:lager, :logger, :inets, :opentelemetry]
    mod: {OpenTelemetryDemo.Application, []}
  ]
end

def deps do
  [
    # opentelemetry

yatender-oktalk

defmodule OpenTelemetryDemo do
  @moduledoc """
  Documentation for `OpenTelemetryDemo`.
  """
  require OpenTelemetry.Tracer
  require OpenTelemetry.Span

  @doc """
  random function just to show the open-telemetry demo,
  this function will mimic some working of the modules.

yatender-oktalk

use Mix.Config

config :opentelemetry,
       :processors,
       ot_batch_processor: %{
         exporter:
           {:opentelemetry_zipkin,
            %{
              address: 'http://localhost:9411/api/v2/spans',
              local_endpoint: %{service_name: "open_telemetry_demo"}

yatender-oktalk

defmodule OpenTelemetryDemo.Application do
  # See https://hexdocs.pm/elixir/Application.html
  # for more information on OTP Applications
  @moduledoc """
  OpenTelemetryDemo entry point
  """

  use Application

  @impl true

yatender-oktalk

defmodule Alpha.MixProject do

...
  defp deps do
    [
      {:opentelemetry, "~> 0.4.0"},
      {:opentelemetry_api, "~> 0.3.2"},
      {:opentelemetry_zipkin, "~> 0.2.0"}
    ]
  end

yatender-oktalk

import Config

config :opentelemetry,
       :processors,
       ot_batch_processor: %{
         exporter:
           {:opentelemetry_zipkin,
            %{
              address: 'http://localhost:9411/api/v2/spans',
              local_endpoint: %{service_name: "alpha"}