小编tha*_*_DG的帖子

Hive动态分区

我正在尝试使用动态分区创建分区表,但我遇到了一个问题.我在Hortonworks Sandbox 2.0上运行Hive 0.12.

set hive.exec.dynamic.partition=true;
INSERT OVERWRITE TABLE demo_tab PARTITION (land)
SELECT stadt, geograph_breite, id, t.country
FROM demo_stg t;
Run Code Online (Sandbox Code Playgroud)

但它不起作用..我得到一个错误.

这是创建表demo_stg的Query :

create table demo_stg
(
    country STRING,
    stadt STRING,
    geograph_breite FLOAT,
    id INT
    )
ROW FORMAT DELIMITED FIELDS TERMINATED BY "\073";
Run Code Online (Sandbox Code Playgroud)

demo_tab:

CREATE TABLE demo_tab 
(
    stadt STRING,
    geograph_breite FLOAT,
    id INT
)
PARTITIONED BY (land STRING)
ROW FORMAT DELIMITED FIELDS TERMINATED BY "\073";
Run Code Online (Sandbox Code Playgroud)
  • demo_stg也填充了数据,所以它不是空的.

感谢帮助 :)

hadoop hive hiveql

11
推荐指数
2
解决办法
5万
查看次数

Cats:Monads的非尾递归tailRecM方法

cat中,当使用Monadtrait 创建Monad时,tailRecM应该提供方法的实现.

我有一个下面的场景,我发现不可能提供尾部递归实现 tailRecM

  sealed trait Tree[+A]

  final case class Branch[A](left: Tree[A], right: Tree[A]) extends Tree[A]

  final case class Leaf[A](value: A) extends Tree[A]

  implicit val treeMonad = new Monad[Tree] {

    override def pure[A](value: A): Tree[A] = Leaf(value)

    override def flatMap[A, B](initial: Tree[A])(func: A => Tree[B]): Tree[B] =
      initial match {
        case Branch(l, r) => Branch(flatMap(l)(func), flatMap(r)(func))
        case Leaf(value) => func(value)
      }

    //@tailrec
    override def tailRecM[A, B](a: A)(func: (A) => Tree[Either[A, B]]): Tree[B] = { …
Run Code Online (Sandbox Code Playgroud)

recursion functional-programming scala scala-cats

11
推荐指数
2
解决办法
845
查看次数

快速,轻量级的XML解析器

我有一个特定的格式XML文档,我将推动.此文档将始终为相同类型,因此非常严格.

我需要解析这个,以便我可以将它转换为JSON(嗯,一个稍微混淆的版本,所以其他人可以使用它与DOJO).

我的问题是,我是否应该使用非常快速的轻量级(不需要SAX等)XML解析器(任何想法?)或编写我自己的,基本上转换为StringBuffer并旋转数组?基本上,我假设所有HTML解析器都将通过字符串(或内存缓冲区)旋转并解析,从而产生输出.

谢谢

编辑

xml将介于3/4行到最大约50行之间(极端情况下).

java xml dojo json

10
推荐指数
2
解决办法
2万
查看次数

org.hibernate.LazyInitializationException:如何正确使用Hibernate的延迟加载功能

使用Hibernate和lazy = true模式从数据库加载对象列表时遇到了一些问题.希望有人可以帮助我.

我在这里有一个名为UserAccount的简单类,如下所示:

public class UserAccount {
    long id;
    String username;
    List<MailAccount> mailAccounts = new Vector<MailAccount>();

    public UserAccount(){
        super();
    }

    public long getId(){
        return id;
    }

    public void setId(long id){
        this.id = id;
    }

    public String getUsername(){
        return username;
    }

    public void setUsername(String username){
        this.username = username;
    }

    public List<MailAccount> getMailAccounts() {
        if (mailAccounts == null) {
            mailAccounts = new Vector<MailAccount>();
        }
        return mailAccounts;
    }

    public void setMailAccounts(List<MailAccount> mailAccounts) {
        this.mailAccounts = mailAccounts;
    }
}
Run Code Online (Sandbox Code Playgroud)

我通过以下映射文件在Hibernate中映射此类:

<?xml version="1.0"?>
<!DOCTYPE …
Run Code Online (Sandbox Code Playgroud)

java hibernate

9
推荐指数
2
解决办法
3万
查看次数

连接语句中出现错误"ORA-00932:不一致的数据类型:预期 - 得到了BLOB"

我在下面的存储过程中执行有问题.当我在下面的存储过程中添加列时,我
收到错误.是一个blob字段.如果我删除这个字段一切正常.我不知道为什么会这样.请帮忙....ORA-00932: inconsistent datatypes: expected - got BLOBFM.FAXFILE_BLOBFAXFILE_BLOB




        CREATE OR REPLACE Procedure HCADMIN.Proc_GetFaxDetailsByDate
         ( 
           FromDate varchar2 default null,
           ToDate varchar2 default null,
           FaxNo varchar2 default null,
           ClaimNo varchar2 default null,
            NspCode varchar2 default null,
           PolicyNo varchar2 default null,
           HEGICNo varchar2 default null,
           cur_faxdetails OUT SYS_REFCURSOR
           )
        IS
       BEGIN
      OPEN cur_faxdetails For

      Select distinct
       FM.RECORDNO_NUM,
       FM.CLAIMNO_VAR,
       FM.FAXNO_VAR,
       FM.FAXSTATUS_VAR,
       FM.FAXTYPE_VAR,
       FM.USERNAME_VAR,
       FM.HEGIC_NO_VAR, 
       FM.RESEND_NO_NUM,
       FM.RESNDCOUNT_NUM,
       TO_date(FM.TIMESTAMP_DTE,'dd/MM/yyyy') as "TIMESTAMP_DTE",
       FR.RECIPIENTFAXNO_VAR,
       FM.FAXFILE_BLOB

       From TPA_FAXMASTER FM Left  join TPA_FAXRECIPIENT FR on                                      FM.RECORDNO_NUM=FR.RECORDNO_NUM 
 WHERE …
Run Code Online (Sandbox Code Playgroud)

sql database oracle join ora-00932

9
推荐指数
1
解决办法
2万
查看次数

如何在scala中削减for-comprehension short(突破它)?

我有一段代码,代码如下:

val e2 = for (e <- elements if condition(expensiveFunction(e))) yield {
            expensiveFunction(e)
         }
Run Code Online (Sandbox Code Playgroud)

条件对于少数元素是正确的,然后对所有剩余的元素变为假.

不幸的是,这不起作用(即使我忽略性能)因为我elements是一个无限的迭代器.

有没有办法在for-comprehension中使用"break",这样当某个条件成立时它会停止产生元素?否则,计算我的scala-idiomatic方法是e2什么?

scala break infinite-sequence for-comprehension

9
推荐指数
2
解决办法
5332
查看次数

Scala Futures如何与flatMap链接在一起?

我正在Scala中第一次使用Futures,正在研究使用flatMap组合器的例子; 我一直在关注这个讨论:

http://docs.scala-lang.org/overviews/core/futures.html

具体来说,这个例子:

val usdQuote = future { connection.getCurrentValue(USD) }
val chfQuote = future { connection.getCurrentValue(CHF) }
val purchase = for {
    usd <- usdQuote
    chf <- chfQuote
      if isProfitable(usd, chf)
} yield connection.buy(amount, chf)

purchase onSuccess {
    case _ => println("Purchased " + amount + " CHF")
}
Run Code Online (Sandbox Code Playgroud)

被翻译成这个:

val purchase = usdQuote flatMap {
    usd =>
         chfQuote
        .withFilter(chf => isProfitable(usd, chf))
        .map(chf => connection.buy(amount, chf))
}
Run Code Online (Sandbox Code Playgroud)

我掌握一点麻烦的是如何以及何时执行flatMap?

我知道usdQuote和chfQuote是在"某个时间"由"某个线程"执行的,并且它们的注册回调函数被调用,问题是:

a)usdQuote和chfQuote是否同时执行?(我很确定他们是).

b)flatMap如何将Future useQuote的值分配给usd?在操作usdQuote完成时,是否会调用它?

c)什么线程正在执行'flatMap'和'map'操作(可能更多是后一个问题的后续操作).

干杯.

monads scala future

9
推荐指数
1
解决办法
7213
查看次数

`git reset --hard master`和`git reset --hard origin/master`有什么区别?

我在Stackoverflow /其他地方尝试了很多链接,以正确理解其行为

git reset --hard option

我知道:

  • 如果省略或如果它被删除origin,则在最近的提交中完成重置origin
  • 如果提供SHA1哈希,则在相应的提交上完成重置.

我不明白的是以下值:

  1. origin
  2. HEAD
  3. origin/master
  4. origin/branch

所有似乎都有相同的行为,即他们指向最新的提交master.

请解释上面提供的所有4值选项的重要性.

我还想知道我是否在特定分支上如何重置为该分支上的最后一次提交?例如v1.2,如果我在,origin/v1.2仍然会带我到最新的提交master.

git version-control github git-reset

9
推荐指数
1
解决办法
2万
查看次数

如何降低recaptcha难度级别

reCAPTCHA生成的一些验证码是不可读的.我们可以使用任何配置来降低reCAPTCHA的难度级别(我使用的是reCAPTCHA PHP API)

或者是否有任何reCAPTCHA服务不使用php gd库?

php recaptcha

7
推荐指数
1
解决办法
4354
查看次数

如何在spring项目中使用自定义anotation(hibernate)加密/解密数据

我正在为一个项目开发一些RESTFull Web服务.我使用Spring框架并使用gradle进行构建.问题是,我想在写入和读取数据时加密和解密数据表.我已经有了一个用AES等加密和解密数据的算法(类).我需要的是,如何注释这个方法来休眠实体类,我需要为这个类创建bean吗?

例如: -

@Column(columnDefinition= "LONGBLOB", name = "card_no")
        @ColumnTransformer(
                read="decrypt(card_no)",
                write="encrypt(?)")
        private String cardNo;
Run Code Online (Sandbox Code Playgroud)

像这样我想在这里添加我自己的加密/解密java方法.

java encryption hibernate jpa interceptor

6
推荐指数
2
解决办法
9800
查看次数