Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
From: Hilmi Yildirim <hilmi.yildirim@neofonie.de>
Message-ID: <555C4AD9.2090009@neofonie.de>
Date: Wed, 20 May 2015 10:50:33 +0200
User-Agent: Mozilla/5.0 (X11; Linux x86_64;
 rv:31.0) Gecko/20100101 Thunderbird/31.7.0
MIME-Version: 1.0
To: user@flink.apache.org
Subject: Re: Write Stream to HBase
References: <555C42F9.5020900@neofonie.de>
 <CAELUF_BiRJ9mxUeHWjveivzZpDPquppLpD7WiTV_w5XFOAoKAQ@mail.gmail.com>
In-Reply-To: 
 <CAELUF_BiRJ9mxUeHWjveivzZpDPquppLpD7WiTV_w5XFOAoKAQ@mail.gmail.com>
Content-Type: multipart/alternative;
 boundary="------------070709040500000702090905"

This is a multi-part message in MIME format.
--------------070709040500000702090905
Content-Type: text/plain; charset=utf-8; format=flowed
Content-Transfer-Encoding: 8bit

Thank you Flavio,
these are examples for Batch Processing. But I want to write a 
continuous stream into an HBase within a StreamExecutionEnvironment 
instead of a ExecutionEnvironment.

Best Regards,
Hilmi

Am 20.05.2015 um 10:42 schrieb Flavio Pompermaier:
> I've added an example of HBase writing 
> at flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java. 
>
> Otherwise you can look at these 2 URLs:
>
>   * https://github.com/fpompermaier/flink/blob/hbaseOutExample/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java
>   * https://github.com/apache/flink/blob/57615aaa19e9933e43ed0431a78dd231bf98b103/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java
>
> Best,
> Flavio
>
> On Wed, May 20, 2015 at 10:16 AM, Hilmi Yildirim 
> <hilmi.yildirim@neofonie.de <mailto:hilmi.yildirim@neofonie.de>> wrote:
>
>     Hi,
>     I want to write a stream continuously into an HBase. For example,
>     I have 1 source and 4 workers. I want that each worker writes
>     autonomously into HBase. Is there a proper way to do it?
>
>     Best Regards,
>
>     -- 
>     --
>     Hilmi Yildirim
>     Software Developer R&D
>
>     T: +49 30 24627-281 <tel:%2B49%2030%2024627-281>
>     Hilmi.Yildirim@neofonie.de <mailto:Hilmi.Yildirim@neofonie.de>
>
>     http://www.neofonie.de
>
>     Besuchen Sie den Neo Tech Blog für Anwender:
>     http://blog.neofonie.de/
>
>     Folgen Sie uns:
>     https://plus.google.com/+neofonie
>     http://www.linkedin.com/company/neofonie-gmbh
>     https://www.xing.com/companies/neofoniegmbh
>
>     Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin
>     Handelsregister Berlin-Charlottenburg: HRB 67460
>     Geschäftsführung: Thomas Kitlitschko
>
>
>

-- 
--
Hilmi Yildirim
Software Developer R&D

T: +49 30 24627-281
Hilmi.Yildirim@neofonie.de

http://www.neofonie.de

Besuchen Sie den Neo Tech Blog für Anwender:
http://blog.neofonie.de/

Folgen Sie uns:
https://plus.google.com/+neofonie
http://www.linkedin.com/company/neofonie-gmbh
https://www.xing.com/companies/neofoniegmbh

Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin
Handelsregister Berlin-Charlottenburg: HRB 67460
Geschäftsführung: Thomas Kitlitschko


--------------070709040500000702090905
Content-Type: text/html; charset=utf-8
Content-Transfer-Encoding: 8bit

<html>
  <head>
    <meta content="text/html; charset=utf-8" http-equiv="Content-Type">
  </head>
  <body bgcolor="#FFFFFF" text="#000000">
    Thank you Flavio,<br>
    these are examples for Batch Processing. But I want to write a
    continuous stream into an HBase within a StreamExecutionEnvironment
    instead of a ExecutionEnvironment.<br>
    <br>
    Best Regards,<br>
    Hilmi<br>
    <br>
    <div class="moz-cite-prefix">Am 20.05.2015 um 10:42 schrieb Flavio
      Pompermaier:<br>
    </div>
    <blockquote
cite="mid:CAELUF_BiRJ9mxUeHWjveivzZpDPquppLpD7WiTV_w5XFOAoKAQ@mail.gmail.com"
      type="cite">
      <div dir="ltr">I've added an example of HBase writing
at flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java.
        <div>Otherwise you can look at these 2 URLs:</div>
        <div>
          <ul>
            <li><a moz-do-not-send="true"
href="https://github.com/fpompermaier/flink/blob/hbaseOutExample/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java">https://github.com/fpompermaier/flink/blob/hbaseOutExample/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java</a></li>
            <li><a moz-do-not-send="true"
href="https://github.com/apache/flink/blob/57615aaa19e9933e43ed0431a78dd231bf98b103/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java">https://github.com/apache/flink/blob/57615aaa19e9933e43ed0431a78dd231bf98b103/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java</a></li>
          </ul>
          <div>Best,</div>
        </div>
        <div>Flavio</div>
        <div class="gmail_extra"><br>
          <div class="gmail_quote">On Wed, May 20, 2015 at 10:16 AM,
            Hilmi Yildirim <span dir="ltr">&lt;<a
                moz-do-not-send="true"
                href="mailto:hilmi.yildirim@neofonie.de" target="_blank">hilmi.yildirim@neofonie.de</a>&gt;</span>
            wrote:<br>
            <blockquote class="gmail_quote" style="margin:0 0 0
              .8ex;border-left:1px #ccc solid;padding-left:1ex">Hi,<br>
              I want to write a stream continuously into an HBase. For
              example, I have 1 source and 4 workers. I want that each
              worker writes autonomously into HBase. Is there a proper
              way to do it?<br>
              <br>
              Best Regards,<br>
              <br>
              -- <br>
              --<br>
              Hilmi Yildirim<br>
              Software Developer R&amp;D<br>
              <br>
              T: <a moz-do-not-send="true"
                href="tel:%2B49%2030%2024627-281" value="+493024627281"
                target="_blank">+49 30 24627-281</a><br>
              <a moz-do-not-send="true"
                href="mailto:Hilmi.Yildirim@neofonie.de" target="_blank">Hilmi.Yildirim@neofonie.de</a><br>
              <br>
              <a moz-do-not-send="true" href="http://www.neofonie.de"
                target="_blank">http://www.neofonie.de</a><br>
              <br>
              Besuchen Sie den Neo Tech Blog für Anwender:<br>
              <a moz-do-not-send="true" href="http://blog.neofonie.de/"
                target="_blank">http://blog.neofonie.de/</a><br>
              <br>
              Folgen Sie uns:<br>
              <a moz-do-not-send="true"
                href="https://plus.google.com/+neofonie" target="_blank">https://plus.google.com/+neofonie</a><br>
              <a moz-do-not-send="true"
                href="http://www.linkedin.com/company/neofonie-gmbh"
                target="_blank">http://www.linkedin.com/company/neofonie-gmbh</a><br>
              <a moz-do-not-send="true"
                href="https://www.xing.com/companies/neofoniegmbh"
                target="_blank">https://www.xing.com/companies/neofoniegmbh</a><br>
              <br>
              Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin<br>
              Handelsregister Berlin-Charlottenburg: HRB 67460<br>
              Geschäftsführung: Thomas Kitlitschko<br>
              <br>
            </blockquote>
          </div>
          <br>
          <div class="gmail_signature">
            <div dir="ltr"><br>
            </div>
          </div>
        </div>
      </div>
    </blockquote>
    <br>
    <pre class="moz-signature" cols="72">-- 
--
Hilmi Yildirim
Software Developer R&amp;D

T: +49 30 24627-281
<a class="moz-txt-link-abbreviated" href="mailto:Hilmi.Yildirim@neofonie.de">Hilmi.Yildirim@neofonie.de</a>

<a class="moz-txt-link-freetext" href="http://www.neofonie.de">http://www.neofonie.de</a>

Besuchen Sie den Neo Tech Blog für Anwender:
<a class="moz-txt-link-freetext" href="http://blog.neofonie.de/">http://blog.neofonie.de/</a>

Folgen Sie uns:
<a class="moz-txt-link-freetext" href="https://plus.google.com/+neofonie">https://plus.google.com/+neofonie</a>
<a class="moz-txt-link-freetext" href="http://www.linkedin.com/company/neofonie-gmbh">http://www.linkedin.com/company/neofonie-gmbh</a>
<a class="moz-txt-link-freetext" href="https://www.xing.com/companies/neofoniegmbh">https://www.xing.com/companies/neofoniegmbh</a>

Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin
Handelsregister Berlin-Charlottenburg: HRB 67460
Geschäftsführung: Thomas Kitlitschko
</pre>
  </body>
</html>

--------------070709040500000702090905--