小编war*_*que的帖子

猪 - 分裂,缺乏默认或if/else

由于猪分割操作中没有其他或默认语句,以下是最优雅的方法吗?我不是必须复制粘贴代码的忠实粉丝.

SPLIT rawish_data
    INTO good_rawish_data IF (
    (uid > 0L) AND
    (value1 > 0) AND
    (value1 < 100) AND
    (value1 IS NOT NULL) AND
    (value2 > 0L) AND
    (value2 < 200L) AND
    (value3 >= 0) AND
    (value3 <= 300)),

    bad_rawish_data IF (NOT (
    (uid > 0L) AND
    (value1 > 0) AND
    (value1 < 100) AND
    (value1 IS NOT NULL) AND
    (value2 > 0L) AND
    (value2 < 200L) AND
    (value3 >= 0) AND
    (value3 <= 300)));
Run Code Online (Sandbox Code Playgroud)

我想做点什么

SPLIT data
    INTO good_data …
Run Code Online (Sandbox Code Playgroud)

apache-pig

6
推荐指数
1
解决办法
6972
查看次数

如何限制并行运行的某些管道的数量?

我想允许并行运行以下管道,但由于资源有限,我必须限制并行运行的最大数量。

pipeline {

  agent { label "$JENKINS_AGENT" }
  parameters { .. }
  options { .. }

  stages {
    stage('Checkout') { .. }
    stage('Config') { .. }
    stage('Deploy') { .. }
    stage('Test') { .. }
  }

  post {
    failure { .. }
    success { .. }
    always {
      cleanup()
    }
  }
}
Run Code Online (Sandbox Code Playgroud)

例如,如果我仅限于 3 个部署,我该如何实现这一目标?

编辑:我目前已将以下内容添加到我的 jenkinsfile 中。似乎有效,但我不确定这是否是正确的方法。(使用Throttle 并发构建插件

properties([
  [
    $class: 'ThrottleJobProperty',
    categories: ['parallel_pipeline'],
    limitOneJobWithMatchingParams: false,
    maxConcurrentPerNode: 3,
    maxConcurrentTotal: 3,
    paramsToUseForLimit: '',
    throttleEnabled: true,
    throttleOption: 'project' …
Run Code Online (Sandbox Code Playgroud)

jenkins jenkins-pipeline

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

将功能分支变基/复制到旧版本

我想将提交从一个分支反向移植到一个较旧的分支。我该怎么做?我知道我可以例如一个一个地挑选每个提交,但是最简单的方法是什么?

由此:

___(a)__(b)__(c)__(d)__(e)__(f)__(g) <- master
    \    \             /
     \    (1)__(2)__(3) <- feature
      \
       (x)__(y)__(z) <- old release
Run Code Online (Sandbox Code Playgroud)

对此:

___(a)__(b)__(c)__(d)__(e)__(f)__(g) <- master
    \    \             /
     \    (1)__(2)__(3) <- feature
      \
       (x)__(y)__(z)__(1)__(2)__(3) <- old release with feature
Run Code Online (Sandbox Code Playgroud)

git

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

在 Scala 中初始化任意类型数组

如何将类型 A 的数组初始化为与其他数组具有相同的长度?(在本例中,A 是 String 或 Int)

  def init_arr_with_same_len[A](arr1: Array[A]): Array[A] = {
    val len = arr1.length
    val arr2 = new Array[A](len)
    arr2
  }
Run Code Online (Sandbox Code Playgroud)

scala

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

标签 统计

apache-pig ×1

git ×1

jenkins ×1

jenkins-pipeline ×1

scala ×1