title: Hazelcast jet data loading
body: <p>I'm trying to load database data into hazelcast jet map instance</p>
  <pre><code>public void sourceStage(JetInstance jet, Pipeline pipeLine){
  SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
      dataSource.setDriver(new org.postgresql.Driver());
      dataSource.setUrl(&quot;jdbc:postgresql://localhost/development&quot;);
      dataSource.setUsername(&quot;postgres&quot;);
      dataSource.setPassword(&quot;root&quot;);
      JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
      String sql1 = &quot;SELECT  id1 , id2 FROM public.tbl_data where name='india'&quot;;
      jdbcTemplate.query(sql1, new RowMapper&lt;Object&gt;() {
          @Override
          public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
              jet.getMap(&quot;t1&quot;).put(rs.getString(&quot;id1&quot;), rs.getString(&quot;id2&quot;));
              return null;
          }
      });
  }
  </code></pre>
  <p>and again trying to use same map as source in the pipe line</p>
  <pre><code>        pipeLine.readFrom(Sources.map(&quot;t1&quot;)).map(map -&gt; {
              System.err.println(map.getKey() + &quot;---&quot; + map.getValue());
              return map;
          }).writeTo(Sinks.logger());
  </code></pre>
  <p>and I see I'm not able to read the data as source.
  but if check <code>jet.getMap(&quot;t1&quot;).size()</code>
  I'm getting the size value.</p>