Apache Flink

Gradle dependencies:


plugins {
    id 'java'
    id 'application'
}

group = 'az.etibarli'
version = '1.0-SNAPSHOT'

java {
    toolchain {
        languageVersion = JavaLanguageVersion.of(11)
    }
}

repositories {
    mavenCentral()
}

dependencies {
    implementation 'org.apache.flink:flink-java:1.17.1'
    implementation 'org.apache.flink:flink-streaming-java:1.17.1'
    implementation 'org.apache.flink:flink-clients:1.17.1'
}

application {
    mainClass = 'az.etibarli.WordCountStreaming'  // Make sure this matches your main class
}

jar {
    manifest {
        attributes 'Main-Class': 'az.etibarli.WordCountStreaming'
    }

} 


































Комментарии

Отправить комментарий

Популярные сообщения из этого блога

Lesson1: JDK, JVM, JRE

Изображение
1. Compiler - takes the entire programming code written in high language and translates the whole of it into machine code at once. After this process the an executable file will be ready to run. The translation takes some times to be done, but after that execution is so fast. 2. Interpreter - takes each single instructions of the code translates it and then executes it on its own. The translation step is before the program runs is fast, but execution is slow. JDK = JRE + development tools JRE = JVM + library class JDK -> Java Development Kit. A kit which provides the environment to develop and execute (run) Java program. JRE -> Java Runtime Environment. Provides environment to only run. JVM -> Java Virtual Machine f * Compiled: Fortran, C, C++, Pascal, Haskell, Rust, Go * Interpreted: JavaScript, PHP, Python, Ruby Java both compiled and interpreted language. Terminalda : javac Main.java yazdiqda, source fayli(.java) bytecode(.class) faylina cevirir. Terminalda: java Main (bu z...
Далее...

SE_21_Lesson_11: Inheritance, Polymorphism

->  instanceof anlayishi, misallarla izahi   package org.example.lesson_13 ; public class Ulubaba { public String ad ; public String soyad ; public Integer yash ; public void odunDogramaq () { System . out .println( "Ulubaba 50 kq odunu 1 saata dograyir" ) ; } } package org.example.lesson_13 ; public class Baba extends Ulubaba { public String hobbi ; public void otBicmek () { System . out .println( "Baba 1 hektar otu 1 gune bicir" ) ; } } package org.example.lesson_13 ; public class Main { public static void main ( String [] args ) { Baba baba = new Baba() ; System . out .println( baba instanceof Ulubaba ) ; System . out .println( baba instanceof Object ) ; } } -> Upcasting package org.example.lesson_13 ; public class Main { public static void main ( String [] args ) { Ulubaba u = new Baba() ; } } -> Downcasting Problemsiz situasiya: package org.example.lesson_13...
Далее...

Preparation for Java interview

Изображение
1.⁠ ⁠Eror ve Exception  2.⁠ ⁠⁠Heap and Stack  3.⁠ ⁠⁠String pool  4.⁠ ⁠⁠Mutable and Immutable class  5.⁠ ⁠⁠Classi nece  Immutible ede bilerik?  6.⁠ ⁠⁠StringBulder vs StringBuffer  7.⁠ ⁠⁠Thread  nece yaradilir?  2.⁠ ⁠⁠checked and anchecked  3.⁠ ⁠⁠exception Handler  4.⁠ ⁠⁠Entity relationships   5.⁠ ⁠⁠Entity fetch Type LAZY and EGAR  5.⁠ ⁠⁠OOP prinsips   6.⁠ ⁠⁠SOLID  7.⁠ ⁠⁠Singlton designs pattern  8.⁠ ⁠⁠Connection pool  8.⁠ ⁠⁠Bulder  9.⁠ ⁠⁠Prox 10.⁠ ⁠⁠Protodtype 11.⁠ ⁠Hansi type  12.⁠ ⁠⁠ArrayList vs LinkedList 13.⁠ ⁠⁠Set and Hashest 14.⁠ ⁠⁠HashMap ve HashTable 15.⁠ ⁠⁠Interface Ve Abstract class ferq 16.⁠ ⁠⁠Java 8 features  17.⁠ ⁠⁠Functional Interface nece yaradilir ve Java 8 de gelen hazir Functional Interfaces 17.⁠ ⁠⁠Stream API, intermadite, terminal, Lazy Intialise 15.⁠ ⁠⁠Spring boot features  16.⁠ ⁠⁠Spring Boot transactions management  17.⁠ ⁠⁠ACID 18.⁠ ⁠⁠Duty read, repeatable read, non-repeatable  19.⁠ ⁠⁠Isolation Levels 4 nov 20.⁠ ⁠⁠propigat...
Далее...