ksql-fork-with-deep-learning-function
Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example
File Explorer
Download Latest Version (.zip)- ksql
- ksql-datagen
- ksql-print-metrics
- ksql-run-class
- ksql-server-start
- ksql-server-stop
- ksql-stop
- pom.xml
- suppressions.xml
- datagen.properties
- ksql-server.properties
- log4j-file.properties
- log4j-rolling.properties
- log4j-silent.properties
- log4j.properties
- series
- standard_build_layout.patch
- format
- changelog
- compat
- confluent-ksql.postinst
- confluent-ksql.service
- confluent-ksql.spec.in
- control
- copyright
- gbp.conf
- Makefile
- rules
- README.md
- application-mode.png
- client-server.png
- standalone-mode.png
- ctas-snippet.sql
- config-reference.rst
- docker-compose.yml
- ksql-quickstart-schemas.jpg
- quickstart-docker.md
- quickstart-non-docker.md
- README.md
- concepts.md
- contributing.md
- examples.md
- faq.md
- key-constraints.rst
- README.md
- requirements.txt
- syntax-reference.md
- application-mode.png
- client-server.png
- grafana-success.png
- ksql-quickstart-schemas.jpg
- standalone-mode.png
- ksql-includes.rst
- avro-schema.rst
- index.rst
- security.rst
- cli-config.rst
- common-scenarios.rst
- index.rst
- installing.rst
- upgrading.rst
- basics-docker.rst
- basics-local.rst
- clickstream-docker.rst
- docker-compose.yml
- examples.rst
- index.rst
- conf.py
- faq.rst
- index.rst
- make.bat
- Makefile
- operations.rst
- quickstart.rst
- README.md
- requirements.txt
- syntax-reference.rst
- findbugs-exclude.xml
- development.xml
- package.xml
- standalone.xml
- CliSpecificCommand.java
- Console.java
- JLineReader.java
- JLineTerminal.java
- LineReader.java
- OutputFormat.java
- Cli.java
- Options.java
- CliUtils.java
- TimestampLogFileAppender.java
- Ksql.java
- log4j.properties
- OptionsTest.java
- ConsoleTest.java
- RemoteCliSpecificCommandTest.java
- KsqlRestClientTest.java
- CliUtilsTest.java
- CliTest.java
- CliTestFailedException.java
- FakeException.java
- TestLineReader.java
- TestResult.java
- TestRunner.java
- TestTerminal.java
- log4j.properties
- Dockerfile
- pom.xml
- connect.properties
- null-filter-4.0.0-SNAPSHOT.jar
- README.md
- clickstream-analysis-dashboard.json
- clickstream-analysis-dashboard.sh
- clickstream-schema.sql
- drop-clickstream-schema.sql
- elastic-dynamic-template.sh
- ksql-connect-es-grafana.sh
- ksql-tables-to-grafana.sh
- malicious-users-dashboard.json
- malicious-users-dashboard.sh
- run-grafana.sh
- development.xml
- package.xml
- standalone.xml
- DemoTest.java
- Dockerfile
- grafana-success.png
- non-docker-clickstream.md
- pom.xml
- README.md
- DdlConfig.java
- LogMetricAndContinueExceptionHandler.java
- UdafAggregator.java
- ConsumerCollector.java
- MetricCollector.java
- MetricCollectors.java
- ProducerCollector.java
- TopicSensors.java
- QueryId.java
- LongColumnTimestampExtractionPolicy.java
- LongTimestampExtractor.java
- MetadataTimestampExtractionPolicy.java
- StringTimestampExtractionPolicy.java
- StringTimestampExtractor.java
- StringToTimestampParser.java
- TimestampExtractionPolicy.java
- TimestampExtractionPolicyFactory.java
- ErrorMessageUtil.java
- KsqlConfig.java
- KsqlConstants.java
- KsqlException.java
- KsqlReferentialIntegrityException.java
- Pair.java
- SchemaUtil.java
- StringUtil.java
- WelcomeMsgUtils.java
- GenericRow.java
- checkstyle.xml
- ConsumerCollectorTest.java
- MetricCollectorsTest.java
- ProducerCollectorTest.java
- LongTimestampExtractionPolicyTest.java
- StringTimestampExtractionPolicyTest.java
- StringTimestampExtractorTest.java
- TimestampExtractionPolicyFactoryTest.java
- ErrorMessageUtilTest.java
- KsqlConfigTest.java
- SchemaUtilTest.java
- WelcomeMsgUtilsTest.java
- pom.xml
- resources.xml
- pom.xml
- AggregateAnalysis.java
- AggregateAnalyzer.java
- Analysis.java
- AnalysisContext.java
- Analyzer.java
- ExpressionAnalyzer.java
- QueryAnalyzer.java
- CodeGenRunner.java
- SqlToJavaVisitor.java
- AbstractCreateStreamCommand.java
- CommandFactories.java
- CreateStreamCommand.java
- CreateTableCommand.java
- DdlCommand.java
- DdlCommandExec.java
- DdlCommandFactory.java
- DdlCommandResult.java
- DropSourceCommand.java
- DropTopicCommand.java
- RegisterTopicCommand.java
- SetPropertyCommand.java
- ExceptionUtil.java
- KafkaResponseGetFailedException.java
- KafkaTopicClientException.java
- KafkaTopicException.java
- CountAggFunctionFactory.java
- CountKudaf.java
- DoubleMaxKudaf.java
- IntegerMaxKudaf.java
- LongMaxKudaf.java
- MaxAggFunctionFactory.java
- DoubleMinKudaf.java
- IntegerMinKudaf.java
- LongMinKudaf.java
- MinAggFunctionFactory.java
- DoubleSumKudaf.java
- IntegerSumKudaf.java
- LongSumKudaf.java
- SumAggFunctionFactory.java
- TopKAggregateFunctionFactory.java
- TopkKudaf.java
- TopkDistinctAggFunctionFactory.java
- TopkDistinctKudaf.java
- KudafAggregator.java
- KudafInitializer.java
- StringToTimestamp.java
- TimestampToString.java
- ArrayContainsKudf.java
- JsonExtractStringKudf.java
- AbsKudf.java
- CeilKudf.java
- FloorKudf.java
- RandomKudf.java
- RoundKudf.java
- AnomalyKudf.java
- DeepLearning_model_R_1509973865970_1.java
- ConcatKudf.java
- IfNullKudf.java
- LCaseKudf.java
- LenKudf.java
- SubstringKudf.java
- TrimKudf.java
- UCaseKudf.java
- Kudf.java
- AggregateFunctionFactory.java
- FunctionRegistry.java
- KsqlAggregateFunction.java
- KsqlFunction.java
- KsqlFunctionException.java
- KsqlEngineMetrics.java
- AddTimestampColumn.java
- KafkaStreamsBuilder.java
- KafkaStreamsBuilderImpl.java
- PhysicalPlanBuilder.java
- AggregateNode.java
- FilterNode.java
- JoinNode.java
- KsqlBareOutputNode.java
- KsqlStructuredDataOutputNode.java
- OutputNode.java
- PlanNode.java
- PlanNodeId.java
- PlanVisitor.java
- ProjectNode.java
- StructuredDataSourceNode.java
- LogicalPlanner.java
- PlanException.java
- PlanSourceExtractorVisitor.java
- KsqlSchemaRegistryClientFactory.java
- QueuedSchemaKStream.java
- SchemaKGroupedStream.java
- SchemaKStream.java
- SchemaKTable.java
- SelectValueMapper.java
- SqlPredicate.java
- JsonPathTokenizer.java
- AggregateExpressionRewriter.java
- ArrayUtil.java
- AvroUtil.java
- ExpressionMetadata.java
- ExpressionTypeManager.java
- GenericRowValueTypeEnforcer.java
- KafkaConsumerGroupClient.java
- KafkaConsumerGroupClientImpl.java
- KafkaTopicClient.java
- KafkaTopicClientImpl.java
- PersistentQueryMetadata.java
- QueryMetadata.java
- QueuedQueryMetadata.java
- SerDeUtil.java
- Version.java
- KsqlContext.java
- KsqlEngine.java
- QueryEngine.java
- checkstyle.xml
- log4j.properties
- version.properties
- AggregateAnalyzerTest.java
- AnalyzerTest.java
- QueryAnalyzerTest.java
- CodeGenRunnerTest.java
- SqlToJavaVisitorTest.java
- CommandFactoriesTest.java
- IntegerMaxKudafTest.java
- IntegerMinKudafTest.java
- IntegerSumKudafTest.java
- DoubleTopkKudafTest.java
- IntTopkKudafTest.java
- LongTopkKudafTest.java
- StringTopkKudafTest.java
- DoubleTopkDistinctKudafTest.java
- IntTopkDistinctKudafTest.java
- LongTopkDistinctKudafTest.java
- StringTopkDistinctKudafTest.java
- StringToTimestampTest.java
- TimestampToStringTest.java
- ArrayContainsKudfTest.java
- JsonExtractStringKudfTest.java
- EndToEndIntegrationTest.java
- IntegrationTestHarness.java
- JoinIntTest.java
- JsonFormatTest.java
- SecureIntegrationTest.java
- StreamsSelectAndProjectIntTest.java
- UdfIntTest.java
- WindowingIntTest.java
- KsqlEngineMetricsTest.java
- PhysicalPlanBuilderTest.java
- AggregateNodeTest.java
- JoinNodeTest.java
- KsqlBareOutputNodeTest.java
- KsqlStructuredDataOutputNodeTest.java
- PlanTestUtil.java
- ProjectNodeTest.java
- StructuredDataSourceNodeTest.java
- LogicalPlannerTest.java
- PlanSourceExtractorVisitorTest.java
- KsqlSchemaRegistryClientFactoryTest.java
- LogicalPlanBuilder.java
- SchemaKStreamTest.java
- SchemaKTableTest.java
- SelectValueMapperTest.java
- SqlPredicateTest.java
- ClientTrustStore.java
- Credentials.java
- KeyStoreUtil.java
- SecureKafkaHelper.java
- ServerKeyStore.java
- AssertEventually.java
- EmbeddedSingleNodeKafkaCluster.java
- IntegrationTestUtils.java
- KafkaEmbedded.java
- ZooKeeperEmbedded.java
- JsonPathTokenizerTest.java
- ArrayUtilTest.java
- AvroUtilTest.java
- ExpressionTypeManagerTest.java
- FakeKafkaTopicClient.java
- GenericRowValueTypeEnforcerTest.java
- ItemDataProvider.java
- KafkaTopicClientImplIntegrationTest.java
- KafkaTopicClientImplTest.java
- OrderDataProvider.java
- PageViewDataProvider.java
- SchemaUtilTest.java
- SerDeUtilTest.java
- TestDataProvider.java
- TopicConsumer.java
- TopicProducer.java
- UserDataProvider.java
- KsqlContextTest.java
- KsqlEngineTest.java
- QueryTranslationTest.java
- average.json
- count.json
- having.json
- hopping-windows.json
- joins.json
- max-group-by.json
- min-group-by.json
- partition-by.json
- project-filter.json
- README.md
- session-windows.json
- sum.json
- topk-distinct.json
- topk-group-by.json
- tumbling-windows.json
- avro_order_schema.avro
- log4j.properties
- TestCatalog.json
- pom.xml
- development.xml
- package.xml
- standalone.xml
- Generator.java
- Main.java
- AvroProducer.java
- DataGen.java
- DataGenProducer.java
- DelimitedProducer.java
- JsonProducer.java
- SessionManager.java
- EmbeddedKsql.java
- clickstream_codes_schema.avro
- clickstream_schema.avro
- clickstream_users_schema.avro
- inventory.avro
- ksql-server.properties
- orders_schema.avro
- pageviews_schema.avro
- product.avro
- purchase.avro
- ratings_schema.avro
- SampleQueries.sql
- users_array_map_schema.avro
- users_schema.avro
- SessionManagerTest.java
- Dockerfile
- pom.xml
- README.md
- KsqlStdOut.java
- KsqlStream.java
- KsqlTable.java
- KsqlTopic.java
- MetaStore.java
- MetaStoreImpl.java
- ReferentialIntegrityTableEntry.java
- StructuredDataSource.java
- MetastoreTest.java
- StructuredDataSourceTest.java
- MetaStoreFixture.java
- avro_order_schema.avro
- TestCatalog.json
- pom.xml
- development.xml
- package.xml
- standalone.xml
- pom.xml
- SqlBase.g4
- ParseFailedException.java
- AbstractStreamCreateStatement.java
- AbstractStreamDropStatement.java
- AliasedRelation.java
- AllColumns.java
- ArithmeticBinaryExpression.java
- ArithmeticUnaryExpression.java
- AstVisitor.java
- BetweenPredicate.java
- BinaryLiteral.java
- BooleanLiteral.java
- Cast.java
- ComparisonExpression.java
- CreateAsSelect.java
- CreateStream.java
- CreateStreamAsSelect.java
- CreateTable.java
- CreateTableAsSelect.java
- CreateView.java
- DdlStatement.java
- DecimalLiteral.java
- DefaultAstVisitor.java
- DefaultExpressionTraversalVisitor.java
- DefaultTraversalVisitor.java
- Delete.java
- DereferenceExpression.java
- DoubleLiteral.java
- DropStream.java
- DropTable.java
- DropTopic.java
- DropView.java
- EmptyStatement.java
- ExistsPredicate.java
- Explain.java
- ExplainFormat.java
- ExplainOption.java
- ExplainType.java
- ExportCatalog.java
- Expression.java
- ExpressionRewriter.java
- ExpressionTreeRewriter.java
- Extract.java
- FieldReference.java
- FrameBound.java
- FunctionCall.java
- GenericLiteral.java
- GroupBy.java
- GroupingElement.java
- HoppingWindowExpression.java
- InListExpression.java
- InPredicate.java
- IntervalLiteral.java
- IsNotNullPredicate.java
- IsNullPredicate.java
- Join.java
- JoinCriteria.java
- JoinOn.java
- JoinUsing.java
- KsqlWindowExpression.java
- LambdaExpression.java
- LikePredicate.java
- ListProperties.java
- ListQueries.java
- ListRegisteredTopics.java
- ListStreams.java
- ListTables.java
- ListTopics.java
- Literal.java
- LoadProperties.java
- LogicalBinaryExpression.java
- LongLiteral.java
- NaturalJoin.java
- Node.java
- NodeLocation.java
- NotExpression.java
- NullIfExpression.java
- NullLiteral.java
- PrintTopic.java
- QualifiedName.java
- QualifiedNameReference.java
- Query.java
- QueryBody.java
- QuerySpecification.java
- RegisterTopic.java
- Relation.java
- RenameColumn.java
- RenameTable.java
- Row.java
- RunScript.java
- SampledRelation.java
- SearchedCaseExpression.java
- Select.java
- SelectItem.java
- SessionWindowExpression.java
- SetOperation.java
- SetProperty.java
- SetSession.java
- ShowCatalogs.java
- ShowColumns.java
- ShowCreate.java
- ShowFunctions.java
- ShowPartitions.java
- SimpleCaseExpression.java
- SimpleGroupBy.java
- SingleColumn.java
- StackableAstVisitor.java
- Statement.java
- Statements.java
- StringLiteral.java
- SubqueryExpression.java
- SubscriptExpression.java
- SymbolReference.java
- Table.java
- TableElement.java
- TableSubquery.java
- TerminateQuery.java
- TimeLiteral.java
- TimestampLiteral.java
- TumblingWindowExpression.java
- UnsetProperty.java
- Values.java
- WhenClause.java
- Window.java
- WindowExpression.java
- WindowFrame.java
- WindowName.java
- WithQuery.java
- AstBuilder.java
- CaseInsensitiveStream.java
- DefaultTraversalVisitor.java
- ExpressionFormatter.java
- KsqlParser.java
- KsqlParserErrorStrategy.java
- ParsingException.java
- SqlFormatter.java
- DataSourceExtractor.java
- KsqlPreconditions.java
- HoppingWindowExpressionTest.java
- SessionWindowExpressionTest.java
- TumblingWindowExpressionTest.java
- ExpressionFormatterTest.java
- KsqlParserTest.java
- checkstyle.xml
- log4j.properties
- pom.xml
- development.xml
- package.xml
- standalone.xml
- KsqlRestClientException.java
- KsqlRestClient.java
- RestResponse.java
- CommandStatus.java
- CommandStatusEntity.java
- CommandStatuses.java
- ExecutionPlan.java
- KafkaTopicInfo.java
- KafkaTopicsList.java
- KsqlEntity.java
- KsqlEntityList.java
- KsqlErrorMessage.java
- KsqlRequest.java
- KsqlStatementErrorMessage.java
- KsqlTopicInfo.java
- KsqlTopicsList.java
- PropertiesList.java
- Queries.java
- SchemaMapper.java
- ServerInfo.java
- SourceDescription.java
- SourceInfo.java
- StreamedRow.java
- StreamsList.java
- TablesList.java
- TopicDescription.java
- Command.java
- CommandId.java
- CommandIdAssigner.java
- CommandRunner.java
- CommandStatusFuture.java
- CommandStore.java
- RestoreCommands.java
- StatementExecutor.java
- QueryStreamWriter.java
- StreamedQueryResource.java
- TopicStreamWriter.java
- WSQueryEndpoint.java
- Errors.java
- KsqlExceptionMapper.java
- KsqlResource.java
- KsqlRestException.java
- RootDocument.java
- ServerInfoResource.java
- StatusResource.java
- Executable.java
- KsqlRestApplication.java
- KsqlRestConfig.java
- KsqlServerMain.java
- ServerOptions.java
- StandaloneExecutor.java
- StatementParser.java
- OptionsParser.java
- ZipUtil.java
- log4j.properties
- KsqlRestClientTest.java
- KafkaTopicsListTest.java
- KsqlTopicsListTest.java
- ServerInfoTest.java
- CommandRunnerTest.java
- CommandStoreTest.java
- CommandTest.java
- RestoreCommandsTest.java
- StatementExecutorTest.java
- MockApplication.java
- MockKafkaTopicClient.java
- MockKsqlResources.java
- MockStatusResource.java
- MockStreamedQueryResource.java
- TopicStreamWriterFormatTest.java
- KsqlExceptionMapperTest.java
- KsqlResourceTest.java
- StatusResourceTest.java
- StreamedQueryResourceTest.java
- TestUtils.java
- KsqlRestApplicationTest.java
- KsqlRestConfigTest.java
- ServerOptionsTest.java
- StandaloneExecutorTest.java
- Dockerfile
- pom.xml
- KsqlAvroTopicSerDe.java
- KsqlGenericRowAvroDeserializer.java
- KsqlGenericRowAvroSerializer.java
- KsqlDelimitedDeserializer.java
- KsqlDelimitedSerializer.java
- KsqlDelimitedTopicSerDe.java
- KsqlJsonDeserializer.java
- KsqlJsonSerializer.java
- KsqlJsonTopicSerDe.java
- DataSource.java
- KsqlTopicSerDe.java
- KsqlGenericRowAvroDeserializerTest.java
- KsqlGenericRowAvroSerializerTest.java
- KsqlDelimitedDeserializerTest.java
- KsqlDelimitedSerializerTest.java
- KsqlJsonDeserializerTest.java
- KsqlJsonSerializerTest.java
- pom.xml
- development.xml
- package.xml
- standalone.xml
- ArgumentParseException.java
- PrintMetrics.java
- PrintMetricsException.java
- pom.xml
- KsqlVersionMetrics.avsc
- BasicCollector.java
- KsqlModuleType.java
- KsqlVersionChecker.java
- KsqlVersionCheckerAgent.java
- KsqlVersionCheckerResponseHandler.java
- VersionCheckerAgent.java
- BasicCollectorTest.java
- KsqlVersionCheckerResponseHandlerTest.java
- VersionCheckerIntegrationTest.java
- pom.xml
- test.txt
- LICENSE-annotations-3.0.1.txt
- LICENSE-antlr4-runtime-4.7.txt
- LICENSE-avro-1.8.1.txt
- LICENSE-avro-random-generator-0.1-20170531.181813-9.txt
- LICENSE-commons-collections4-4.0.txt
- LICENSE-commons-compress-1.8.1.txt
- LICENSE-commons-csv-1.4.txt
- LICENSE-commons-lang3-3.3.2.txt
- LICENSE-generex-1.0.1.txt
- LICENSE-jackson-annotations-2.8.0.txt
- LICENSE-jackson-core-2.8.4.txt
- LICENSE-jackson-core-2.8.5.txt
- LICENSE-jackson-core-asl-1.9.13.txt
- LICENSE-jackson-databind-2.8.4.txt
- LICENSE-jackson-databind-2.8.5.txt
- LICENSE-jackson-mapper-asl-1.9.13.txt
- LICENSE-jline-3.3.1.txt
- LICENSE-jol-core-0.2.txt
- LICENSE-jopt-simple-5.0.4.txt
- LICENSE-jsr305-3.0.2.txt
- LICENSE-log4j-1.2.17.txt
- LICENSE-netty-3.7.0.Final.txt
- LICENSE-snappy-java-1.1.1.3.txt
- LICENSE-snappy-java-1.1.4.txt
- LICENSE-zookeeper-3.4.8.txt
- licenses.html
- cli-180417-161153.log
- cli-180417-161205.log
- cli-180417-161236.log
- cli-180417-161906.log
- cli-180417-163914.log
- ksql-kafka.log
- NOTICE-avro-1.8.1.txt
- NOTICE-jackson-core-2.8.5.txt
- NOTICE-jackson-core-asl-1.9.13.txt
- NOTICE-jackson-databind-2.8.5.txt
- NOTICE-jackson-mapper-asl-1.9.13.txt
- NOTICE-log4j-1.2.17.txt
- cc01.jpg
- kibana_01.jpg
- ksq-lrocket.png
- KSQL_UDF_Deep_Learning_IoT.png
- screencast.jpg
- ecg_discord_test.csv
- ecg_discord_test.msgs
- ecg_discord_train.csv
- stream_loop_of_test_data_into_kafka.sh
- .github_changelog_generator
- .gitignore
- CHANGELOG.md
- create_es_sinks.sh
- demo.adoc
- DEVELOPMENT.md
- EcdSensorData.avro
- Jenkinsfile
- kibana_objects.json
- LICENSE
- pom.xml
- README.md
// repository documentation
Was this content helpful?
(0 ratings)
