CMakeLists.txt
LICENSE
MANIFEST.in
NOTICE
README.md
pyproject.toml
setup.py
vcpkg.json
cpp/cmake/modules/FindBrotli.cmake
cpp/cmake/modules/FindCSP.cmake
cpp/cmake/modules/FindColor.cmake
cpp/cmake/modules/FindDepsArrowAdapter.cmake
cpp/cmake/modules/FindDepsBase.cmake
cpp/cmake/modules/FindDepsKafkaAdapter.cmake
cpp/cmake/modules/FindDepsParquetAdapter.cmake
cpp/cmake/modules/FindGRPC.cmake
cpp/cmake/modules/FindNumpy.cmake
cpp/cmake/modules/FindPyArrow.cmake
cpp/cmake/modules/FindPythonHeaders.cmake
cpp/cmake/modules/FindRdKafka.cmake
cpp/cmake/modules/Findcsp_autogen.cmake
cpp/cmake/modules/Findlz4.cmake
cpp/cmake/modules/Findutf8proc.cmake
cpp/csp/adapters/CMakeLists.txt
cpp/csp/adapters/arrow/ArrowFieldReader.cpp
cpp/csp/adapters/arrow/ArrowFieldReader.h
cpp/csp/adapters/arrow/ArrowFieldWriter.cpp
cpp/csp/adapters/arrow/ArrowFieldWriter.h
cpp/csp/adapters/arrow/ArrowTypeVisitor.h
cpp/csp/adapters/arrow/CMakeLists.txt
cpp/csp/adapters/arrow/RecordBatchToStruct.cpp
cpp/csp/adapters/arrow/RecordBatchToStruct.h
cpp/csp/adapters/arrow/StructToRecordBatch.cpp
cpp/csp/adapters/arrow/StructToRecordBatch.h
cpp/csp/adapters/kafka/CMakeLists.txt
cpp/csp/adapters/kafka/KafkaAdapterManager.cpp
cpp/csp/adapters/kafka/KafkaAdapterManager.h
cpp/csp/adapters/kafka/KafkaConsumer.cpp
cpp/csp/adapters/kafka/KafkaConsumer.h
cpp/csp/adapters/kafka/KafkaInputAdapter.cpp
cpp/csp/adapters/kafka/KafkaInputAdapter.h
cpp/csp/adapters/kafka/KafkaOutputAdapter.cpp
cpp/csp/adapters/kafka/KafkaOutputAdapter.h
cpp/csp/adapters/kafka/KafkaPublisher.cpp
cpp/csp/adapters/kafka/KafkaPublisher.h
cpp/csp/adapters/kafka/KafkaSubscriber.cpp
cpp/csp/adapters/kafka/KafkaSubscriber.h
cpp/csp/adapters/parquet/ArrowIPCFileReaderWrapper.cpp
cpp/csp/adapters/parquet/ArrowIPCFileReaderWrapper.h
cpp/csp/adapters/parquet/ArrowIPCFileWriterWrapper.cpp
cpp/csp/adapters/parquet/ArrowIPCFileWriterWrapper.h
cpp/csp/adapters/parquet/ArrowSingleColumnArrayBuilder.h
cpp/csp/adapters/parquet/CMakeLists.txt
cpp/csp/adapters/parquet/DialectGenericListReaderInterface.h
cpp/csp/adapters/parquet/DialectGenericListWriterInterface.h
cpp/csp/adapters/parquet/FileReaderWrapper.cpp
cpp/csp/adapters/parquet/FileReaderWrapper.h
cpp/csp/adapters/parquet/FileWriterWrapper.cpp
cpp/csp/adapters/parquet/FileWriterWrapper.h
cpp/csp/adapters/parquet/FileWriterWrapperContainer.cpp
cpp/csp/adapters/parquet/FileWriterWrapperContainer.h
cpp/csp/adapters/parquet/ParquetDictBasketOutputWriter.cpp
cpp/csp/adapters/parquet/ParquetDictBasketOutputWriter.h
cpp/csp/adapters/parquet/ParquetFileReaderWrapper.cpp
cpp/csp/adapters/parquet/ParquetFileReaderWrapper.h
cpp/csp/adapters/parquet/ParquetFileWriterWrapper.cpp
cpp/csp/adapters/parquet/ParquetFileWriterWrapper.h
cpp/csp/adapters/parquet/ParquetInputAdapterManager.cpp
cpp/csp/adapters/parquet/ParquetInputAdapterManager.h
cpp/csp/adapters/parquet/ParquetOutputAdapter.cpp
cpp/csp/adapters/parquet/ParquetOutputAdapter.h
cpp/csp/adapters/parquet/ParquetOutputAdapterManager.cpp
cpp/csp/adapters/parquet/ParquetOutputAdapterManager.h
cpp/csp/adapters/parquet/ParquetOutputFilenameAdapter.cpp
cpp/csp/adapters/parquet/ParquetOutputFilenameAdapter.h
cpp/csp/adapters/parquet/ParquetReader.cpp
cpp/csp/adapters/parquet/ParquetReader.h
cpp/csp/adapters/parquet/ParquetReaderColumnAdapter.cpp
cpp/csp/adapters/parquet/ParquetReaderColumnAdapter.h
cpp/csp/adapters/parquet/ParquetStatusUtils.h
cpp/csp/adapters/parquet/ParquetWriter.cpp
cpp/csp/adapters/parquet/ParquetWriter.h
cpp/csp/adapters/utils/CMakeLists.txt
cpp/csp/adapters/utils/FileUtils.h
cpp/csp/adapters/utils/JSONMessageStructConverter.cpp
cpp/csp/adapters/utils/JSONMessageStructConverter.h
cpp/csp/adapters/utils/JSONMessageWriter.h
cpp/csp/adapters/utils/MessageEnums.cpp
cpp/csp/adapters/utils/MessageEnums.h
cpp/csp/adapters/utils/MessageStructConverter.cpp
cpp/csp/adapters/utils/MessageStructConverter.h
cpp/csp/adapters/utils/MessageWriter.cpp
cpp/csp/adapters/utils/MessageWriter.h
cpp/csp/adapters/utils/RawBytesMessageStructConverter.cpp
cpp/csp/adapters/utils/RawBytesMessageStructConverter.h
cpp/csp/adapters/utils/StructAdapterInfo.h
cpp/csp/adapters/utils/ValueDispatcher.h
cpp/csp/adapters/websocket/CMakeLists.txt
cpp/csp/adapters/websocket/ClientAdapterManager.cpp
cpp/csp/adapters/websocket/ClientAdapterManager.h
cpp/csp/adapters/websocket/ClientHeaderUpdateAdapter.cpp
cpp/csp/adapters/websocket/ClientHeaderUpdateAdapter.h
cpp/csp/adapters/websocket/ClientInputAdapter.cpp
cpp/csp/adapters/websocket/ClientInputAdapter.h
cpp/csp/adapters/websocket/ClientOutputAdapter.cpp
cpp/csp/adapters/websocket/ClientOutputAdapter.h
cpp/csp/adapters/websocket/WebsocketEndpoint.cpp
cpp/csp/adapters/websocket/WebsocketEndpoint.h
cpp/csp/core/BasicAllocator.h
cpp/csp/core/CMakeLists.txt
cpp/csp/core/Config.h.in
cpp/csp/core/DynamicBitSet.h
cpp/csp/core/Enum.h
cpp/csp/core/EnumBitSet.h
cpp/csp/core/Exception.cpp
cpp/csp/core/Exception.h
cpp/csp/core/FileUtils.h
cpp/csp/core/Generator.h
cpp/csp/core/Hash.h
cpp/csp/core/Platform.h
cpp/csp/core/QueueWaiter.h
cpp/csp/core/SRMWLockFreeQueue.h
cpp/csp/core/System.h
cpp/csp/core/TaggedPointerUnion.h
cpp/csp/core/Time.cpp
cpp/csp/core/Time.h
cpp/csp/cppnodes/CMakeLists.txt
cpp/csp/cppnodes/baselibimpl.cpp
cpp/csp/cppnodes/basketlibimpl.cpp
cpp/csp/cppnodes/mathimpl.cpp
cpp/csp/cppnodes/statsimpl.cpp
cpp/csp/cppnodes/statsimpl.h
cpp/csp/engine/AdapterManager.cpp
cpp/csp/engine/AdapterManager.h
cpp/csp/engine/AlarmInputAdapter.h
cpp/csp/engine/BasketInfo.cpp
cpp/csp/engine/BasketInfo.h
cpp/csp/engine/CMakeLists.txt
cpp/csp/engine/ConstInputAdapter.h
cpp/csp/engine/Consumer.cpp
cpp/csp/engine/Consumer.h
cpp/csp/engine/CppNode.h
cpp/csp/engine/CspEnum.cpp
cpp/csp/engine/CspEnum.h
cpp/csp/engine/CspType.cpp
cpp/csp/engine/CspType.h
cpp/csp/engine/CycleStepTable.cpp
cpp/csp/engine/CycleStepTable.h
cpp/csp/engine/DialectGenericType.h
cpp/csp/engine/Dictionary.cpp
cpp/csp/engine/Dictionary.h
cpp/csp/engine/DynamicEngine.cpp
cpp/csp/engine/DynamicEngine.h
cpp/csp/engine/DynamicNode.cpp
cpp/csp/engine/DynamicNode.h
cpp/csp/engine/Engine.cpp
cpp/csp/engine/Engine.h
cpp/csp/engine/Enums.cpp
cpp/csp/engine/Enums.h
cpp/csp/engine/EventPropagator.cpp
cpp/csp/engine/EventPropagator.h
cpp/csp/engine/Feedback.h
cpp/csp/engine/GraphOutputAdapter.cpp
cpp/csp/engine/GraphOutputAdapter.h
cpp/csp/engine/InputAdapter.cpp
cpp/csp/engine/InputAdapter.h
cpp/csp/engine/InputId.h
cpp/csp/engine/Node.cpp
cpp/csp/engine/Node.h
cpp/csp/engine/OutputAdapter.cpp
cpp/csp/engine/OutputAdapter.h
cpp/csp/engine/PartialSwitchCspType.h
cpp/csp/engine/PendingPushEvents.cpp
cpp/csp/engine/PendingPushEvents.h
cpp/csp/engine/Profiler.h
cpp/csp/engine/PullInputAdapter.h
cpp/csp/engine/PushEvent.h
cpp/csp/engine/PushInputAdapter.h
cpp/csp/engine/PushPullEvent.h
cpp/csp/engine/PushPullInputAdapter.cpp
cpp/csp/engine/PushPullInputAdapter.h
cpp/csp/engine/RootEngine.cpp
cpp/csp/engine/RootEngine.h
cpp/csp/engine/Scheduler.cpp
cpp/csp/engine/Scheduler.h
cpp/csp/engine/StatusAdapter.cpp
cpp/csp/engine/StatusAdapter.h
cpp/csp/engine/Struct.cpp
cpp/csp/engine/Struct.h
cpp/csp/engine/TickBuffer.h
cpp/csp/engine/TimeSeries.cpp
cpp/csp/engine/TimeSeries.h
cpp/csp/engine/TimeSeriesProvider.cpp
cpp/csp/engine/TimeSeriesProvider.h
cpp/csp/engine/TimerInputAdapter.h
cpp/csp/engine/TypeCast.h
cpp/csp/engine/VectorContainer.cpp
cpp/csp/engine/VectorContainer.h
cpp/csp/engine/WindowBuffer.h
cpp/csp/python/CMakeLists.txt
cpp/csp/python/Common.h
cpp/csp/python/Conversions.cpp
cpp/csp/python/Conversions.h
cpp/csp/python/CspTypeFactory.cpp
cpp/csp/python/CspTypeFactory.h
cpp/csp/python/Exception.h
cpp/csp/python/InitHelper.h
cpp/csp/python/NumpyConversions.cpp
cpp/csp/python/NumpyConversions.h
cpp/csp/python/NumpyInputAdapter.h
cpp/csp/python/PyAdapterManager.cpp
cpp/csp/python/PyAdapterManager.h
cpp/csp/python/PyAdapterManagerWrapper.cpp
cpp/csp/python/PyAdapterManagerWrapper.h
cpp/csp/python/PyBasketInputProxy.cpp
cpp/csp/python/PyBasketInputProxy.h
cpp/csp/python/PyBasketOutputProxy.cpp
cpp/csp/python/PyBasketOutputProxy.h
cpp/csp/python/PyConstAdapter.cpp
cpp/csp/python/PyConstants.cpp
cpp/csp/python/PyConstants.h
cpp/csp/python/PyCppNode.cpp
cpp/csp/python/PyCppNode.h
cpp/csp/python/PyCspEnum.cpp
cpp/csp/python/PyCspEnum.h
cpp/csp/python/PyCspType.cpp
cpp/csp/python/PyCspType.h
cpp/csp/python/PyDynamicNode.cpp
cpp/csp/python/PyEngine.cpp
cpp/csp/python/PyEngine.h
cpp/csp/python/PyFeedbackAdapter.cpp
cpp/csp/python/PyGraphOutputAdapter.cpp
cpp/csp/python/PyGraphOutputAdapter.h
cpp/csp/python/PyInputAdapterWrapper.cpp
cpp/csp/python/PyInputAdapterWrapper.h
cpp/csp/python/PyInputProxy.cpp
cpp/csp/python/PyInputProxy.h
cpp/csp/python/PyIterator.h
cpp/csp/python/PyManagedSimInputAdapter.cpp
cpp/csp/python/PyNode.cpp
cpp/csp/python/PyNode.h
cpp/csp/python/PyNodeWrapper.cpp
cpp/csp/python/PyNodeWrapper.h
cpp/csp/python/PyNumbaNode.cpp
cpp/csp/python/PyNumbaNode.h
cpp/csp/python/PyNumpyAdapter.cpp
cpp/csp/python/PyObjectPtr.h
cpp/csp/python/PyOutputAdapter.cpp
cpp/csp/python/PyOutputAdapterWrapper.cpp
cpp/csp/python/PyOutputAdapterWrapper.h
cpp/csp/python/PyOutputProxy.cpp
cpp/csp/python/PyOutputProxy.h
cpp/csp/python/PyPullInputAdapter.cpp
cpp/csp/python/PyPushInputAdapter.cpp
cpp/csp/python/PyPushInputAdapter.h
cpp/csp/python/PyPushPullInputAdapter.cpp
cpp/csp/python/PyStruct.cpp
cpp/csp/python/PyStruct.h
cpp/csp/python/PyStructFastList.h
cpp/csp/python/PyStructFastList_impl.h
cpp/csp/python/PyStructList.h
cpp/csp/python/PyStructList_impl.h
cpp/csp/python/PyStructToDict.cpp
cpp/csp/python/PyStructToDict.h
cpp/csp/python/PyStructToJson.cpp
cpp/csp/python/PyStructToJson.h
cpp/csp/python/PyTimerAdapter.cpp
cpp/csp/python/VectorWrapper.h
cpp/csp/python/cspbaselibimpl.cpp
cpp/csp/python/cspbasketlibimpl.cpp
cpp/csp/python/cspimpl.cpp
cpp/csp/python/cspmathimpl.cpp
cpp/csp/python/cspnpstatsimpl.cpp
cpp/csp/python/cspstatsimpl.cpp
cpp/csp/python/csptestlibimpl.cpp
cpp/csp/python/csptypesimpl.cpp
cpp/csp/python/npstatsimpl.cpp
cpp/csp/python/adapters/ArrowCppNodes.cpp
cpp/csp/python/adapters/ArrowInputAdapter.h
cpp/csp/python/adapters/ArrowNumpyListReader.h
cpp/csp/python/adapters/ArrowNumpyListWriter.h
cpp/csp/python/adapters/CMakeLists.txt
cpp/csp/python/adapters/PyArrowInputAdapter.cpp
cpp/csp/python/adapters/kafkaadapterimpl.cpp
cpp/csp/python/adapters/parquetadapterimpl.cpp
cpp/csp/python/adapters/websocketadapterimpl.cpp
cpp/tests/CMakeLists.txt
cpp/tests/core/CMakeLists.txt
cpp/tests/core/test_basic_allocator.cpp
cpp/tests/core/test_dynamicbitset.cpp
cpp/tests/core/test_enum.cpp
cpp/tests/core/test_platform.cpp
cpp/tests/core/test_srmwlockfreequeue.cpp
cpp/tests/core/test_tagged_pointer_union.cpp
cpp/tests/core/test_time.cpp
cpp/tests/engine/CMakeLists.txt
cpp/tests/engine/test_dictionary.cpp
cpp/tests/engine/test_engine_initial.cpp
cpp/tests/engine/test_partial_switch_csp_type.cpp
cpp/tests/engine/test_tick_buffer.cpp
cpp/tests/engine/test_time_series.cpp
cpp/tests/engine/test_window_buffer.cpp
csp/__init__.py
csp/baselib.py
csp/basketlib.py
csp/curve.py
csp/dataframe.py
csp/math.py
csp/profiler.py
csp/random.py
csp/showgraph.py
csp/stats.py
csp/typing.py
csp.egg-info/PKG-INFO
csp.egg-info/SOURCES.txt
csp.egg-info/dependency_links.txt
csp.egg-info/requires.txt
csp.egg-info/top_level.txt
csp/adapters/__init__.py
csp/adapters/arrow.py
csp/adapters/csv.py
csp/adapters/db.py
csp/adapters/kafka.py
csp/adapters/parquet.py
csp/adapters/perspective.py
csp/adapters/slack.py
csp/adapters/status.py
csp/adapters/symphony.py
csp/adapters/utils.py
csp/adapters/websocket.py
csp/adapters/websocket_types.py
csp/adapters/output_adapters/__init__.py
csp/adapters/output_adapters/parquet.py
csp/adapters/output_adapters/parquet_utility_nodes.py
csp/build/csp_autogen.py
csp/impl/__cspimpl.py
csp/impl/__csptypesimpl.py
csp/impl/__init__.py
csp/impl/adaptermanager.py
csp/impl/builtin_functions.py
csp/impl/constants.py
csp/impl/enum.py
csp/impl/error_handling.py
csp/impl/genericpushadapter.py
csp/impl/mem_cache.py
csp/impl/outputadapter.py
csp/impl/pandas.py
csp/impl/pandas_accessor.py
csp/impl/pandas_ext_type.py
csp/impl/pandas_perspective.py
csp/impl/perspective_common.py
csp/impl/pulladapter.py
csp/impl/pushadapter.py
csp/impl/pushpulladapter.py
csp/impl/struct.py
csp/impl/warnings.py
csp/impl/types/__init__.py
csp/impl/types/autogen_types.py
csp/impl/types/common_definitions.py
csp/impl/types/container_type_normalizer.py
csp/impl/types/generic_values_resolver.py
csp/impl/types/instantiation_type_resolver.py
csp/impl/types/numpy_type_util.py
csp/impl/types/pydantic_type_resolver.py
csp/impl/types/pydantic_types.py
csp/impl/types/tstype.py
csp/impl/types/type_annotation_normalizer_transformer.py
csp/impl/types/typing_utils.py
csp/impl/wiring/__init__.py
csp/impl/wiring/adapters.py
csp/impl/wiring/ast_utils.py
csp/impl/wiring/base_parser.py
csp/impl/wiring/context.py
csp/impl/wiring/delayed_edge.py
csp/impl/wiring/delayed_node.py
csp/impl/wiring/dynamic.py
csp/impl/wiring/edge.py
csp/impl/wiring/feedback.py
csp/impl/wiring/graph.py
csp/impl/wiring/graph_parser.py
csp/impl/wiring/node.py
csp/impl/wiring/node_parser.py
csp/impl/wiring/numba_node.py
csp/impl/wiring/numba_node_parser.py
csp/impl/wiring/outputs.py
csp/impl/wiring/runtime.py
csp/impl/wiring/signature.py
csp/impl/wiring/special_output_names.py
csp/impl/wiring/threaded_runtime.py
csp/impl/wiring/numba_utils/__init__.py
csp/impl/wiring/numba_utils/csp_cpp_numba_interface.py
csp/impl/wiring/numba_utils/csp_numba_functions.py
csp/impl/wiring/numba_utils/csp_string_extension.py
csp/impl/wiring/numba_utils/datetime_extension.py
csp/impl/wiring/numba_utils/numba_type_resolver.py
csp/tests/__init__.py
csp/tests/test_baselib.py
csp/tests/test_basketlib.py
csp/tests/test_baskets.py
csp/tests/test_build.py
csp/tests/test_curve.py
csp/tests/test_dynamic.py
csp/tests/test_engine.py
csp/tests/test_examples.py
csp/tests/test_graph_mem_cache.py
csp/tests/test_history.py
csp/tests/test_math.py
csp/tests/test_numba_features.py
csp/tests/test_numba_type_checking.py
csp/tests/test_parsing.py
csp/tests/test_profiler.py
csp/tests/test_random.py
csp/tests/test_showgraph.py
csp/tests/test_stats.py
csp/tests/test_strict_structs.py
csp/tests/test_type_checking.py
csp/tests/test_typing.py
csp/tests/adapters/__init__.py
csp/tests/adapters/arrow_test_data.arrow
csp/tests/adapters/conftest.py
csp/tests/adapters/csv_test_data.csv
csp/tests/adapters/kafka_utils.py
csp/tests/adapters/parquet_test_data.parquet
csp/tests/adapters/test_arrow.py
csp/tests/adapters/test_arrow_record_batches.py
csp/tests/adapters/test_csv.py
csp/tests/adapters/test_db.py
csp/tests/adapters/test_kafka.py
csp/tests/adapters/test_numpy.py
csp/tests/adapters/test_parquet.py
csp/tests/adapters/test_perspective.py
csp/tests/adapters/test_status.py
csp/tests/adapters/test_websocket.py
csp/tests/impl/__init__.py
csp/tests/impl/test_custom_push_adapter.py
csp/tests/impl/test_dateframe.py
csp/tests/impl/test_enum.py
csp/tests/impl/test_error_handling.py
csp/tests/impl/test_genericpushadapter.py
csp/tests/impl/test_numba_features_support.py
csp/tests/impl/test_outputadapter.py
csp/tests/impl/test_pandas.py
csp/tests/impl/test_pandas_accessor.py
csp/tests/impl/test_pandas_ext_type.py
csp/tests/impl/test_pandas_perspective.py
csp/tests/impl/test_pulladapter.py
csp/tests/impl/test_pushadapter.py
csp/tests/impl/test_pushpulladapter.py
csp/tests/impl/test_struct.py
csp/tests/impl/types/__init__.py
csp/tests/impl/types/test_pydantic_type_resolver.py
csp/tests/impl/types/test_pydantic_types.py
csp/tests/impl/types/test_tstype.py
csp/tests/impl/wiring/__init__.py
csp/tests/impl/wiring/test_alarms.py
csp/tests/impl/wiring/test_basket_outputs.py
csp/tests/impl/wiring/test_edge.py
csp/tests/impl/wiring/test_node.py
csp/tests/impl/wiring/test_state.py
csp/tests/impl/wiring/test_threaded_runtime.py
csp/tests/impl/wiring/numba_utils/__init__.py
csp/tests/impl/wiring/numba_utils/test_numba_datetime_extension.py
csp/tests/test_utils/__init__.py
csp/tests/test_utils/test_datetime.py
csp/tests/utils/__init__.py
csp/tests/utils/typed_curve_generator.py
csp/utils/__init__.py
csp/utils/csp_watch_profile.py
csp/utils/datetime.py