小编Am1*_*3zA的帖子

我想在数据库中更新我的一些表,并希望所有这些工作在1个事务中完成,首先我删除branchbuildin(表)中的一些条目并在此操作后插入新的一个当我插入并使用相同的buildingname输入时出现问题和branch_fk(因为我在这个表上有这个约束(uniqueConstraints = {@ UniqueConstraint(columnNames = {"buildingname","branch_fk"})}))但是当我不使用hibernate会话并使用普通的JDBC事务时我不喜欢没有这些问题.

List<Integer> allBranchBuilding = branchBuildingDao.getAllBranchBuildingID(pkId, sess);
            for (Integer integer : allBranchBuilding) {
                branchBuildingDao.delete(integer, sess); // delete kardane tamame BranchBuilding ha va tel haie aanha
            }

            Address myAdr = new Address();
            setAddress(myAdr, centralFlag, city, latit, longit, mainstreet, remainAdr, state);
            BranchBuildingEntity bbe = new BranchBuildingEntity();
            setBranchBuildingEntity(bbe, be, myAdr, city, centralFlag, latit, longit, mainstreet, buildingName, remainAdr, state, des);
            branchBuildingDao.save(bbe, sess);//Exception Occurred                

我在第一个方法中得到了我的会话:

        Session sess = null;
        sess = HibernateUtil.getSession();
        Transaction tx = sess.beginTransaction();

我创建了一个C#Windows表单,其中有一个DataGridView我可以添加或删除此DatagridView中的一些行,但现在我想知道如何保存我的更改,所以每次打开窗口时我都可以看到我添加的行.

PS:我必须提到我不想使用任何数据库,有什么解决方案吗？
是否可以使用C#应用程序设置执行此操作？

我想为我们的一些人实现数据重放,为此,我需要使用Kafka保留策略(因为我正在使用join,我需要窗口时间准确).PS我使用的是Kafka版本0.10.1.1

我将数据发送到这样的主题:

 kafkaProducer.send(
                    new ProducerRecord<>(kafkaTopic, 0, (long) r.get("date_time") ,r.get(keyFieldName).toString(), r)
            );

我创建这样的主题:

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopic
kafka-topics --zookeeper localhost --alter --topic myTopic --config retention.ms = 172800000 kafka-主题--zookeeper localhost --alter --topic myTopic --config segment.ms = 172800000

因此,通过以上设置,我应该将我的主题的保留时间设置为48小时.

我扩展TimestampExtractor以记录每条消息的实际时间.

public class ConsumerRecordOrWallclockTimestampExtractor implements TimestampExtractor {
    private static final Logger LOG = LoggerFactory.getLogger(ConsumerRecordOrWallclockTimestampExtractor.class);
    @Override
    public long extract(ConsumerRecord<Object, Object> consumerRecord) {
        LOG.info("TIMESTAMP : " + consumerRecord.timestamp() + " - Human readable : " + new Date(consumerRecord.timestamp())); …

我有一个数据帧，我想将其作为请求正文发送HTTP Post，最好的Sparky方法是什么？
如何控制HTTP请求的数量？如果记录数量变大，有没有办法将发送数据帧拆分为多个 HTTP Post 调用？

假设我的数据框是这样的：

+--------------------------------------+------------+------------+------------------+
|               user_id                |    city    | user_name  |   facebook_id    |
+--------------------------------------+------------+------------+------------------+
| 55c3c59d-0163-46a2-b495-bc352a8de883 | Toronto    | username_x | 0123482174440907 |
| e2ddv22d-4132-c211-4425-9933aa8de454 | Washington | username_y | 0432982476780234 |
+--------------------------------------+------------+------------+------------------+

我想要在 HTTP Post 请求正文中包含user_id和到此端点facebook_idlocalhost:8080/api/spark

当我想要检查用户名并检索此特定用户名的其他信息时,我的登录表有utf8字符集和utf8排序规则,hql查询给出了与小写和大写相同的结果.我应该为我的HQL查询做什么工作案例sesitive我使用Mysql 5和java hibernarte

这是我的疑问:

return queryManager.executeQueryUniqueResult("select b.login from BranchEntity b where b.userName = ?", username);

我想写这些SQL查询:

CREATE VIEW `uniaverage` AS 
  SELECT `averagegrade`.`mjr`,`averagegrade`.`lev`, 
     AVG(`averagegrade`.`average`) AS `uniAVG` 
  FROM `averagegrade` GROUP BY `averagegrade`.`lev`, `averagegrade`.`mjr`;

但是MySQL Query Browser给了我这个错误:

Operand Should Contain 1 column(s)

我在哪里读到我可以在超过1列使用group by !!! 我该如何解决这个错误？或者如何更改查询以获得相同的结果？

我在架构注册表中有3个不同的主题和3个Avro文件，我想流这些主题并将它们结合在一起并将它们写入一个主题。问题是我要加入的密钥与我将数据写入每个主题的密钥不同。

假设我们有以下3个Avro文件：
Alarm：

{
  "type" : "record",
  "name" : "Alarm",
  "namespace" : "com.kafkastream.schema.avro",
  "fields" : [ {
    "name" : "alarm_id",
    "type" : "string",
    "doc" : "Unique identifier of the alarm."
  }, {
    "name" : "ne_id",
    "type" : "string",
    "doc" : "Unique identifier of the  network element ID that produces the alarm."
  }, {
    "name" : "start_time",
    "type" : "long",
    "doc" : "is the timestamp when the alarm was generated."
  }, {
    "name" : "severity",
    "type" : [ "null", "string" …

我正在读取一个存储二进制文件的文件。在 python 中我可以轻松解码文件

>>> s = '0000000000A0A240'
>>> s.decode('hex')
'\x00\x00\x00\x00\x00\xa0\xa2@'
>>> import struct
>>> struct.unpack('d', s.decode('hex'))[0]
2384.0

现在我想用Java做同样的解码，我们有类似的东西吗？

我正在使用scipy.spatial(来自scipy.spatial import ConvexHull)来绘制一系列点的凸包.

import pylab as pl
from scipy.spatial import ConvexHull

pl.figure()  
pl.hold(True)  

points = np.concatenate((x, y), axis=1)

hull = ConvexHull(points)

pl.plot(points[:,0], points[:,1], 'ro')

for simplex in hull.simplices:
    pl.plot(points[simplex,0], points[simplex,1], 'dk--')    

问题是我没有正确理解什么是hull.simplices,我想找到在convexhull方面的点的索引,所以我可以使用这些索引从x和y得到点

我有两个JS对象,我想检查第一个Object是否具有所有第二个Object的键并执行某些操作,否则抛出异常.最好的方法是什么？

function(obj1, obj2){
    if(obj1.HasAllKeys(obj2)) {
         //do something
    }
    else{
         throw new Error(...);
    } 
};

例如,在下面的示例中,因为FirstObject具有所有SecondObject的键,所以它应该运行代码:

FirstObject
{
    a : '....',
    b : '...',
    c : '...',
    d : '...'
}
SecondObject
{    
    b : '...',    
    d : '...'
}

但是在下面的例子中我想抛出一个异常,因为在FirstObject中不存在XXX:

FirstObject
{
    a : '....',
    b : '...',
    c : '...',
    d : '...'
}
SecondObject
{    
    b : '...',    
    XXX : '...'
}