@Test void testUpstreamNode_duplicate() { SdkWorkflowBuilder builder = new SdkWorkflowBuilder(); SdkNode node1 = builder.apply("node1", new PrintHello()); IllegalArgumentException e = Assertions.assertThrows( IllegalArgumentException.class, () -> node1.apply("node2", new PrintHello().withUpstreamNode(node1))); assertEquals("Duplicate upstream node ids [node1]", e.getMessage()); }
public SdkNode apply(String nodeId, SdkTransform transform) { return applyInternal(nodeId, transform, emptyList(), Collections.emptyMap()); }
SdkWorkflowBuilder { public SdkNode apply(String nodeId, SdkTransform transform) { return applyInternal(nodeId, transform, emptyList(), Collections.emptyMap()); } }
SdkWorkflowBuilder { public SdkNode apply(String nodeId, SdkTransform transform) { return applyInternal(nodeId, transform, emptyList(), Collections.emptyMap()); } SdkWorkflowBuilder(); }
SdkWorkflowBuilder { public SdkNode apply(String nodeId, SdkTransform transform) { return applyInternal(nodeId, transform, emptyList(), Collections.emptyMap()); } SdkWorkflowBuilder(); SdkNode apply(String nodeId, SdkTransform transform); SdkNode apply(String nodeId, SdkTransform transform, Map<String, SdkBindingData> inputs); static SdkBindingData literalOfInteger(long value); static SdkBindingData literalOfFloat(double value); static SdkBindingData literalOfString(String value); static SdkBindingData literalOfBoolean(boolean value); static SdkBindingData literalOfDatetime(Instant value); static SdkBindingData literalOfDuration(Duration value); SdkBinding mapOf(String name1, SdkBindingData value1); SdkBinding mapOf(
      String name1, SdkBindingData value1, String name2, SdkBindingData value2); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3,
      String name4,
      SdkBindingData value4); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3,
      String name4,
      SdkBindingData value4,
      String name5,
      SdkBindingData value5); SdkBinding tupleOf(SdkNode... nodes); SdkBindingData inputOfInteger(String name); SdkBindingData inputOfInteger(String name, String help); SdkBindingData inputOfString(String name); SdkBindingData inputOfString(String name, String help); SdkBindingData inputOfBoolean(String name); SdkBindingData inputOfBoolean(String name, String help); SdkBindingData inputOfDatetime(String name); SdkBindingData inputOfDatetime(String name, String help); SdkBindingData inputOfDuration(String name); SdkBindingData inputOfDuration(String name, String help); SdkBindingData inputOfFloat(String name); SdkBindingData inputOfFloat(String name, String help); void output(String name, SdkBindingData value); void output(String name, SdkBindingData value, String help); void applyInternal(SdkNode node); WorkflowTemplate toIdlTemplate(); }
SdkWorkflowBuilder { public SdkNode apply(String nodeId, SdkTransform transform) { return applyInternal(nodeId, transform, emptyList(), Collections.emptyMap()); } SdkWorkflowBuilder(); SdkNode apply(String nodeId, SdkTransform transform); SdkNode apply(String nodeId, SdkTransform transform, Map<String, SdkBindingData> inputs); static SdkBindingData literalOfInteger(long value); static SdkBindingData literalOfFloat(double value); static SdkBindingData literalOfString(String value); static SdkBindingData literalOfBoolean(boolean value); static SdkBindingData literalOfDatetime(Instant value); static SdkBindingData literalOfDuration(Duration value); SdkBinding mapOf(String name1, SdkBindingData value1); SdkBinding mapOf(
      String name1, SdkBindingData value1, String name2, SdkBindingData value2); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3,
      String name4,
      SdkBindingData value4); SdkBinding mapOf(
      String name1,
      SdkBindingData value1,
      String name2,
      SdkBindingData value2,
      String name3,
      SdkBindingData value3,
      String name4,
      SdkBindingData value4,
      String name5,
      SdkBindingData value5); SdkBinding tupleOf(SdkNode... nodes); SdkBindingData inputOfInteger(String name); SdkBindingData inputOfInteger(String name, String help); SdkBindingData inputOfString(String name); SdkBindingData inputOfString(String name, String help); SdkBindingData inputOfBoolean(String name); SdkBindingData inputOfBoolean(String name, String help); SdkBindingData inputOfDatetime(String name); SdkBindingData inputOfDatetime(String name, String help); SdkBindingData inputOfDuration(String name); SdkBindingData inputOfDuration(String name, String help); SdkBindingData inputOfFloat(String name); SdkBindingData inputOfFloat(String name, String help); void output(String name, SdkBindingData value); void output(String name, SdkBindingData value, String help); void applyInternal(SdkNode node); WorkflowTemplate toIdlTemplate();  }