tonvanbart

class Dog {

    String name;

    public Dog(String name) {
        this.name = name;
    }

    public String bark() {
        return name + " says: Woof!";

tonvanbart

package main

import (
	"encoding/csv"
	"encoding/json"
	"encoding/xml"
	"fmt"
	"log"
	"os"
	"strconv"

tonvanbart

package io.axual.connect.plugins.kafka;

import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;

public class Tryout {

    @Test

tonvanbart

package main

import (
	"encoding/json"
	"fmt"
	"io"
	"net/http"
)

type Astronaut struct {

tonvanbart

from abc import ABC, abstractmethod


class ProxySubject(ABC):
    """
    The interface we will use in our proxy and subject.
    """

    @abstractmethod
    def do_stuff(self, arg):

tonvanbart

#!/usr/bin/python

# check the status of Kafka connectors on a given host

import urllib2
import json
import sys, getopt

def main(argv):
    hostname = ""

tonvanbart

package com.kpn.datalab.mab;

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

tonvanbart

package com.kpn.datalab.mab;

import org.apache.flink.api.common.functions.AggregateFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.RichSourceFunction;
import org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.junit.Test;

tonvanbart

package testing;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.PropertySource;
import org.springframework.test.context.ContextConfiguration;

tonvanbart

#!/bin/sh

if [ "$#" -ne 1 ]; then
    echo Usage is: $0 base-url where base-url is up to and including gateway/api
    exit 0
fi

XSRF_COOKIE="$(curl $1/provisioning/health -I 2>/dev/null | grep Set-Cookie | sed -e 's/^Set-Cookie: XSRF-TOKEN=\([^;]*\);\(.*\)/\1/')"
echo found cookie: $XSRF_COOKIE