Skip to main content

​
Configuration properties

Properties for the Channel are provided inside the configuration of a Topic.
KeyRequiredTypeDefaultDescription
targetYStringName of the Target.
custom-fieldsSet<String>Set of names of the Custom Fields.
accumulatebooleanfalseIf enabled, the messages will accumulate all of their tuples (from all the message chunks) and only publish them to the transaction manager when the message is sent.

​
YAML example

dlc:
  csv:
    topics:
      topic1:
        channels:
          - target: target1
            custom-fields:
              - calculator1
              - calculator2
              - calculator3
              - calculator4
              - calculator5

​
Java configuration

ChannelDescription Java object can be used for configuration in Java. The Object is used in the configuration of a Topic. Use NamedEntityResolverService to get Target or Column Calculator by name.
ParameterRequiredTypeDefaultDescription
targetDescriptionYITargetDescriptionThe Target associated with this channel.
customFieldsSet<ICustomFieldDescription>Set of Custom Fields which belong to the channel.
accumulatebooleanfalseIf enabled, the messages will accumulate all of their tuples (from all the message chunks) and only publish them to the transaction manager when the message is sent.

​
Java example

@Bean
public CsvTopicDescription topic1(NamedEntityResolverService namedEntityResolver) {
    return CsvTopicDescription.builder("topic1", "glob:file*.csv")
            .channel(ChannelDescription.builder(namedEntityResolver.getDlcTargetDescription("target1"))
                    .customFields(
                            Set.of(
                                    new CustomFieldDescription(
                                            "Calculator1",
                                            scope -> new ConstantCalculator<>("field1", 1)
                                    ),
                                    new AnonymousCustomFieldDescription(
                                            scope -> new ConstantCalculator<>("field1", scope.get("constant"))
                                    )
                            )
                    )
                    .build())
            .build();
}