Skip to content

Instantly share code, notes, and snippets.

View virtualsafety's full-sized avatar

virtualsafety virtualsafety

7 followers · 14 following
View GitHub Profile
@virtualsafety
virtualsafety / elasticsearch.md
Created November 21, 2017 08:12 — forked from kkc/elasticsearch.md
Elasticsearch performance tuning

##TUNING##

Configuration

System: set file descriptors to 32K or 64K

vim /etc/security/limit.conf

@virtualsafety
virtualsafety / java和scala混合编程.txt
Last active May 24, 2021 09:57
java和scala混合编程
http://www.cnblogs.com/yjmyzz/p/4694219.html
mvn clean scala:compile compile package
http://blog.csdn.net/kwu_ganymede/article/details/51832427
https://blogs.oracle.com/arungupta/entry/scala_and_maven_getting_started
mvn scala:run
http://running8.blog.51cto.com/2687882/1603429
@virtualsafety
virtualsafety / myip.go
Created July 26, 2017 03:30 — forked from jniltinho/myip.go
Get My IP Golang
package main
/*
URL: https://github.com/mccoyst/myip/blob/master/myip.go
URL: http://changsijay.com/2013/07/28/golang-get-ip-address/
*/
import (
"net"
"os"
@virtualsafety
virtualsafety / check.go
Created July 14, 2017 03:47 — forked from mattes/check.go
Check if file or directory exists in Golang
if _, err := os.Stat("/path/to/whatever"); os.IsNotExist(err) {
// path/to/whatever does not exist
}
if _, err := os.Stat("/path/to/whatever"); err == nil {
// path/to/whatever exists
}
@virtualsafety
virtualsafety / read_exec_output_line_by_line.go
Created July 1, 2017 14:37
read exec output line by line
(1)方法一
cmd := exec.Command("cmd", "args")
stdout, err := cmd.StdoutPipe()
cmd.Start()
r := bufio.NewReader(stdout)
for {
line, isPrefix, err := r.ReadLine()
@virtualsafety
virtualsafety / AlertActiveSessionTuple.scala
Created May 4, 2017 01:43
read json from kafka , parse json to case class , and then convert case class to tuple.
package com.test.flink
import java.util.Properties
import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09
import org.apache.flink.streaming.util.serialization.SimpleStringSchema
import org.apache.flink.streaming.api.windowing.time.Time
import org.json4s._
import org.json4s.jackson.JsonMethods._
@virtualsafety
virtualsafety / ScalaJson.scala
Last active July 8, 2021 06:27
利用json4s解析json数据
import org.json4s._
import org.json4s.jackson.JsonMethods._
object ScalaJson {
def main(args: Array[String]): Unit = {
implicit val formats = DefaultFormats
case class Model(hello: String, age: Int)
@virtualsafety
virtualsafety / reflect_1.scala
Created April 15, 2017 13:38
查看 Scala 语法树的方法
import scala.reflect.runtime._
import scala.tools.reflect.ToolBox
val cm = universe.runtimeMirror(getClass.getClassLoader)
val tb = cm.mkToolBox()
tb.parse("for(i <- List(1,2,3) ) {println(i)}")
@virtualsafety
virtualsafety / shell_output.go
Created April 10, 2017 03:39 — forked from hivefans/shell_output.go
get the realtime output for a shell command in golang
package main
import (
"bufio"
"fmt"
"io"
"os"
"os/exec"
"strings"
)
@virtualsafety
virtualsafety / HelloQuasiquotes.scala
Last active April 9, 2017 12:56
下面的例子演示了如何利用Quasiquotes来实现Code Generation:
import scala.reflect.runtime.currentMirror
import scala.tools.reflect.ToolBox
object HelloQuasiquotes {
def main(args: Array[String]): Unit = {
val universe: scala.reflect.runtime.universe.type = scala.reflect.runtime.universe
import universe._
val toolbox = currentMirror.mkToolBox()