title: Parsing json from incoming datastream to perform simple transformations in Flink
body: <p>I am using Apache Flink with AWS Kineses for the first time. Basically my objective is to transform incoming data from a Kinesis stream in such a way that I can perform simple transformations such as filtering and aggregating.</p>
  
  <p>I am adding the source using the below:</p>
  
  <pre><code>return env.addSource(new FlinkKinesisConsumer&lt;&gt;(inputStreamName, new SimpleStringSchema(), inputProperties));
  </code></pre>
  
  <p>Eventually when I am print the incoming stream I am getting json data in as expected:</p>
  
  <pre><code>final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  DataStream&lt;String&gt; input = createSourceFromStaticConfig(env);
  input.print();
  </code></pre>
  
  <p>This is a sample result of the print:</p>
  
  <blockquote>
    <p>{"event_num": "5530", "timestmap": "2019-03-04 14:29:44.882376",
    "amount": "80.4", "type": "Purchase"} {"event_num": "5531", "timestmap": "2019-03-04
    14:29:44.881379", "amount": "11.98", "type": "Service"}</p>
  </blockquote>
  
  <p>Can someone enlighten me how I can access these json elements in such a way that I can perform simple transformation such as, selecting only records containing "Service" as a type?</p>