MCPcopy Create free account

hub / github.com/alpinegizmo/flink-mobile-data-usage / types & classes

Types & classes15 in github.com/alpinegizmo/flink-mobile-data-usage

⨍ Functions 29◇ Types & classes 15
ClassAccountUpdateGenerator
src/main/java/com/ververica/flink/example/datausage/sources/AccountUpdateGenerator.java:31
ClassEnrichedUsageRecord
src/main/java/com/ververica/flink/example/datausage/records/EnrichedUsageRecord.java:25
ClassKafkaProducerJob
src/main/java/com/ververica/flink/example/datausage/KafkaProducerJob.java:32
ClassQuotaEnrichmentJob
src/main/java/com/ververica/flink/example/datausage/QuotaEnrichmentJob.java:31
ClassSum
src/main/java/com/ververica/flink/example/datausage/UsageAlertingProcessFunctionJob.java:218
ClassTotalUsageBatchJob
src/main/java/com/ververica/flink/example/datausage/TotalUsageBatchJob.java:39
ClassTotalUsageStreamingJob
src/main/java/com/ververica/flink/example/datausage/TotalUsageStreamingJob.java:37
ClassUsageAlertingFunction
src/main/java/com/ververica/flink/example/datausage/UsageAlertingProcessFunctionJob.java:165
ClassUsageAlertingProcessFunctionJob
src/main/java/com/ververica/flink/example/datausage/UsageAlertingProcessFunctionJob.java:41
ClassUsageAlertingSQLJob
src/main/java/com/ververica/flink/example/datausage/UsageAlertingSQLJob.java:31
ClassUsageRecord
This class is set up as a Flink POJO so that it can be serialized by Flink's PojoSerializer. That's why there is an empty, default constructor, and th
src/main/java/com/ververica/flink/example/datausage/records/UsageRecord.java:33
ClassUsageRecordDeserializationSchema
src/main/java/com/ververica/flink/example/datausage/records/UsageRecordDeserializationSchema.java:29
ClassUsageRecordGenerator
src/main/java/com/ververica/flink/example/datausage/sources/UsageRecordGenerator.java:28
ClassUsageRecordIterator
src/main/java/com/ververica/flink/example/datausage/sources/UsageRecordGenerator.java:64
ClassUsageRecordSerializationSchema
src/main/java/com/ververica/flink/example/datausage/records/UsageRecordSerializationSchema.java:30