Skip to main content

Before You Start

Welcome to developing applications with Apache Flink and AMPS, the Advanced Message Processing System from 60East Technologies.

These guides will help you learn how to use the AMPS Flink connector to develop applications with AMPS and Flink.

Before reading this guide, it is important to have a good understanding of the following topics:

  • Developing Applications in Java

    To be successful using this guide, you will need to possess a working knowledge of the Java language. Visit http://java.oracle.com for resources on learning Java.

  • AMPS Concepts

    The connector uses the AMPS Java client, so we recommend reading about the AMPS Java Client.

    Many features included in the connector require an understanding of AMPS, so we recommend reading the Introduction to AMPS guide.

    Detailed explanations of the AMPS server behavior are in the AMPS Server Documentation.

  • Flink Concepts

    The connector is used to receive data from AMPS as well as sink data to AMPS.

    Before working through this guide, we recommend reading the First Steps documentation to help set up Flink.

    To better understand how to create applications and programs using Flink, we recommend reading the Programming Guide for Flink's DataStream API.

Setting up Development Instances​

In order to use the connector, a Flink cluster and a running AMPS server are required. You can write and compile programs that use the connector without a Flink cluster or AMPS instance, but you will get more out of this guide by running the programs against a Flink cluster and a working AMPS server.

Setting up an AMPS Development Instance​

Instructions for starting an instance of AMPS are available in the Introduction to AMPS guide.

tip

The AMPS server runs on x64 Linux. The Introduction to AMPS and AMPS FAQ contain information on how to run an AMPS server on a development system that does not run Linux.

Instructions for starting a Flink cluster are available in the First Steps section from Flink.

tip

Although Java 11 is the minimum required version to run Flink, the recommended version for running Flink 2.x is Java 17. The connectors were built with Java 17 in mind and may not be compatible with lower Java versions.