Allen_Oscar-CSDN博客

原创 Java 调用Hive 自定义UDF

Hive 具有一个可选的组件叫做HiveServer,它允许通过在一定的端口访问Hive.将自定义的UDF的jar拷贝到安装的hive服务器中（如 /home/hadoop下）具体的不啰嗦了，看代码吧！、package com.hive.client;import java.sql.Connection;import java.sql.DriverManager;import

2015-04-20 10:31:00 4009 3

原创 Java 连接 Hive

Hive具有一个可选的组件叫做HiveServer后者HiveThrift,其允许通过指定端口访问Hive.访问Hive常用访问方式是通过CLI进行访问。不过，CLI设计使其不方便通过编程的方式访问。CLI是胖客户端。Hive提供了jdbc驱动，使得我们可以用Java代码来连接Hive并进行一些类关系型数据库的sql语句查询等操作。同关系型数据库一样，我们也需要将Hive的服务打开；在Hive

2015-04-27 10:13:46 2412

转载【Storm总结-5】Twitter Storm: Transactional Topolgoy简介

转自： http://xumingming.sinaapp.com/736/twitter-storm-transactional-topolgoy/----------------------------概述Storm通过保证每个tuple至少被处理一次来提供可靠的数据处理。关于这一点最常被问到的问题就是“既然tuple可能会被重写发射(repla

2014-11-10 16:37:18 698

转载【Storm总结-4】Storm 中acker的工作流程

转自http://xumingming.sinaapp.com/410/twitter-storm-code-analysis-acker-merchanism/---------------------------概述我们知道storm一个很重要的特性是它能够保证你发出的每条消息都会被完整处理，完整处理的意思是指：一个tuple被完全处理的意思是

2014-11-10 16:36:32 848

转载【Storm总结-3】Storm如何保证消息不丢失 (Guaranteeing-message-processing)

转自： http://xumingming.sinaapp.com/127/twitter-storm如何保证消息不丢失/---------------------------------本文翻译自： https://github.com/nathanmarz/storm/wiki/Guaranteeing-message-processingstorm

2014-11-10 16:35:31 959

转载【Storm总结-2】关于Storm 中Topology的并发度的理解

主要思想来源于storm的项目页面： https://github.com/nathanmarz/storm/wiki/Understanding-the-parallelism-of-a-Storm-topology其中加入了一些个人的理解，所以就把文章mark成原创了，实际上大部分还是人家的东西。其实翻译这个文章的人也挺多，我看了几个，总是感觉有点绕，所以干脆自己总结一下。目标是简单明

2014-11-10 16:35:30 864

转载【Storm总结-1】Storm 简介 -- 转一个我认为总结的比较好的介绍

第一次接触Storm还是在1年半以前了，当时在做S4，找Storm来进行对比，慢慢的对storm也有了越来越多的了解，到后来在项目中也用到了storm。随着了解的深入和使用的增加，一直想写一系列关于storm的文章，结果发现很多勤奋努力的同学们已经写了很多，所以慢慢转一个系列过来，中间也许夹杂一些个人的理解吧。-----------------转自： http://ww

2014-11-10 16:33:28 843

原创策略模式

定义策略模式：定义了算法族，分别封装起来，让它们之间可以相互替换，此模式让算法的变化独立于使用算法的客户。类图设计原则 1.找出应用中可能需要变化之处，把它们独立出来，不要和那些不需要变化的代码混在一起。 2.针对接口编程，而不是针对实现编程。 3.多用组合，少用继承。举例分析设计一个模拟鸭子游戏，游戏中会出现各种

2014-06-13 12:32:41 1144

原创观察者模式

定义：定义了对象之间的一对多依赖，当一个对象改变状态时，它的所有依赖者都会收到通知并自动更新。类图：利用观察者模式，主题是具有状态的对象，并且可以控制这些状态。有许多观察者依赖主题来告诉他们状态何时改变了。这就产生一个关系：“一个“主题对”多个“观察者的关系。当两个对象之间松耦合，他们依然可以交互，但是不太清楚彼此的细节。观察者模式

2014-06-12 16:41:02 1117

转载 flex blazeds spring activemq 网站资料地址

1. activemq 集成spring 官方说明 http://activemq.apache.org/spring-support.html 2. spring blazeds 整合组件关于 spring flex 的说明文档.版本为 1.05m http://static.springsource.org/spring-flex/docs/1

2014-01-07 14:34:45 1602 1

原创 Spring+ActiveMQ+Flex- 智慧公交（二）

智慧公交-核心的部分就是消息推送这一块，推送和接受消息能跑通了，其他的就是业务上问题了。智能公交调度系统-系统结合了GPS GIS GPRS 等。GPS、GPRS大家都明白，GIS(地理信息系统)在智慧公交项目上主要是用来展示公交线路的地图。在地图上我们可以看到公交线路，车辆位置、行驶方向，可以查看公交车内部的监控、公交站点监控等实时信息。上一篇文章有三个问题还没

2013-12-10 07:51:15 4183 8

原创 Spring+ActiveMQ+Flex- 智慧公交

智能公交调度系统-系统结合了GPS GIS GPRS 等，将车辆的状态信息实时传到调度中心，调度中心可以自动调度和监控车辆。通过将GPS接入后台在通过消息中间件将消息发送到前端，前端可以实时看到车辆运行状态、运行轨迹等信息。该县的公交数量有280辆，我们采用BlazeDS（免费）完全可以胜任，LCDS（商业）比较昂贵，但性能好。那就简单介绍一下是以Flex为前台，结合Blaze

2013-12-05 07:40:59 5585 10

原创 Spring整合ActiveMQ-序列化的 Java对象

JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。· StreamMessage -- Java原始值的数据流· MapMessage--一套名称-值对· TextMessage--一个字符串对象· ObjectMessage--一个序列化的 Java对象· BytesMessage--一个未解释字

2013-12-02 10:48:43 5192

原创 Spring整合ActiveMQ

公司有新的项目-智慧公交服务平台。要求实现公交GPS定位，在地图上动态显示订阅的公交车行车轨迹、轨迹回放等等一些功能。这就要用到消息推送服务中间件ActiveMQ。采用UDP的方式推送消息。先简单介绍一下Spring整合ActiveMQ，后续将介绍Spring+activeMQ+Flex消息推送的实现。一.消息监听Spring提供了三种 AbstractMessageListenerCon

2013-12-02 08:04:02 3450

原创 Flex回调函数

回调函数就是一个通过函数指针调用的函数。如果你把函数的指针(地址)作为参数传递给另一个函数，当这个指针被用为调用它所指向的函数时，我们就说这是回调函数。回调函数不是由该函数的实现方法直接调用，而是在特定的事件或条件发生时由另一个方法调用的，用于对该事件或条件进行相应。下面还是通过代码的方式，自己实现一个回调函数的应用。FlexCallBack.mxml<s:Application

2013-09-07 09:04:46 2429

原创 FLEX 事件机制-自定义事件

最近在做地图JS和FLEX的封装工作，flex封装需要用到自定义事件这方面知识，在这里就简单介绍一下FLEX自定义事件。

2013-09-07 07:56:32 2505

原创 JS 与Flex交互:html中的js 与flex中的actionScript通信

Flex与JavaScript交互的问题，这里和大家分享一下，主要包括Flex调用JavaScript中的函数和JavaScript调用Flex中的函数两大部分内容。Flex 与JavaScript 交互，主要依靠Flex的ExternalInterface，其提供了addCallBack和call方法。一.Html页面嵌套Flexhtml嵌套Flex需要用到swfobject.js,

2013-08-05 20:12:07 2202

转载 JS原型和原型链

原型使用方式1个人理解，之前写JS都是这样:var decimalDigits = 2, tax = 5; function add(x, y) { return x + y; } function subtract(x, y) { return x

2013-08-04 20:11:56 888

原创 JS Flex交互:html嵌套Flex(swf)

一.html页面嵌套Flex需要用到 swfobject.js swfobject的使用是非常简单的，只需要包含 swfobject.js这个js文件，然后在DOM中插入一些简单的JS代码，就能嵌入Flash媒体资源了。swfobject.embedSWF(swfUrl, id, width, height, version, expressInstallSwfurl, flashvars

2013-08-04 09:04:57 3479

原创 Swing 写的日期时间组件

在网上收集的swing时间组件完善了一下，日期上下按钮可以点击，闰年平年判断，月份是多少天自动更新改变。希望大家继续完善。MainAppimport java.awt.Dimension;import java.awt.Toolkit;import java.awt.event.WindowAdapter;import java.awt.event.WindowEvent;

2013-08-01 20:49:26 2057

原创 geoserver wmts服务叠加

由于项目需求，在发布的地图服务的基础上，在其上面叠加一层路网数据，类似arcgis的服务叠加简单介绍一下geoserver wtms服务叠加。geoserver 发布两个地图切片服务分别为test1:test1_linegroup和test1:test1_pointgroup。test1:是工作空间test1_linegroup：图层组test1_pointgroup：图层组f

2013-08-01 19:43:17 5006 4

原创 geoserver + postgis+postgresql+agslib.swc

运用开源的geoserver+postgis+postgresql+arcgis for flex api 开发地图应用系统。1.Geoserver GeoServer 是 OpenGIS Web 服务器规范的 J2EE 实现的社区开源项目，利用 GeoServer 可以方便的发布地图数据，允许用户对特征数据进行更新、删除、插入操作，通过 GeoServer 可以比较容易的

2013-07-31 21:50:17 2155

原创 TiledMapServiceLayer扩展

扩展TiledMapServiceLayer agslib 是免费的可以进行扩张，加载天地图、google地图，geoserver wmts服务。1．重载TiledMapServiceLayer接口类实现geoserver wmts瓦片地图的加载

2013-07-31 20:45:02 3393

转载 Flex特效

1：glow(发光)代码：alphaFrom="0.6" alphaTo="0.2" blurXFrom="0.0" blurXTo="50.0" blurYFrom="0.0" blurYTo="50.0" color="0xffffff"/>duratuion 是特效的时间 1000毫秒alphaFrom 是透明度从 0.6开始alphaTo 是透明

2013-07-13 11:26:56 1457

转载 Flex特效

http://www.noupe.com/adobe/flex-developers-toolbox-free-components-themes-and-tutorials.html经典中的经典 http://demo.quietlyscheming.com/fisheye/TileExplorer.html （2D）鱼眼效果 http://www.efflex.

2013-07-13 07:30:51 1611

原创 Flex 加载地图

一、Arcgis for Flex api方法介绍 a.AddLayer(layer:Layer, index:int = -1);向地图添加一个图层。 b.使用ActionScript地图上添加一层 var myGraphicsLayer:GraphicsLayer = new GraphicsLayer(); myMap.addLayer

2013-07-01 20:31:40 2512

转载 arcgis server部署服务地图无法预览

arcgis server部署服务地图无法预览一、确定问题1、打开ArcCatalog，停止地图服务。2、修改地图服务的输出路径（output directory）为None，此时Supported Image Return Type显示为MIME。3、启动地图服务，预览出来了，那么可以肯定问题是虚拟路径配置不正确。二、解决问题1、打开IIS，在默认网站下找到arcgiso

2013-06-29 09:05:50 2541

原创 java生成Excel

一.利用poi生成excel，介绍一下基本用法1.HSSFWorkbook workbook = new HSSFWorkbook();创建工作薄2.HSSFSheet sheet = workbook.createSheet("工资表");一个sheet最多有65535行3.HSSFRow row = sheet.createRow(0);创建行（最顶端，头部）;4.HSSFCe

2013-06-28 21:34:34 1070

原创 java动态代理

一．代理模式定义：为另一个对象提供一个替身或占位符以控制对这个对象的访问。使用Java API 的代理，创建一个保护代理。Java 在java.lang.reflect包中有自己的代理支持，利用这个包你可以在运行时动态的创建一个代理类，实现一个或多个接口，并将方法的调用转发到你所指定的类。因为实际的代理类是在运行时创建的，我们称这个Java技术为：动态代理。Java已经为你创建

2013-06-17 19:49:54 1108

原创 HttpURLConnection 用法

1.HttpURLConnection 获取服务端返回信息 public void getInfo() throws IOException{ String respContent = "" ; int code = 200; String geoUrl = "http://www.hao123.com/?tn=98012088_1_hao_pg";

2013-06-16 10:26:45 1771

原创 Blob类型转换为byte数组类型

Blob类型转换成byte数组类型存储到Oracle数据库import java.io.BufferedInputStream;import java.io.IOException;import java.sql.Blob;public class BlobToBytes { /** * 把Blob类型转换为byte数组类型 * * @param blo

2013-06-15 21:18:21 21739

原创 java 日期处理

1.二个小时时间间的差值,必须保证二个时间都是"HH:MM"的格式，返回字符型的分钟2.得到二个日期间的间隔天数3.得到一个时间延后或前移几天的时间,nowdate为时间,delay为前移或后延的天数4.判断二个时间是否在同一个周5.产生周序列,即得到当前时间所在的年度是第几周....

2013-06-15 20:58:29 1317

原创 HibernateTemplate常用方法

一. HibernateTemplate常用方法 void delete(Object entity)：删除指定持久化实例 deleteAll(Collection entities)：删除集合内全部持久化类实例 find(String queryString)：根据HQL查询字符串来返回实例集合 findByNamedQu

2013-06-15 14:37:58 1874

原创 Spring声明式事务XML配置

Spring声明式事务功能应该是大家应用Spring中使用的最多的功能之一了，的确该功能极大的简化了大家对数据库操作的。目前Spring支持的声明式事务有两个配置方式，一种是XML配置方式，另一种是注解方式。在开发中最常用的还是XML配置方式。PROPAGATION_REQUIRED使用当前事务，如果当前没有事务，则开启新事务。（常用） <bean id="txManager"

2013-06-15 11:34:38 1953

原创 java 读取请求地址

1.java 获取请求URL ，进行编码 java.net.URLEncoder.encode。 public String getRequestUrl(HttpServletRequest req,HttpServletResponse resp) throws UnsupportedEncodingException, ParseException{ String quer

2013-06-15 09:30:57 1415

原创 postgis 常用函数

一.坐标处理 1.ST_AsText(geometry g1); 取得坐标。例如：ST_AsText(geom)值为： POINT(118.84639183778 37.4281744123688) 2.ST_GeomFromText(text WKT, integersrid);将坐标转化成geom。例如：ST_GeomFromText('point(118.84639183

2013-06-14 22:47:50 4116

原创 java 反射工厂

工厂方法模式定义：定义了一个创建对象的接口，但由子类决定要实例化的类是哪一个。工厂方法让类把实例化推迟到子类。UML类图：所有工厂模式都用来封装对象的创建。工厂方法模式通过让子类决定改创建的对象是什么，来达到将对象创建的过程封装的目的。1. Creator所有子类都必须实现这个抽象的factoryMethod()方法。2. ConcreteCreator

2013-06-13 19:16:38 1717

原创 Spring Aop 配置

1.切面类：在方法前后加逻辑（日志，执行时间...）。package com.tech.allen.util;import org.aspectj.lang.JoinPoint;import org.aspectj.lang.ProceedingJoinPoint; public class AspectClass { public void doBefore

2013-06-12 16:51:29 1083

原创改变flex tree节点图标

<mx:Tree x="9" y="8" defaultLeafIcon="@Embed(source='img/Tree_defaultLeafIcon.png')" folderClosedIcon="@Embed(source='img/folder-close.png')" folderOpenIcon="@Embed(source='img/fo

2013-06-11 14:33:31 1141

pdi-ce-stable-JDBC

kettle JDBC连接数据库驱动，kettle JDBC连接数据库驱动

2014-05-28

JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。 • StreamMessage -- Java原始值的数据流 • MapMessage--一套名称-值对 • TextMessage--一个字符串对象 • ObjectMessage--一个序列化的 Java对象 • BytesMessage--一个未解释字节的数据流

2013-12-02