.gitignore
Dockerfile
Makefile
README.md
pyproject.toml
req.txt
requirements.txt
requirements_dev.txt
setup.cfg
setup.py
test.py
data/cloudtrail_data_sample.json
data/coinbase_column_data.json
data/coinbase_data_ddl.sql
data/coinbase_preview_data.json
data/payload_data_sample_onboarding.txt
data/sie_xray_column.json
data/sie_xray_data_sample.json
data/sie_xray_ddl.sql
docker/Makefile
docker/docker-compose.yaml
docker/notebooks/CSVDataProducer.ipynb
docker/notebooks/CodeExecutorAgent.ipynb
docker/notebooks/DataSimulator.ipynb
docker/notebooks/DebeziumCDCDataExtractionAgent.ipynb
docker/notebooks/KafkaExplorerExeAgent.ipynb
docker/notebooks/KafkaExplorerReactiveAgent.ipynb
docker/notebooks/KafkaProtobufConsumer.ipynb
docker/notebooks/KafkaProtobufConsumerNoProtoc.ipynb
docker/notebooks/KafkaProtobufConsumerWithSchemaRegistry.ipynb
docker/notebooks/KafkaProtobufProducer.ipynb
docker/notebooks/KafkaProtobufProducerWithSchemaRegistry.ipynb
docker/notebooks/OpenAIAgent.ipynb
docker/notebooks/SchemaInferenceAgent.ipynb
docker/notebooks/SupportAnalysisAgent.ipynb
docker/notebooks/Talk2DataAgent_Reactive.ipynb
docker/notebooks/Text2SQL_Agent_llamaIndex.ipynb
docker/notebooks/Text2SQL_ReAct_AutoGen04.ipynb
docker/notebooks/llamaIndex-timeplus-connect.ipynb
docker/notebooks/mongo_cdc_payload.json
docker/notebooks/postgres_cdc_payload.json
docker/notebooks/search_result.proto
docker/notebooks/search_result_pb2.py
docker/script/analysis.sql
docker/script/debezium_extraction.sql
docker/script/debezium_extraction_ai_output.sql
docker/script/external_stream.sql
docker/script/inference.sql
docker/script/mongo_query.sh
docker/script/pipelein.md
docker/script/pipelein_s3.md
docker/script/postgres_query.sh
docker/script/register.sh
docker/script/s3_external_table.sql
docker/simulator/Dockerfile
docker/simulator/Makefile
docker/simulator/requirements.txt
docker/simulator/simulator.py
docker/tp-sync/00_chat.sql
docker/tp-sync/01_external_cdc_streams.sql
docker/tp-sync/12_data_onboarding_agent.sql
docker/tp-sync/13_data_extaction_agent.sql
docker/tp-sync/14_text2sql_agent.sql
docker/tp-sync/15_kafka_explore_reactive_agent.sql
docker/tp-sync/16_kafka_explore_code_exec_agent.sql.bak
docker/tp-sync/20_agent_config.sql
example/analysis_recommendations.py
example/cdc_flat.py
example/cdc_flat_generic.py
example/cdc_flat_mutable.py
example/cdc_hierarchy.py
example/cdc_hierarchy_generic.py
example/cdc_pipeline_builder.py
example/config_mapping.py
example/field_summary.py
example/field_summary_hierarchy.py
example/get_agent_config.py
example/inference.py
example/inference_all_types.py
example/inference_extrenal_raw.py
example/inference_hierachy.py
example/kafka_explorer.py
example/kafka_topic_explore.py
example/payload.json
example/payload_testchat.json
example/secret.py
example/sql_analyzer.py
example/text2sql.py
example/translate_ddl_to_clickhouse.py
example/validate_agent_config.py
performance/inference.json
performance/inference_agent_validation.py
prompt/inference_test_data_generation.txt
src/neutrino/__init__.py
src/neutrino/conf/__init__.py
src/neutrino/kafka/__init__.py
src/neutrino/kafka/agent.py
src/neutrino/kafka/tools.py
src/neutrino/logging/__init__.py
src/neutrino/logging/handler.py
src/neutrino/mcp/__init__.py
src/neutrino/mcp/api_server.py
src/neutrino/mcp/application_server.py
src/neutrino/mcp/cli_client.py
src/neutrino/mcp/main.py
src/neutrino/mcp/mcp_env.py
src/neutrino/mcp/mcp_server.py
src/neutrino/mcp/prompt_template.py
src/neutrino/mcp/ui_client.py
src/neutrino/mcp/utils.py
src/neutrino/message/__init__.py
src/neutrino/onboard/__init__.py
src/neutrino/onboard/agent.py
src/neutrino/pipeline/__init__.py
src/neutrino/pipeline/agent.py
src/neutrino/pipeline/cdc.py
src/neutrino/pipeline/ddl_translation.py
src/neutrino/timeplus/__init__.py
src/neutrino/timeplus/analyzer.py
src/neutrino/timeplus/text2sql.py
src/neutrino/timeplus/utils.py
src/neutrino/utils/__init__.py
src/neutrino/utils/tools.py
src/timeplus_neutrino.egg-info/PKG-INFO
src/timeplus_neutrino.egg-info/SOURCES.txt
src/timeplus_neutrino.egg-info/dependency_links.txt
src/timeplus_neutrino.egg-info/requires.txt
src/timeplus_neutrino.egg-info/top_level.txt
test/conftest.py
test/test_tools.py