加载中
java 接收syslog ,简单测试代码

/* * 接收syslog 数据发到kafka上,flink消费kafka * * org.myorg.quickstart.kafka.UDPServer * * cd /etc/rsyslog.d * * systemctl restart rsyslog * [root@localhost rsyslog.d]# cat......

09/16 19:01
6
游戏 socket开发

三个软件分别是前台服务器(qt)、后台服务器(win32)和客服端(cocos2dx)。后台服务器的数据库采用sqlite3(方便将数据库集成后台服务器里面),阻塞式TCP协议(运用等待事件函数WSAWaitFo...

java操作时间,按分钟回退

String minTime = "2011-01-2815:57:04.0"; String maxTime = "2019-05-2411:41:47.0"; String apartMin = "25"; Date mdate = TimeUtil.fromDate(minTime); Date axdate = TimeUtil.fromDat...

06/20 14:24
2
java解析datax 的json 包,获取json里的数据

JSONArray reader1 =JSON.parseArray(ccont).getJSONObject(0) .getJSONObject("reader").getJSONObject("parameter").getJSONArray("connection").getJSONObject(0).getJSONArray("querySql...

06/19 14:50
2
入侵探测器学习

本文档改编自纸张基于成本的数据挖掘建模和评估应用于 欺诈和入侵检测:来自 Salvatore J. Stolfo,Wei Fan,Wenke Lee,Andreas Prodromidis和Philip K. Chan 的JAM项目的结果。 入侵探测器...

JAM
06/10 13:49
2
FlowRunnerManager java调度Linux命令源码分析

/* * Copyright 2012 LinkedIn Corp. * * Licensed under the Apache License, Version 2.0 (the "License"); you may not * use this file except in compliance with the License. You may...

04/24 17:16
26
http://www.schonlau.net/翻译

NISS distinguished alumni award 尼斯杰出校友奖 I am thrilled to announce I won the 2018 NISS distinguished alumni award. NISS is the US-based National Institute of Statistical S...

04/19 17:17
4
Python开发, 恶意病毒扫描

#!/usr/bin/python ''' Extracts some basic features from PE files. Many of the features implemented have been used in previously published works. For more information, check out ...

web安全机器学习截图,基于win7上的效果展示

web安全机器学习截图,基于win7上的效果展示

04/03 16:38
1
创建mysql 账号 赋予权限 只读权限

创建mysql 账号 赋予权限 创建mysql 账号 赋予权限 只读权限 GRANT SELECT ON *.* TO 'bigdata'@'%' IDENTIFIED BY "123456"; Query OK, 0 rows affected (0.00 sec) mysql> FLUSH PRIVILEGE...

04/01 09:50
7
hdfs 写orc

package com.1.test; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.net.URI; import java.net.URISyntaxException; import org.apache.h...

kafka读取 topic

kafka-topics --zookeeper master:2181 --list

Fastjson是一个Java语言编写的高性能功能完善的JSON库。由阿里巴巴公司团队开发的.

Fastjson是一个Java语言编写的高性能功能完善的JSON库。由阿里巴巴公司团队开发的. 主要特性主要体现在以下几个方面: 1.高性能 fastjson采用独创的算法,将parse的速度提升到极致,超过所有j...

hive创建 年月日分区表,自带的

create_time STRING, creator STRING ) partitioned BY ( YEAR STRING, MONTH STRING, DAY STRING ) clustered BY (id) INTO 1 buckets ROW formatdelimited FIELDS TERMINATED BY '\t' STOR...

hbase flink 的maven pom。xml 配置

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apach...

主机状态运行不良

主机状态运行不良 概述 在安装集群的时候,install parcels这个步骤的时候。显示主机运行状况不良并且一直迟迟没有安装好。 报错效果 报错原因 是因为节点上次安装没有成功,所以这个agent的...

03/15 10:44
3
elasti 时间范围查询

GET /111.topic-*/_search { "query": { "range": { "lastUpdateTime.keyword": { "lt":"2019-03-12 15:53:05" , "gte":"2019-03-12 15:33:05" } } } }......

03/14 17:13
3
nginx 转发 Kibana

upstream goto{ server 127.0.0.1:5601; }upstream app{ server 127.0.0.1:5601; } upstream bundles{ server 127.0.0.1:5601; } upstream plugins{ server 127.0.0.1:5601; } upstream api{...

Zeppelin 可视化操作spark sql

pache Zeppelin提供了web版的类似ipython的notebook,用于做数据分析和可视化。背后可以接入不同的数据处理引擎,包括spark, hive, tajo等,原生支持scala, java, shell, markdown等。它的整...

logstash 简单读kafka ,写es数据

input { kafka { bootstrap_servers => ["192.168.1.1:9092"] # 注意这里配置的kafka的broker地址不是zk的地址 group_id => "logstash" # 自定义groupid topics => ["ttt.log.topic"] # kaf...

03/02 14:39
15

没有更多内容

加载失败,请刷新页面

返回顶部
顶部