StructuredStreamingKinesis¶
Reads in streaming text from Kinesis stream
Input¶
It does not take any DataFrame as input
Output¶
It reads events from Kinesis and creates DataFrame from the resulting rows. This DataFrame is passed to the output Nodes.
Type¶
sparkstreaming
Class¶
fire.nodes.structuredstreaming.NodeStructuredStreamingKinesis
Fields¶
| Name | Title | Description |
|---|---|---|
| streamName | Stream Name | Kinesis Stream Name |
| endpointUrl | Endpoint Url | Kinesis Endpoint Url |
| editorData | Editor Data | Data to be used for testing in the Workflow Editor |