Tutorial by Examples: l

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&...

Given the CSV file peoples.csv: 1,Reed,United States,Female 2,Bradley,United States,Female 3,Adams,United States,Male 4,Lane,United States,Male 5,Marshall,United States,Female 6,Garza,United States,Male 7,Gutierrez,United States,Male 8,Fox,Germany,Female 9,Medina,United States,Male 10,Nich...

In addition to peoples.csv (see simple aggregation from a CSV) we have two more CSVs representing products and sales. sales.csv (people_id, product_id): 19,5 6,4 10,4 2,4 8,1 19,2 8,4 5,5 13,5 4,4 6,1 3,3 8,3 17,2 6,2 1,2 3,5 15,5 3,3 6,3 13,2 20,4 20,2 products.csv (id, n...

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...

Unlike other languages, Python doesn't have a do-until or a do-while construct (this will allow code to be executed once before the condition is tested). However, you can combine a while True with a break to achieve the same purpose. a = 10 while True: a = a-1 print(a) if a<7: ...

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...

This method will create a new Excel Spreadsheet. Pass in the fileName which is a full file path name. using DocumentFormat.OpenXml; using DocumentFormat.OpenXml.Packaging; using DocumentFormat.OpenXml.Spreadsheet; using System; .... void Create(string fileName) { using (Sp...

Homebrew can be installed using the following command in the terminal: /usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)" It runs as the current user; you don’t need to use sudo. The script can be viewed online and will print a summary of...

Reading in a single step: IFS=$'\n' read -r -a arr < file Reading in a loop: arr=() while IFS= read -r line; do arr+=("$line") done 4.0 Using mapfile or readarray (which are synonymous): mapfile -t arr < file readarray -t arr < file

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

Parent component : import {Component} from '@angular/core'; @Component({ selector: 'parent-component', templateUrl: './parent-component.html' }) export class ParentComponent { users : Array<User> = []; changeUsersActivation(user : User){ user.changeButtonState(); } ...

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...

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&...

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....