KSQL-ApacheKafka的流式SQL引擎
需积分: 13 106 浏览量
2019-08-08
10:22:34
上传
评论
收藏 2.22MB ZIP 举报
KSQL-ApacheKafka的流式SQL引擎 （885个子文件） 
clickstream_schema.avro 5KB users_array_map_schema.avro 4KB clickstream_users_schema.avro 3KB ratings_schema.avro 3KB orders_schema.avro 2KB orders_schema.avro 2KB users_schema.avro 1KB purchase.avro 1KB product.avro 1KB inventory.avro 913B pageviews_schema.avro 828B clickstream_codes_schema.avro 729B avro_order_schema.avro 244B avro_order_schema.avro 244B KsqlVersionMetrics.avsc 662B make.bat 6KB changelog 158B compat 2B gbp.conf 115B configure 1KB configure 939B control 398B copyright 921B Dockerfile 1KB Dockerfile 1KB Dockerfile 1KB Dockerfile 543B Dockerfile 543B Dockerfile 516B ensure 1KB format 12B SqlBase.g4 19KB .github_changelog_generator 97B .gitignore 189B
licenses.html 6KB confluent-ksql.spec.in 2KB
udf-example.jar 12KB null-filter-4.0.0-SNAPSHOT.jar 3KB AstBuilder.java 58KB KsqlParserTest.java 57KB KsqlResourceTest.java 40KB JoinNodeTest.java 40KB StatementRewriter.java 40KB Console.java 31KB KsqlResource.java 31KB StatementRewriterTest.java 30KB CodeGenRunnerTest.java 27KB PhysicalPlanBuilderTest.java 26KB KafkaTopicClientImplTest.java 26KB Cli.java 24KB Analyzer.java 24KB KsqlEngine.java 23KB SchemaKStreamTest.java 23KB CliTest.java 23KB StatementExecutorTest.java 22KB SqlToJavaVisitor.java 22KB StreamsSelectAndProjectIntTest.java 22KB SchemaUtilTest.java 20KB SqlFormatter.java 20KB KsqlGenericRowAvroDeserializerTest.java 20KB EndToEndEngineTestUtil.java 20KB JoinNode.java 20KB KsqlConfig.java 19KB ExpressionTreeRewriter.java 19KB ExpressionFormatter.java 18KB SchemaKStream.java 18KB SchemaKTableTest.java 18KB KsqlRestApplication.java 17KB AggregateNode.java 16KB UdfCompiler.java 16KB IntegrationTestUtils.java 16KB StatementExecutor.java 16KB KsqlGenericRowAvroSerializerTest.java 16KB SchemaUtil.java 16KB GenericRowValueTypeEnforcerTest.java 15KB PhysicalPlanBuilder.java 15KB KsqlEngineTest.java 15KB ExpressionFormatterTest.java 14KB DataGenProducer.java 14KB IntegrationTestHarness.java 13KB SecureIntegrationTest.java 13KB UdfLoader.java 13KB EmbeddedSingleNodeKafkaCluster.java 13KB DataGen.java 13KB KafkaTopicClientImpl.java 13KB UdfIntTest.java 13KB StreamedQueryResourceTest.java 13KB SetParentVisitor.java 13KB UdfCompilerTest.java 12KB InternalFunctionRegistry.java 12KB MetricCollectorsTest.java 12KB AvroSchemaInferenceTest.java 12KB JoinIntTest.java 12KB AggregateAnalyzerTest.java 12KB EndToEndIntegrationTest.java 12KB DefaultTraversalVisitor.java 12KB KsqlRestClient.java 12KB JsonFormatTest.java 11KB AstVisitor.java 11KB StructuredDataSourceNode.java 11KB共 885 条
- 1
- 2
- 3
- 4
- 5
- 6
- 9
资源评论
