dantin

version: '2'
services:
  zookeeper:
    # use official zookeeper image
    image: zookeeper
    ports:
      - "2181:2181"

  kafka:
    image: wurstmeister/kafka

dantin

package main

import (
	"database/sql"
	"flag"
	"fmt"
	"os"
	"os/signal"
	"strings"
	"sync"

dantin

# -*- coding: utf-8 -*-
import argparse
import logging
import sys
import threading

import pymysql.cursors

from datetime import datetime

dantin

package main

import (
	"database/sql"
	"flag"
	"fmt"
	"os"
	"os/signal"
	"sync"
	"syscall"

dantin

#!/usr/bin/env bash

#   Copyright 2014 Steve Francia
#
#   Licensed under the Apache License, Version 2.0 (the "License");
#   you may not use this file except in compliance with the License.
#   You may obtain a copy of the License at
#
#       http://www.apache.org/licenses/LICENSE-2.0
#

dantin

func init() {
    rand.Seed(time.Now().UnixNano())
}

var letterRunes = []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ")

func RandStringRunes(n int) string {
    b := make([]rune, n)
    for i := range b {
        b[i] = letterRunes[rand.Intn(len(letterRunes))]

dantin

/**
 * Template class for Hadoop MapReduce Job
 */
public class HadoopMapReduceJobTemplate extends Configured implements Tool {
  
  /**
   * Mapper
   */
  public static class MapClass extends MapReduceBase implements Mapper<Text, Text, Text, Text> {
    public void map(Text key, Text value,

dantin

/**
 *
 * 拷贝本地目录下的所有文件至HDFS
 * 
 */
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;

dantin

@Autowired
public void setDessert(Dessert dessert) {
  this.dessert = dessert;
}


===
Dessert.java接口有多个实现类

dantin

public Employee getEmployeeById(long id) {

  Connection conn = null;
  PreparedStatement stmt = null;
  ResultSet rs = null;
  
  try {
    conn = dataSource.getConnection();
    stmt = conn.prepareStatement(
          "select id, firstname, lastname, salary from " +