ansrivas/spark-structured-streaming ansrivas/spark-structured-streaming

  • Stars
    star
    63
  • Rank 483,633 (Top 10 %)
  • Language
    Scala
  • License
    MIT License
  • Created almost 8 years ago
  • Updated almost 5 years ago
Twitter logo Share LinkedIn logo Share Facebook logo Share
ansrivas/spark-structured-streaming
github

ansrivas

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Spark structured streaming with Kafka data source and writing to Cassandra

More Repositories

1

fiberprometheus

prometheus middleware for Fiber
Go
165
star
2

angular2-flask

Simple angular2 app with python-flask backend ( Learning Angular2 )
JavaScript
151
star
3

keras-rest-server

A very simple project to create a rest backend for serving a neural network model based on keras
Python
65
star
4

GNG

Implementation of growing neural gas algorithm
Python
22
star
5

kafka-rust-example

Simple command line application to read/write message to kafka topic using protobuf
Rust
14
star
6

pylogging

A small wrapper around python logging module which can easily format and write logs to file.
Python
12
star
7

aiven-rs

An async rust-sdk to interact with https://aiven.io/
Rust
9
star
8

yelp_dataset

Sample analysis for the latest yelp dataset using spark
Scala
7
star
9

chi-jwt-go

A very naive but almost complete method of jwt-authentication using chi and jwt-go
Go
5
star
10

documize

An unofficial documize docker image
Dockerfile
4
star
11

fiber-pongo2-pkger

Template-project with fiber and pongo2 as template + pkger to package static assets.
Go
4
star
12

docker-volume-manager

Manage your named docker volumes using this simple script.
Python
4
star
13

rocketchat-client-rs

Rust library to send messages to RocketChat webhook
Rust
3
star
14

protemplates

This creates a simple project structure for different languages. ( similar to Cargo from rust )
Go
3
star
15

initcassandra

A super hacky way to initialize keyspaces and tables in cassandra using docker-compose.
Shell
2
star
16

getignore

Get your gitignore file directly from github
Go
2
star
17

gowindow

Create a rolling window and generate some stats.
Go
2
star
18

flask-alpine

Minimal python alpine image to adduser and run a simple flask server
Python
2
star
19

bid-tracker-rs

Actix-Web application showing some common patterns of arranging an application using custom-error handler, mutexed resource sharing, configuration parsing etc.
Rust
2
star
20

docker-volumes

A simple way to save and reload volumes in docker-compose files.
2
star
21

pyswitcheo

pyswitcheo is a simple python client to interact with Switcheo Decentralized Exchange
Python
2
star
22

setgitconfig-rs

Set the proper username and email address for a git repository based on giturl
Rust
1
star
23

sparkJava

A sample java project for setting up Apache spark with eclipse IDE
Java
1
star
24

go-datastructs

Experiments with golang (with graphs)
Go
1
star
25

asyncio-http-service

Aiohttp-asyncpg-aiohttp_jinja2-gunicorn based dockerized http service to get started quickly (Work In Progress)
JavaScript
1
star
26

schema-registry-client

Rust
1
star
27

gameailab

Source for game lab- ai agents using fuzzy logic and neural networks
Python
1
star
28

go-analyze-git

Go
1
star
29

elk-http-input

Create a logstash input based on http-plugin
Python
1
star
30

superrocket

A supervisord process notification for rocketchat.
Python
1
star
31

go-bidtracker

Go
1
star
32

go-fixsshperms

Go
1
star
33

spark-neuralnetworks

sample example to use neural networks with Apache Spark, using XOR
XSLT
1
star
34

golang-quickstart

This is a quick project to help creating a cleaner sub directory structure in a golang project
Go
1
star
35

file-healthchecker

Check health of your long running python apps which are not web-based
Python
1
star