amazon-kinesis-data-analytics-java-examples:用于Kinesis Data Analytics的示例Java应用程序，演示了源，接收器和运算符-源码

[{"title":"（ 51 个子文件 101KB ） amazon-kinesis-data-analytics-java-examples:用于Kinesis Data Analytics的示例Java应用程序，演示了源，接收器和运算符-源码","children":[{"title":"amazon-kinesis-data-analytics-java-examples-master","children":[{"title":"CloudWatchSink","children":[{"title":"pom.xml <span style='color:#111;'> 4.29KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"sink","children":[{"title":"CloudWatchLogSink.java <span style='color:#111;'> 3.06KB </span>","children":null,"spread":false}],"spread":true},{"title":"CustomSinkStreamingJob.java <span style='color:#111;'> 6.30KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"GettingStarted_1_8","children":[{"title":"pom.xml <span style='color:#111;'> 4.19KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"BasicStreamingJob.java <span style='color:#111;'> 3.58KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"GettingStarted_1_6","children":[{"title":"pom.xml <span style='color:#111;'> 4.24KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"BasicStreamingJob.java <span style='color:#111;'> 3.58KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".github","children":[{"title":"PULL_REQUEST_TEMPLATE.md <span style='color:#111;'> 197B </span>","children":null,"spread":false}],"spread":true},{"title":"S3Sink","children":[{"title":"pom.xml <span style='color:#111;'> 5.15KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"S3StreamingSinkJob.java <span style='color:#111;'> 3.01KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"python","children":[{"title":"S3Sink","children":[{"title":"application_properties.json <span style='color:#111;'> 666B </span>","children":null,"spread":false},{"title":"streaming-file-sink.py <span style='color:#111;'> 5.71KB </span>","children":null,"spread":false}],"spread":true},{"title":"GettingStarted","children":[{"title":"application_properties.json <span style='color:#111;'> 601B </span>","children":null,"spread":false},{"title":"getting-started.py <span style='color:#111;'> 4.76KB </span>","children":null,"spread":false}],"spread":true},{"title":"TumblingWindow","children":[{"title":"application_properties.json <span style='color:#111;'> 740B </span>","children":null,"spread":false},{"title":"tumbling-windows.py <span style='color:#111;'> 4.97KB </span>","children":null,"spread":false}],"spread":true},{"title":"SlidingWindow","children":[{"title":"application_properties.json <span style='color:#111;'> 737B </span>","children":null,"spread":false},{"title":"sliding-windows.py <span style='color:#111;'> 5.01KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"LICENSE <span style='color:#111;'> 931B </span>","children":null,"spread":false},{"title":"FirehoseSink","children":[{"title":"pom.xml <span style='color:#111;'> 4.29KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"FirehoseSinkStreamingJob.java <span style='color:#111;'> 3.90KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"GettingStartedTable","children":[{"title":"pom.xml <span style='color:#111;'> 6.50KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"python","children":[{"title":"stock.py <span style='color:#111;'> 1.19KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"StreamingJob.java <span style='color:#111;'> 8.51KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"Beam","children":[{"title":"pom.xml <span style='color:#111;'> 5.50KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"kinesisanalytics","children":[{"title":"beam","children":[{"title":"BasicBeamStreamingJob.java <span style='color:#111;'> 3.48KB </span>","children":null,"spread":false},{"title":"DefaultCredentialsProviderClientsProvider.java <span style='color:#111;'> 1.28KB </span>","children":null,"spread":false},{"title":"BasicBeamStreamingJobOptions.java <span style='color:#111;'> 584B </span>","children":null,"spread":false},{"title":"BasicBeamStreamingJobOptionsParser.java <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"CONTRIBUTING.md <span style='color:#111;'> 3.62KB </span>","children":null,"spread":false},{"title":"KafkaConnectors","children":[{"title":"pom.xml <span style='color:#111;'> 3.65KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"KafkaGettingStartedJob.java <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"CustomMetrics","children":[{"title":"WordCount","children":[{"title":"pom.xml <span style='color:#111;'> 4.29KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"WordCountApplication.java <span style='color:#111;'> 4.50KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"RecordCount","children":[{"title":"pom.xml <span style='color:#111;'> 4.30KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"RecordSchemaHelper.java <span style='color:#111;'> 1.37KB </span>","children":null,"spread":false},{"title":"RecordCountApplication.java <span style='color:#111;'> 5.63KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"EfoConsumer","children":[{"title":"pom.xml <span style='color:#111;'> 4.28KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"software","children":[{"title":"amazon","children":[{"title":"kinesis","children":[{"title":"EfoApplication.java <span style='color:#111;'> 2.75KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"CODE_OF_CONDUCT.md <span style='color:#111;'> 309B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 250B </span>","children":null,"spread":false},{"title":"GettingStarted","children":[{"title":"pom.xml <span style='color:#111;'> 4.29KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"BasicStreamingJob.java <span style='color:#111;'> 3.58KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"TumblingWindow","children":[{"title":"pom.xml <span style='color:#111;'> 4.30KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"TumblingWindowStreamingJob.java <span style='color:#111;'> 3.20KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"SlidingWindow","children":[{"title":"pom.xml <span style='color:#111;'> 4.31KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"SlidingWindowStreamingJobWithParallelism.java <span style='color:#111;'> 4.20KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"CustomKeystore","children":[{"title":"pom.xml <span style='color:#111;'> 7.50KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false}],"spread":false},{"title":"java","children":[{"title":"com","children":[{"title":"amazonaws","children":[{"title":"services","children":[{"title":"kinesisanalytics","children":[{"title":"KDAFlinkStreamingJob.java <span style='color:#111;'> 2.48KB </span>","children":null,"spread":false},{"title":"CustomFlinkKafkaConsumer.java <span style='color:#111;'> 2.09KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}]