jar

com.airwallex.airskiff : core

Maven & Gradle

Aug 16, 2023
16 stars

core · A stream library for batch and realtime data processing

Table Of Contents

Latest Version

Download com.airwallex.airskiff : core JAR file - Latest Versions:

All Versions

Download com.airwallex.airskiff : core JAR file - All Versions:

Version Vulnerabilities Size Updated
3.0.x
2.0.x
1.0.x
0.0.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 core-2.0.52.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.airwallex.airskiff.flink.types

├─ com.airwallex.airskiff.flink.types.AvroGenericRecordConverter.class - [JAR]

├─ com.airwallex.airskiff.flink.types.AvroSpecificOutputFormat.class - [JAR]

├─ com.airwallex.airskiff.flink.types.AvroSpecificTypeInfo.class - [JAR]

├─ com.airwallex.airskiff.flink.types.AvroSpecificTypeSerializer.class - [JAR]

├─ com.airwallex.airskiff.flink.types.JavaPairSerializerSnapshot.class - [JAR]

├─ com.airwallex.airskiff.flink.types.PairSerializer.class - [JAR]

├─ com.airwallex.airskiff.flink.types.PairSerializerTest.class - [JAR]

├─ com.airwallex.airskiff.flink.types.PairTypeInfo.class - [JAR]

com.airwallex.airskiff

├─ com.airwallex.airskiff.Compiler.class - [JAR]

com.airwallex.airskiff.flink.udx

├─ com.airwallex.airskiff.flink.udx.GetAgeFunction.class - [JAR]

├─ com.airwallex.airskiff.flink.udx.GetAgeFunctionTest.class - [JAR]

├─ com.airwallex.airskiff.flink.udx.NormalizeNameFunction.class - [JAR]

├─ com.airwallex.airskiff.flink.udx.NormalizeNameFunctionTest.class - [JAR]

├─ com.airwallex.airskiff.flink.udx.UnixTimeFunction.class - [JAR]

├─ com.airwallex.airskiff.flink.udx.UnixTimeFunctionTest.class - [JAR]

com.airwallex.airskiff.common

├─ com.airwallex.airskiff.common.GcsDailyLocation.class - [JAR]

├─ com.airwallex.airskiff.common.Pair.class - [JAR]

├─ com.airwallex.airskiff.common.SlidingWindowElement.class - [JAR]

├─ com.airwallex.airskiff.common.SlidingWindowList.class - [JAR]

com.airwallex.airskiff.common.functions

├─ com.airwallex.airskiff.common.functions.Id.class - [JAR]

├─ com.airwallex.airskiff.common.functions.Interval.class - [JAR]

├─ com.airwallex.airskiff.common.functions.NamedMonoid.class - [JAR]

├─ com.airwallex.airskiff.common.functions.NamedSerializableIterableLambda.class - [JAR]

├─ com.airwallex.airskiff.common.functions.NamedSerializableLambda.class - [JAR]

├─ com.airwallex.airskiff.common.functions.PreviousMonoid.class - [JAR]

├─ com.airwallex.airskiff.common.functions.SerializableBiLambda.class - [JAR]

├─ com.airwallex.airskiff.common.functions.SerializableComparable.class - [JAR]

├─ com.airwallex.airskiff.common.functions.SerializableComparator.class - [JAR]

├─ com.airwallex.airskiff.common.functions.SerializableLambda.class - [JAR]

com.airwallex.airskiff.core

├─ com.airwallex.airskiff.core.ConcatStream.class - [JAR]

├─ com.airwallex.airskiff.core.Either.class - [JAR]

├─ com.airwallex.airskiff.core.EventTimeBasedSlidingWindow.class - [JAR]

├─ com.airwallex.airskiff.core.EventTimeBasedSlidingWindowTest.class - [JAR]

├─ com.airwallex.airskiff.core.FilterStream.class - [JAR]

├─ com.airwallex.airskiff.core.FlatMapStream.class - [JAR]

├─ com.airwallex.airskiff.core.KeyedSimpleStream.class - [JAR]

├─ com.airwallex.airskiff.core.LeftJoinPairMonoid.class - [JAR]

├─ com.airwallex.airskiff.core.LeftJoinStream.class - [JAR]

├─ com.airwallex.airskiff.core.MapStream.class - [JAR]

├─ com.airwallex.airskiff.core.MapValueStream.class - [JAR]

├─ com.airwallex.airskiff.core.OrderedSummedStream.class - [JAR]

├─ com.airwallex.airskiff.core.PreviousMonoid.class - [JAR]

├─ com.airwallex.airskiff.core.SourceStream.class - [JAR]

├─ com.airwallex.airskiff.core.SqlStream.class - [JAR]

├─ com.airwallex.airskiff.core.StreamTest.class - [JAR]

├─ com.airwallex.airskiff.core.StreamUtils.class - [JAR]

├─ com.airwallex.airskiff.core.SummedStream.class - [JAR]

├─ com.airwallex.airskiff.core.WindowedStream.class - [JAR]

com.airwallex.airskiff.examples

├─ com.airwallex.airskiff.examples.AddMonoid.class - [JAR]

├─ com.airwallex.airskiff.examples.Counter.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalBatchWordCountJob.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalRealtimeSQLWordCountJob.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkAccumulator.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkExample.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkPartitionByExample.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkSQLExample.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkUnion.class - [JAR]

├─ com.airwallex.airskiff.examples.LocalSparkWindowExample.class - [JAR]

├─ com.airwallex.airskiff.examples.Something.class - [JAR]

com.airwallex.airskiff.core.config

├─ com.airwallex.airskiff.core.config.Config.class - [JAR]

com.airwallex.airskiff.flink

├─ com.airwallex.airskiff.flink.AbstractFlinkCompiler.class - [JAR]

├─ com.airwallex.airskiff.flink.Constants.class - [JAR]

├─ com.airwallex.airskiff.flink.EventTimeAdjustFunction.class - [JAR]

├─ com.airwallex.airskiff.flink.EventTimeAdjustFunctionTest.class - [JAR]

├─ com.airwallex.airskiff.flink.EventTimeManager.class - [JAR]

├─ com.airwallex.airskiff.flink.EventTimeManagerTest.class - [JAR]

├─ com.airwallex.airskiff.flink.FlinkBatchCompiler.class - [JAR]

├─ com.airwallex.airskiff.flink.FlinkConfig.class - [JAR]

├─ com.airwallex.airskiff.flink.FlinkLocalTextConfig.class - [JAR]

├─ com.airwallex.airskiff.flink.FlinkRealtimeCompiler.class - [JAR]

├─ com.airwallex.airskiff.flink.FlinkTest.class - [JAR]

├─ com.airwallex.airskiff.flink.HybridWatermarkGenerator.class - [JAR]

├─ com.airwallex.airskiff.flink.HybridWatermarkGeneratorTest.class - [JAR]

├─ com.airwallex.airskiff.flink.OnlineConfig.class - [JAR]

├─ com.airwallex.airskiff.flink.RealtimeEventTimeTrigger.class - [JAR]

├─ com.airwallex.airskiff.flink.RealtimeWatermarkStrategy.class - [JAR]

├─ com.airwallex.airskiff.flink.Utils.class - [JAR]

com.airwallex.airskiff.spark.udf

├─ com.airwallex.airskiff.spark.udf.GetAgeFunction.class - [JAR]

├─ com.airwallex.airskiff.spark.udf.NormalizeNameFunction.class - [JAR]

├─ com.airwallex.airskiff.spark.udf.UnixTimeFunction.class - [JAR]

com.airwallex.airskiff.core.api

├─ com.airwallex.airskiff.core.api.KStream.class - [JAR]

├─ com.airwallex.airskiff.core.api.Stream.class - [JAR]

├─ com.airwallex.airskiff.core.api.Window.class - [JAR]

com.airwallex.airskiff.spark

├─ com.airwallex.airskiff.spark.AbstractSparkCompiler.class - [JAR]

├─ com.airwallex.airskiff.spark.CustomAccumulator.class - [JAR]

├─ com.airwallex.airskiff.spark.CustomAggregator.class - [JAR]

├─ com.airwallex.airskiff.spark.DistinctCountAggregator.class - [JAR]

├─ com.airwallex.airskiff.spark.KeyedItem.class - [JAR]

├─ com.airwallex.airskiff.spark.SerializableList.class - [JAR]

├─ com.airwallex.airskiff.spark.SparkCompiler.class - [JAR]

├─ com.airwallex.airskiff.spark.SparkConfig.class - [JAR]

├─ com.airwallex.airskiff.spark.SparkLocalTextConfig.class - [JAR]

├─ com.airwallex.airskiff.spark.Utils.class - [JAR]

com.airwallex.airskiff.testhelpers

├─ com.airwallex.airskiff.testhelpers.KList.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.ListSourceConfig.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestCompiler.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestData.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestFlinkConfig.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestInputData.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestMonoid.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestRunner.class - [JAR]

├─ com.airwallex.airskiff.testhelpers.TestSparkConfig.class - [JAR]

Advertisement