mrserverless

public class MultiTenantDataSource implements ManagedDataSource {
    private final ManagedDataSource managedDataSource;
    private final SchemaResolver schemaResolver;

    public MultiTenantDataSource( final ManagedDataSource managedDataSource, final SchemaResolver schemaResolver )
    {
        this.managedDataSource = managedDataSource;
        this.schemaResolver = schemaResolver;
    }

GaryRogers

RSyslog Forwarding Setup

Overview

I'm looking to centralize logging for our dev team into Elasticsearch via Logstash. The wrinkle is that we aren't a Java shop, so installing java on our hosts just to ship logs back to a central Logstash indexer is something we'd like to avoid. So, I'm approaching things as a chance to understand RSyslog and its capabilities as a log shipper.

Procedure

Set up TCP listening on the log index host

Uncomment the following lines in /etc/rsyslog.conf. This will enable the rsyslog daemon to listen for incoming requests on TCP port 514. We're using TCP here so that we can have some confidence that the messages from the agent hosts reach the indexer. (More on this below)

staltz

The introduction to Reactive Programming you've been missing

(by @andrestaltz)

---

This tutorial as a series of videos

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

---

terrancesnyder

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.avro.io.BinaryDecoder;

terrancesnyder

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import org.apache.avro.io.BinaryDecoder;
import org.apache.avro.io.BinaryEncoder;
import org.apache.avro.io.DecoderFactory;

kevin-smets

Default

Powerlevel10k

johnynek

groupBy('source) {
  _.sortBy('links)
    .reverse
    .mapStream[(String,Int), (String, Int, Int, Int)]
      (('destination, 'links) -> ('destination, 'links, 'rank, 'gap)) { destLinks =>
        destLinks.scanLeft(None: Option[(String, Int, Int, Int)]) {
          (prevRowOut: Option[(String,Int,Int,Int)], thisRow: (String, Int))  =>
          val (dest, links) = thisRow
          prevRowOut match {
            case None => Some((dest, links, 1, 0)) // rank 1, gap 0 -- not exactly what you wanted...

mushkevych

FROM    ubuntu:precise
MAINTAINER Bohdan Mushkevych

# Installing Oracle JDK
RUN apt-get -y install python-software-properties ;\
	add-apt-repository ppa:webupd8team/java ;\
	apt-get update && apt-get -y upgrade ;\
	echo oracle-java7-installer shared/accepted-oracle-license-v1-1 select true | /usr/bin/debconf-set-selections ;\
	apt-get -y install oracle-java7-installer && apt-get clean ;\
	update-alternatives --display java ;\

johnfrey99

public class JacksonConverter implements Converter
{
  private final ObjectMapper mapper;

	public JacksonConverter(ObjectMapper mapper)
	{
		this.mapper = mapper;
	}

	@Override public Object fromBody(TypedInput body, Type type) throws ConversionException

visenger

#!/bin/sh

# one way (older scala version will be installed)
# sudo apt-get install scala

#2nd way
sudo apt-get remove scala-library scala
wget http://www.scala-lang.org/files/archive/scala-2.11.4.deb
sudo dpkg -i scala-2.11.4.deb
sudo apt-get update