Skip to content

Commit bce4642

Browse files
author
Kuba Nowakowski
committed
ForEach: add default value {"item1", "item2"} for Elements parameter
Prevents immediate validation error when node is added before user has a chance to fill in the field.
1 parent e001e43 commit bce4642

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

engine/flink/components/base/src/main/scala/pl/touk/nussknacker/engine/flink/util/transformer/ForEachTransformer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ object ForEachTransformer extends CustomStreamTransformer with Serializable {
2020

2121
@MethodToInvoke(returnType = classOf[Object])
2222
def invoke(
23-
@ParamName("Elements") elements: LazyParameter[util.Collection[AnyRef]],
23+
@ParamName("Elements") @DefaultValue("{\"item1\", \"item2\"}") elements: LazyParameter[util.Collection[AnyRef]],
2424
@OutputVariableName outputVariable: String
2525
): FlinkCustomStreamTransformation with ReturningType = {
2626
FlinkCustomStreamTransformation(

engine/lite/components/base/src/main/scala/pl/touk/nussknacker/engine/lite/components/ForEachTransformer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ object ForEachTransformer extends CustomStreamTransformer {
1515

1616
@MethodToInvoke(returnType = classOf[Object])
1717
def invoke(
18-
@ParamName("Elements") elements: LazyParameter[java.util.Collection[Any]],
18+
@ParamName("Elements") @DefaultValue("{\"item1\", \"item2\"}") elements: LazyParameter[java.util.Collection[Any]],
1919
@OutputVariableName outputVariable: String
2020
): LiteCustomComponent = {
2121
new ForEachTransformerComponent(elements, outputVariable)

0 commit comments

Comments
 (0)