jar

com.github.lalilou : flink-datalake-landing

Maven & Gradle

May 25, 2020

l3l-flink-landing · A base project for having datalake landing from streams with next-to-no-coding required.

Table Of Contents

Latest Version

Download com.github.lalilou : flink-datalake-landing JAR file - Latest Versions:

All Versions

Download com.github.lalilou : flink-datalake-landing JAR file - All Versions:

Version Vulnerabilities Size Updated
0.1.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window flink-datalake-landing-0.1.5.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.l3l.flink.landing.transformer

├─ com.l3l.flink.landing.transformer.AbstractSimpleTransformer.class - [JAR]

├─ com.l3l.flink.landing.transformer.ExtractJsonFieldsToMetadata.class - [JAR]

├─ com.l3l.flink.landing.transformer.ExtractTimestampAndWatermark.class - [JAR]

├─ com.l3l.flink.landing.transformer.FilterByMetadataFields.class - [JAR]

├─ com.l3l.flink.landing.transformer.FilterByMetadataFieldsWithRegex.class - [JAR]

├─ com.l3l.flink.landing.transformer.RemoveDuplicatedMessages.class - [JAR]

├─ com.l3l.flink.landing.transformer.RenameMetadataFields.class - [JAR]

├─ com.l3l.flink.landing.transformer.package.class - [JAR]

com.l3l.flink.landing.utils

├─ com.l3l.flink.landing.utils.JsonHelper.class - [JAR]

com.l3l.flink.landing

├─ com.l3l.flink.landing.OperatorFactory.class - [JAR]

├─ com.l3l.flink.landing.PipelineFactory.class - [JAR]

├─ com.l3l.flink.landing.StreamingJob.class - [JAR]

com.l3l.flink.landing.utils.configs

├─ com.l3l.flink.landing.utils.configs.ConfigConstants.class - [JAR]

├─ com.l3l.flink.landing.utils.configs.ConfigFileReader.class - [JAR]

├─ com.l3l.flink.landing.utils.configs.VariablePopulator.class - [JAR]

├─ com.l3l.flink.landing.utils.configs.package.class - [JAR]

com.l3l.flink.landing.sink

├─ com.l3l.flink.landing.sink.AbstractSink.class - [JAR]

├─ com.l3l.flink.landing.sink.KafkaProducer.class - [JAR]

├─ com.l3l.flink.landing.sink.MultiTopicsKafkaProducer.class - [JAR]

├─ com.l3l.flink.landing.sink.TextFile.class - [JAR]

com.l3l.flink.landing.data

├─ com.l3l.flink.landing.data.WrappedSerDeForKafkaStream.class - [JAR]

├─ com.l3l.flink.landing.data.WrappedSerDeForKinesisStream.class - [JAR]

├─ com.l3l.flink.landing.data.WrappedSerDeForStream.class - [JAR]

├─ com.l3l.flink.landing.data.package.class - [JAR]

com.l3l.flink.landing.source

├─ com.l3l.flink.landing.source.AbstractSource.class - [JAR]

├─ com.l3l.flink.landing.source.KafkaConsumer.class - [JAR]

├─ com.l3l.flink.landing.source.KinesisConsumer.class - [JAR]

├─ com.l3l.flink.landing.source.package.class - [JAR]