Sink

note

A Sink cannot be defined via configuration properties but can be referenced by name.

Java Configuration

SinkDescription or AnonymousSinkDescription java object can be used for configuration in Java. The Object is used in the configuration of a Channel.

Additionally, a SinkDescription Spring Bean can be resolved in configuration properties of a channel by name under target-name as well as used in Java by name using the NamedEntityResolverService.

SinkDescription
Parameter Required Type Description
name Y String Name of the Sink.
targetStore Y String Name of the target store.
tuplePublisherFactory Y ITuplePublisherFactory Function which accepts DlcOperationScope and produces an ITuplePublisher.
AnonymousSinkDescription
Parameter Required Type Description
targetStore Y String Name of the target store.
tuplePublisherFactory Y ITuplePublisherFactory Function which accepts DlcOperationScope and produces an ITuplePublisher.