小编Sre*_*ith的帖子

我有如下风暴之箭,

 package storm.bolt;

import java.util.Map;

import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.MultiTableBatchWriter;
import org.apache.accumulo.core.client.TableExistsException;
import org.apache.accumulo.core.client.TableNotFoundException;
import org.apache.accumulo.core.client.ZooKeeperInstance;
import org.apache.accumulo.core.data.Mutation;
import org.apache.accumulo.core.data.Value;
import org.apache.hadoop.io.Text;


import backtype.storm.task.OutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.IRichBolt;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.tuple.Tuple;

public class AccumuloBolt implements IRichBolt {

    private static final long serialVersionUID = 1L;
    private OutputCollector collector;
    private ZooKeeperInstance instance;
    private Connector connector;
    private BatchWriter bw;
    private Text colf;
    private MultiTableBatchWriter mtbw;
    private final String instanceName;
    private final String zooServers;
    private final String userName; …

我有这个错误请求.

红色请求获取错误 - 400错误请求,它花费超过30秒.错误后套接字工作正常,但它需要更多的时间来响应

在app.js中,代码如下

 var app = express(),
      server = require('http').createServer(app); 
      //io = require('socket.io').listen(server);
      var sockets = require('socket.io')({
      'transports': ['websocket', 'flashsocket','htmlfile','xhr-polling','jsonp-polling']
      });
      var io = sockets.listen(server,{ resource: '/socket.io/','sync disconnect on unload':true });
io.sockets.on('connection', function(socket){
  socket.emit('server_emit');
  socket.on('search', function(cattype,pagNo,lang,film,iteamcat,starname){
    var query={'ProductType':cattype,'Language':lang,'ProductCategory':iteamcat,'UsedBy':starname,'UsedIn':film},
    field={},
    options={};

    db.collection("Product").find(query,field,options).toArray(function(error, Product2){     
      socket.emit('result',Product2);
    });




  });

在客户端代码中

<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect();
        socket.on('server_emit', function(){
                console.log("Server emitted to Browser")
        });

</script>

请帮忙

我是Pentaho数据集成的新手; 我需要将一个数据库集成到另一个位置作为ETL Job.我想在ETL作业期间计算插入/更新的数量,并将该计数插入另一个表.谁可以帮我这个事？

我在MySQL数据库中有我的数据,我需要将d3.js中的数据可视化为气泡图.我有可能在Django框架中这样做,如果是这样的话怎么样？

是否有任何Facebook流API可用,例如Twitter Stream API？我只想要公开流式数据(Facebook帖子/评论).

有没有办法通过API获得这样的流？