flink真实案例-读取kafka下沉redis-中间逻辑处理带原始数据.zip

[{"title":"（ 72 个子文件 48KB ） flink真实案例-读取kafka下沉redis-中间逻辑处理带原始数据.zip","children":[{"title":"combitzcoinbenifit","children":[{"title":"pom.xml <span style='color:#111;'> 3.26KB </span>","children":null,"spread":false},{"title":"combitzcoinbenifit.iml <span style='color:#111;'> 6.04KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":null,"spread":false}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 205B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"bitz","children":[{"title":"coin","children":[{"title":"benifit","children":[{"title":"MainJob.java <span style='color:#111;'> 938B </span>","children":null,"spread":false},{"title":"handle","children":[{"title":"Num.java <span style='color:#111;'> 701B </span>","children":null,"spread":false},{"title":"Handle.java <span style='color:#111;'> 3.27KB </span>","children":null,"spread":false}],"spread":true},{"title":"send","children":[{"title":"MyKafkaProducer.java <span style='color:#111;'> 2.79KB </span>","children":null,"spread":false}],"spread":false},{"title":"sink","children":[{"title":"MyRedisMapper.java <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":"SinkData.java <span style='color:#111;'> 923B </span>","children":null,"spread":false}],"spread":false},{"title":"file","children":[{"title":"order_coin <span style='color:#111;'> 1.23KB </span>","children":null,"spread":false}],"spread":false},{"title":"datasource","children":[{"title":"KafkaDatasource.java <span style='color:#111;'> 2.15KB </span>","children":null,"spread":false},{"title":"OtherDatasource.java <span style='color:#111;'> 408B </span>","children":null,"spread":false}],"spread":false},{"title":"utils","children":[{"title":"ConfigUtil.java <span style='color:#111;'> 900B </span>","children":null,"spread":false},{"title":"JsonUtil.java <span style='color:#111;'> 712B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.59KB </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 439B </span>","children":null,"spread":false},{"title":"modules.xml <span style='color:#111;'> 276B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 648B </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 49.38KB </span>","children":null,"spread":false},{"title":"libraries","children":[{"title":"Maven__org_apache_commons_commons_compress_1_4_1.xml <span style='color:#111;'> 591B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_runtime_2_11_1_7_0.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_shaded_asm_5_0_4_5_0.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_tukaani_xz_1_0.xml <span style='color:#111;'> 451B </span>","children":null,"spread":false},{"title":"Maven__org_scala_lang_modules_scala_parser_combinators_2_11_1_0_4.xml <span style='color:#111;'> 698B </span>","children":null,"spread":false},{"title":"Maven__commons_io_commons_io_2_4.xml <span style='color:#111;'> 503B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_force_shading_1_7_0.xml <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"Maven__org_scala_lang_modules_scala_java8_compat_2_11_0_7_0.xml <span style='color:#111;'> 656B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_connector_kafka_base_2_11_1_7_0.xml <span style='color:#111;'> 688B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_akka_akka_stream_2_11_2_4_20.xml <span style='color:#111;'> 594B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_ssl_config_core_2_11_0_2_1.xml <span style='color:#111;'> 595B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_shaded_jackson_2_7_9_5_0.xml <span style='color:#111;'> 639B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_queryable_state_client_java_2_11_1_7_0.xml <span style='color:#111;'> 737B </span>","children":null,"spread":false},{"title":"Maven__org_javassist_javassist_3_19_0_GA.xml <span style='color:#111;'> 550B </span>","children":null,"spread":false},{"title":"Maven__org_xerial_snappy_snappy_java_1_1_4.xml <span style='color:#111;'> 552B </span>","children":null,"spread":false},{"title":"Maven__com_esotericsoftware_kryo_kryo_2_24_0.xml <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_clients_2_11_1_7_0.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false},{"title":"Maven__org_apache_commons_commons_pool2_2_3.xml <span style='color:#111;'> 556B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_akka_akka_protobuf_2_11_2_4_20.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__com_google_code_findbugs_jsr305_1_3_9.xml <span style='color:#111;'> 545B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_nop_1_7_24.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"Maven__org_apache_commons_commons_lang3_3_3_2.xml <span style='color:#111;'> 570B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_streaming_java_2_11_1_7_0.xml <span style='color:#111;'> 646B </span>","children":null,"spread":false},{"title":"Maven__org_apache_bahir_flink_connector_redis_2_11_1_0.xml <span style='color:#111;'> 639B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_shaded_netty_4_1_24_Final_5_0.xml <span style='color:#111;'> 674B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_akka_akka_slf4j_2_11_2_4_20.xml <span style='color:#111;'> 587B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_connector_kafka_2_11_1_7_0.xml <span style='color:#111;'> 653B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_annotations_1_7_0.xml <span style='color:#111;'> 590B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_java_1_7_0.xml <span style='color:#111;'> 541B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_config_1_3_0.xml <span style='color:#111;'> 497B </span>","children":null,"spread":false},{"title":"Maven__com_alibaba_fastjson_1_2_62.xml <span style='color:#111;'> 514B </span>","children":null,"spread":false},{"title":"Maven__org_apache_commons_commons_math3_3_5.xml <span style='color:#111;'> 556B </span>","children":null,"spread":false},{"title":"Maven__com_github_scopt_scopt_2_11_3_5_0.xml <span style='color:#111;'> 541B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_metrics_core_1_7_0.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false},{"title":"Maven__commons_cli_commons_cli_1_3_1.xml <span style='color:#111;'> 528B </span>","children":null,"spread":false},{"title":"Maven__redis_clients_jedis_2_8_0.xml <span style='color:#111;'> 494B </span>","children":null,"spread":false},{"title":"Maven__org_lz4_lz4_java_1_4_1.xml <span style='color:#111;'> 491B </span>","children":null,"spread":false},{"title":"Maven__com_typesafe_akka_akka_actor_2_11_2_4_20.xml <span style='color:#111;'> 587B </span>","children":null,"spread":false},{"title":"Maven__org_reactivestreams_reactive_streams_1_0_0.xml <span style='color:#111;'> 595B </span>","children":null,"spread":false},{"title":"Maven__org_scala_lang_scala_library_2_11_12.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__commons_collections_commons_collections_3_2_2.xml <span style='color:#111;'> 616B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_shaded_guava_18_0_5_0.xml <span style='color:#111;'> 618B </span>","children":null,"spread":false},{"title":"Maven__com_twitter_chill_java_0_7_6.xml <span style='color:#111;'> 521B </span>","children":null,"spread":false},{"title":"Maven__org_clapper_grizzled_slf4j_2_11_1_3_2.xml <span style='color:#111;'> 584B </span>","children":null,"spread":false},{"title":"Maven__org_objenesis_objenesis_2_1.xml <span style='color:#111;'> 508B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_api_1_7_15.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_core_1_7_0.xml <span style='color:#111;'> 541B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_optimizer_2_11_1_7_0.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__com_twitter_chill_2_11_0_7_6.xml <span style='color:#111;'> 521B </span>","children":null,"spread":false},{"title":"Maven__com_esotericsoftware_minlog_minlog_1_2.xml <span style='color:#111;'> 543B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_clients_2_0_1.xml <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"Maven__org_apache_flink_flink_hadoop_fs_1_7_0.xml <span style='color:#111;'> 576B </span>","children":null,"spread":false}],"spread":false},{"title":"inspectionProfiles","children":[{"title":"Project_Default.xml <span style='color:#111;'> 1.41KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]