Tutorial by Examples: u

To run a flink program from your IDE(we can use either Eclipse or Intellij IDEA(preffered)), you need two dependencies:flink-java / flink-scala and flink-clients (as of february 2016). These JARS can be added using Maven and SBT(if you are using scala). Maven <dependency> <group...

This example is the same as WordCount, but uses the Table API. See WordCount for details about execution and results. Maven To use the Table API, add flink-table as a maven dependency: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table_2.11&...

Maven Add the dependencies flink-java and flink-client (as explained in the JVM environment setup example). The code public class WordCount{ public static void main( String[] args ) throws Exception{ // set up the execution environment final ExecutionEnvironment env = E...

This example is the same as WordCount, but uses the Table API. See WordCount for details about execution and results. Maven To use the Streaming API, add flink-streaming as a maven dependency: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-str...

A Table can be written to a TableSink, which is a generic interface to support different formats and file systems. A batch Table can only be written to a BatchTableSink, while a streaming table requires a StreamTableSink. Currently, flink offers only the CsvTableSink interface. Usage In the examp...

Once the sports2000 database has been installed it's time to run it as a standalone server (and not connect to it as a file). Start proenv (proenv in the startmeny on Windows or /usr/install-directory/bin/proenv on Linux/Unix). This example is from Windows. Linux is the same but you need to change...

Pre-requisites: Java 7 Hadoop (Refer here for Hadoop Installation) Mysql Server and Client Installation: Step 1: Download the latest Hive tarball from the downloads page. Step 2: Extract the downloaded tarball (Assumption: The tarball is downloaded in $HOME) tar -xvf /home/username/apache...

app.component.html <div> <div> <div *ngFor="let user of users"> <button class="btn" [@buttonState]="user.active" (click)="user.changeButtonState()">{{user.firstName}}</button> <...

Create a build job (according to your requirement). For this example I have created a freestyle job (AutoPush) to perform ANT build. We are going to create two variables, PUSH (Choice Parameter) and TAG_NUMBER (String Parameter). We can choose the value YES or NO for PUSH, this will decide whether...

The 0.9 release of Kafka introduced a complete redesign of the kafka consumer. If you are interested in the old SimpleConsumer (0.8.X), have a look at this page. If your Kafka installation is newer than 0.8.X, the following codes should work out of the box. Configuration and initialization Kaf...

The user can call Incrementor.Increment K number of times by pressing a key within '0' .. '9' and it's possible to call Incrementor.Increment faster than the task Incrementor can increment I. with Ada.Text_IO; with Ada.Integer_Text_IO; procedure Main is use Ada.Text_IO; task Incrementor...

Configuration and initialization First, create a maven project and add the following dependency in your pom: <dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version&...

NameStorage SizeDescriptionRangesmallint2 bytessmall-range integer-32768 to +32767integer4 bytesypical choice for integer-2147483648 to +2147483647bigint8 byteslarge-range integer-9223372036854775808 to +9223372036854775807decimalvariableuser-specified precision, exactup to 131072 digits before the...

If you need to extract information from a text response, the easiest way is to use Regular Expressions. The matching pattern is very similar to the one used in Perl. Let’s assume we want to test a flight ticket purchase workflow. The first step is to submit the purchase operation. The next step is t...

XPath can be used to navigate through elements and attributes in an XML document. It could be useful when data from the response cannot be extracted using the Regular Expression Extractor. For example, in the case of a scenario where you need to extract data from similar tags with the same attribute...

The CSS/JQuery extractor enables extracting values from a server response by using a CSS/JQuery selector syntax, which might have otherwise been difficult to write using Regular Expression. As a post-processor, this element should be executed to extract the requested nodes, text or attribute values...

JSON is a commonly used data format that is used in web based applications. The JMeter JSON Extractor provides a way to use JSON Path expressions for extracting values from JSON-based responses in JMeter. This post processor must be placed as a child of the HTTP Sampler or for any other sampler that...

When you manually write your performance scripts, you need to deal with correlation yourself. But there is another option to create your scripts - automation scripts recording. On the one hand, the manual approach helps your write structured scripts and you can add all the required extractors at the...

This uses the Dropbox Java SDK to share a file at "/test.txt" with a specific user: List<MemberSelector> newMembers = new ArrayList<MemberSelector>(); MemberSelector newMember = MemberSelector.email("<EMAIL_ADDRESS_TO_INVITE>"); newMembers.add(newMember); ...

This uses the Dropbox Java SDK to retrieve an existing shared link for /Testing/test.txt specifically: ListSharedLinksResult listSharedLinksResult = client.sharing() .listSharedLinksBuilder() .withPath("/Testing/test.txt").withDirectOnly(true) .start(); System....