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

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

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...

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

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

/* * 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...

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...

#!/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上的效果展示

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

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-topics --zookeeper master:2181 --list

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

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...

<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的...

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

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{...

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

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