---

layout: global type: “page singular” title: Spark Structured Streaming description: Spark Structured Streaming makes it easy to build streaming applications and pipelines with the same and familiar Spark APIs. subproject: Streaming

<div style="margin-top: 15px; text-align: left; display: inline-block;">
  <div class="code">
    spark<br/>
    &nbsp;&nbsp;.<span class="sparkop">readStream</span><br/>
    &nbsp;&nbsp;.<span class="sparkop">select</span>(<span class="closure">$"value"</span>.cast(<span class="closure">"string"</span>).alias(<span class="closure">"jsonData"</span>))<br/>
    &nbsp;&nbsp;.<span class="sparkop">select</span>(from_json(<span class="closure">$"jsonData"</span>,jsonSchema).alias(<span class="closure">"payload"</span>))<br/>
    &nbsp;&nbsp;.<span class="sparkop">writeStream</span><br/>
    &nbsp;&nbsp;.<span class="sparkop">trigger</span>(<span class="closure">"1 seconds"</span>)<br/>
    &nbsp;&nbsp;.<span class="sparkop">start</span>()
  </div>
</div>