Associate the FilePollSource (reader) component with the AsapSink
(writer) component. The FilePollSource component reads records from file on the disk
(insert.txt) and transfers those records to the AsapSink component.
The AsapSink component then publishes those records to Event Stream Processor.
- Start Event Stream Processor.
| Operating System |
Step |
|---|
| UNIX |
Open a terminal window: - Start the example
cluster:
start_server_cluster.sh
- Start the project on the cluster:
start_project.sh
|
| Windows |
Open a command window:- Start the example cluster:
start_server_cluster.bat
- Add project to the cluster, and start it on the
cluster:
start_project.bat
|
- Start esp_subscriber to
subscribe to the project that is running on the cluster.
| Operating System |
Step |
|---|
| UNIX |
Open a terminal window and enter: ./esp-subscribe.sh
|
| Windows |
Open a command window and enter: esp-subscribe.bat
|
- Start the FilePollSource and AsapSink components.
| Operating System |
Step |
|---|
| UNIX |
Open a terminal window and enter: ./fileToAsap.sh
|
| Windows |
Open a command window and enter: fileToAsap.bat
|
The FilePollSource components reads from the
insert.txt file and passes records to AsapSink to
publish to the Server.
- In the fileToAsap.props file, change adaptor.FILESOURCE.InputFileName to insert_withNULL.txt,
and run again.