CMakeLists.txt
LICENSE
MANIFEST.in
NOTICE
README.md
pyproject.toml
setup.py
vcpkg.json
cpp/cmake/modules/FindBrotli.cmake
cpp/cmake/modules/FindColor.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/FindSP2.cmake
cpp/cmake/modules/Findlz4.cmake
cpp/cmake/modules/Findsp2_autogen.cmake
cpp/cmake/modules/Findutf8proc.cmake
cpp/sp2/adapters/CMakeLists.txt
cpp/sp2/adapters/kafka/CMakeLists.txt
cpp/sp2/adapters/kafka/KafkaAdapterManager.cpp
cpp/sp2/adapters/kafka/KafkaAdapterManager.h
cpp/sp2/adapters/kafka/KafkaConsumer.cpp
cpp/sp2/adapters/kafka/KafkaConsumer.h
cpp/sp2/adapters/kafka/KafkaInputAdapter.cpp
cpp/sp2/adapters/kafka/KafkaInputAdapter.h
cpp/sp2/adapters/kafka/KafkaOutputAdapter.cpp
cpp/sp2/adapters/kafka/KafkaOutputAdapter.h
cpp/sp2/adapters/kafka/KafkaPublisher.cpp
cpp/sp2/adapters/kafka/KafkaPublisher.h
cpp/sp2/adapters/kafka/KafkaSubscriber.cpp
cpp/sp2/adapters/kafka/KafkaSubscriber.h
cpp/sp2/adapters/parquet/ArrowIPCFileReaderWrapper.cpp
cpp/sp2/adapters/parquet/ArrowIPCFileReaderWrapper.h
cpp/sp2/adapters/parquet/ArrowIPCFileWriterWrapper.cpp
cpp/sp2/adapters/parquet/ArrowIPCFileWriterWrapper.h
cpp/sp2/adapters/parquet/ArrowSingleColumnArrayBuilder.h
cpp/sp2/adapters/parquet/CMakeLists.txt
cpp/sp2/adapters/parquet/DialectGenericListReaderInterface.h
cpp/sp2/adapters/parquet/DialectGenericListWriterInterface.h
cpp/sp2/adapters/parquet/FileReaderWrapper.cpp
cpp/sp2/adapters/parquet/FileReaderWrapper.h
cpp/sp2/adapters/parquet/FileWriterWrapper.cpp
cpp/sp2/adapters/parquet/FileWriterWrapper.h
cpp/sp2/adapters/parquet/FileWriterWrapperContainer.cpp
cpp/sp2/adapters/parquet/FileWriterWrapperContainer.h
cpp/sp2/adapters/parquet/ParquetDictBasketOutputWriter.cpp
cpp/sp2/adapters/parquet/ParquetDictBasketOutputWriter.h
cpp/sp2/adapters/parquet/ParquetFileReaderWrapper.cpp
cpp/sp2/adapters/parquet/ParquetFileReaderWrapper.h
cpp/sp2/adapters/parquet/ParquetFileWriterWrapper.cpp
cpp/sp2/adapters/parquet/ParquetFileWriterWrapper.h
cpp/sp2/adapters/parquet/ParquetInputAdapterManager.cpp
cpp/sp2/adapters/parquet/ParquetInputAdapterManager.h
cpp/sp2/adapters/parquet/ParquetOutputAdapter.cpp
cpp/sp2/adapters/parquet/ParquetOutputAdapter.h
cpp/sp2/adapters/parquet/ParquetOutputAdapterManager.cpp
cpp/sp2/adapters/parquet/ParquetOutputAdapterManager.h
cpp/sp2/adapters/parquet/ParquetOutputFilenameAdapter.cpp
cpp/sp2/adapters/parquet/ParquetOutputFilenameAdapter.h
cpp/sp2/adapters/parquet/ParquetReader.cpp
cpp/sp2/adapters/parquet/ParquetReader.h
cpp/sp2/adapters/parquet/ParquetReaderColumnAdapter.cpp
cpp/sp2/adapters/parquet/ParquetReaderColumnAdapter.h
cpp/sp2/adapters/parquet/ParquetStatusUtils.h
cpp/sp2/adapters/parquet/ParquetWriter.cpp
cpp/sp2/adapters/parquet/ParquetWriter.h
cpp/sp2/adapters/utils/CMakeLists.txt
cpp/sp2/adapters/utils/FileUtils.h
cpp/sp2/adapters/utils/JSONMessageStructConverter.cpp
cpp/sp2/adapters/utils/JSONMessageStructConverter.h
cpp/sp2/adapters/utils/JSONMessageWriter.h
cpp/sp2/adapters/utils/MessageEnums.cpp
cpp/sp2/adapters/utils/MessageEnums.h
cpp/sp2/adapters/utils/MessageStructConverter.cpp
cpp/sp2/adapters/utils/MessageStructConverter.h
cpp/sp2/adapters/utils/MessageWriter.cpp
cpp/sp2/adapters/utils/MessageWriter.h
cpp/sp2/adapters/utils/ProtobufHelper.cpp
cpp/sp2/adapters/utils/ProtobufHelper.h
cpp/sp2/adapters/utils/ProtobufMessageStructConverter.cpp
cpp/sp2/adapters/utils/ProtobufMessageStructConverter.h
cpp/sp2/adapters/utils/RawBytesMessageStructConverter.cpp
cpp/sp2/adapters/utils/RawBytesMessageStructConverter.h
cpp/sp2/adapters/utils/StructAdapterInfo.h
cpp/sp2/adapters/utils/ValueDispatcher.h
cpp/sp2/core/BasicAllocator.h
cpp/sp2/core/CMakeLists.txt
cpp/sp2/core/Config.h.in
cpp/sp2/core/DynamicBitSet.h
cpp/sp2/core/Enum.h
cpp/sp2/core/EnumBitSet.h
cpp/sp2/core/Exception.cpp
cpp/sp2/core/Exception.h
cpp/sp2/core/FileUtils.h
cpp/sp2/core/Generator.h
cpp/sp2/core/Hash.h
cpp/sp2/core/Likely.h
cpp/sp2/core/Platform.h
cpp/sp2/core/QueueWaiter.h
cpp/sp2/core/SRMWLockFreeQueue.h
cpp/sp2/core/System.h
cpp/sp2/core/TaggedPointerUnion.h
cpp/sp2/core/Time.cpp
cpp/sp2/core/Time.h
cpp/sp2/cppnodes/CMakeLists.txt
cpp/sp2/cppnodes/baselibimpl.cpp
cpp/sp2/cppnodes/basketlibimpl.cpp
cpp/sp2/cppnodes/mathimpl.cpp
cpp/sp2/cppnodes/statsimpl.cpp
cpp/sp2/cppnodes/statsimpl.h
cpp/sp2/engine/AdapterManager.cpp
cpp/sp2/engine/AdapterManager.h
cpp/sp2/engine/AlarmInputAdapter.h
cpp/sp2/engine/BasketInfo.cpp
cpp/sp2/engine/BasketInfo.h
cpp/sp2/engine/CMakeLists.txt
cpp/sp2/engine/ConstInputAdapter.h
cpp/sp2/engine/Consumer.cpp
cpp/sp2/engine/Consumer.h
cpp/sp2/engine/CppNode.h
cpp/sp2/engine/CycleStepTable.cpp
cpp/sp2/engine/CycleStepTable.h
cpp/sp2/engine/DialectGenericType.h
cpp/sp2/engine/Dictionary.cpp
cpp/sp2/engine/Dictionary.h
cpp/sp2/engine/DynamicEngine.cpp
cpp/sp2/engine/DynamicEngine.h
cpp/sp2/engine/DynamicNode.cpp
cpp/sp2/engine/DynamicNode.h
cpp/sp2/engine/Engine.cpp
cpp/sp2/engine/Engine.h
cpp/sp2/engine/Enums.cpp
cpp/sp2/engine/Enums.h
cpp/sp2/engine/EventPropagator.cpp
cpp/sp2/engine/EventPropagator.h
cpp/sp2/engine/Feedback.h
cpp/sp2/engine/GraphOutputAdapter.cpp
cpp/sp2/engine/GraphOutputAdapter.h
cpp/sp2/engine/InputAdapter.cpp
cpp/sp2/engine/InputAdapter.h
cpp/sp2/engine/InputId.h
cpp/sp2/engine/Node.cpp
cpp/sp2/engine/Node.h
cpp/sp2/engine/OutputAdapter.cpp
cpp/sp2/engine/OutputAdapter.h
cpp/sp2/engine/PartialSwitchSp2Type.h
cpp/sp2/engine/PendingPushEvents.cpp
cpp/sp2/engine/PendingPushEvents.h
cpp/sp2/engine/Profiler.h
cpp/sp2/engine/PullInputAdapter.h
cpp/sp2/engine/PushEvent.h
cpp/sp2/engine/PushInputAdapter.h
cpp/sp2/engine/PushPullInputAdapter.cpp
cpp/sp2/engine/PushPullInputAdapter.h
cpp/sp2/engine/RootEngine.cpp
cpp/sp2/engine/RootEngine.h
cpp/sp2/engine/Scheduler.cpp
cpp/sp2/engine/Scheduler.h
cpp/sp2/engine/Sp2Enum.cpp
cpp/sp2/engine/Sp2Enum.h
cpp/sp2/engine/Sp2Type.cpp
cpp/sp2/engine/Sp2Type.h
cpp/sp2/engine/StatusAdapter.cpp
cpp/sp2/engine/StatusAdapter.h
cpp/sp2/engine/Struct.cpp
cpp/sp2/engine/Struct.h
cpp/sp2/engine/TickBuffer.h
cpp/sp2/engine/TimeSeries.cpp
cpp/sp2/engine/TimeSeries.h
cpp/sp2/engine/TimeSeriesProvider.cpp
cpp/sp2/engine/TimeSeriesProvider.h
cpp/sp2/engine/TimerInputAdapter.h
cpp/sp2/engine/TypeCast.h
cpp/sp2/engine/VectorContainer.cpp
cpp/sp2/engine/VectorContainer.h
cpp/sp2/engine/WindowBuffer.h
cpp/sp2/python/CMakeLists.txt
cpp/sp2/python/Common.h
cpp/sp2/python/Conversions.cpp
cpp/sp2/python/Conversions.h
cpp/sp2/python/Exception.h
cpp/sp2/python/InitHelper.h
cpp/sp2/python/NumpyConversions.cpp
cpp/sp2/python/NumpyConversions.h
cpp/sp2/python/NumpyInputAdapter.h
cpp/sp2/python/PyAdapterManager.cpp
cpp/sp2/python/PyAdapterManager.h
cpp/sp2/python/PyAdapterManagerWrapper.cpp
cpp/sp2/python/PyAdapterManagerWrapper.h
cpp/sp2/python/PyBasketInputProxy.cpp
cpp/sp2/python/PyBasketInputProxy.h
cpp/sp2/python/PyBasketOutputProxy.cpp
cpp/sp2/python/PyBasketOutputProxy.h
cpp/sp2/python/PyConstAdapter.cpp
cpp/sp2/python/PyConstants.cpp
cpp/sp2/python/PyConstants.h
cpp/sp2/python/PyCppNode.cpp
cpp/sp2/python/PyCppNode.h
cpp/sp2/python/PyDynamicNode.cpp
cpp/sp2/python/PyEngine.cpp
cpp/sp2/python/PyEngine.h
cpp/sp2/python/PyFeedbackAdapter.cpp
cpp/sp2/python/PyGraphOutputAdapter.cpp
cpp/sp2/python/PyGraphOutputAdapter.h
cpp/sp2/python/PyInputAdapterWrapper.cpp
cpp/sp2/python/PyInputAdapterWrapper.h
cpp/sp2/python/PyInputProxy.cpp
cpp/sp2/python/PyInputProxy.h
cpp/sp2/python/PyIterator.h
cpp/sp2/python/PyManagedSimInputAdapter.cpp
cpp/sp2/python/PyNode.cpp
cpp/sp2/python/PyNode.h
cpp/sp2/python/PyNodeWrapper.cpp
cpp/sp2/python/PyNodeWrapper.h
cpp/sp2/python/PyNumbaNode.cpp
cpp/sp2/python/PyNumbaNode.h
cpp/sp2/python/PyNumpyAdapter.cpp
cpp/sp2/python/PyObjectPtr.h
cpp/sp2/python/PyOutputAdapter.cpp
cpp/sp2/python/PyOutputAdapterWrapper.cpp
cpp/sp2/python/PyOutputAdapterWrapper.h
cpp/sp2/python/PyOutputProxy.cpp
cpp/sp2/python/PyOutputProxy.h
cpp/sp2/python/PyPullInputAdapter.cpp
cpp/sp2/python/PyPushInputAdapter.cpp
cpp/sp2/python/PyPushInputAdapter.h
cpp/sp2/python/PyPushPullInputAdapter.cpp
cpp/sp2/python/PySp2Enum.cpp
cpp/sp2/python/PySp2Enum.h
cpp/sp2/python/PySp2Type.cpp
cpp/sp2/python/PySp2Type.h
cpp/sp2/python/PyStruct.cpp
cpp/sp2/python/PyStruct.h
cpp/sp2/python/PyTimerAdapter.cpp
cpp/sp2/python/Sp2TypeFactory.cpp
cpp/sp2/python/Sp2TypeFactory.h
cpp/sp2/python/npstatsimpl.cpp
cpp/sp2/python/sp2baselibimpl.cpp
cpp/sp2/python/sp2basketlibimpl.cpp
cpp/sp2/python/sp2impl.cpp
cpp/sp2/python/sp2mathimpl.cpp
cpp/sp2/python/sp2npstatsimpl.cpp
cpp/sp2/python/sp2statsimpl.cpp
cpp/sp2/python/sp2typesimpl.cpp
cpp/sp2/python/adapters/CMakeLists.txt
cpp/sp2/python/adapters/kafkaadapterimpl.cpp
cpp/sp2/python/adapters/parquetadapterimpl.cpp
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/CMakeLists.txt
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/api.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/arrow_to_pandas.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/arrow_to_pandas.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/arrow_to_python_internal.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/async.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/benchmark.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/benchmark.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/common.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/common.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/csv.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/csv.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/datetime.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/datetime.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/decimal.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/decimal.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/deserialize.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/deserialize.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/extension_type.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/extension_type.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/filesystem.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/filesystem.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/flight.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/flight.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/gdb.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/gdb.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/helpers.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/helpers.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/inference.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/inference.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/init.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/init.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/io.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/io.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/ipc.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/ipc.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/iterators.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/lib.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/lib_api.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_convert.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_convert.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_internal.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_interop.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_to_arrow.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/numpy_to_arrow.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/parquet_encryption.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/parquet_encryption.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/pch.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/platform.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/pyarrow.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/pyarrow.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/pyarrow_api.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/pyarrow_lib.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/python_test.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/python_test.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/python_to_arrow.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/python_to_arrow.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/serialize.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/serialize.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/type_traits.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/udf.cc
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/udf.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/python/visibility.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/int_util.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/int_util_overflow.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/io_util.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/iterator.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/key_value_metadata.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/launder.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/list_util.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/logging.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/macros.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/map.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/math_constants.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/memory.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/mutex.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/parallel.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/pcg_random.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/print.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/queue.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/range.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/ree_util.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/regex.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/rle_encoding.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/rows_to_batches.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/simd.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/small_vector.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/sort.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/spaced.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/span.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/stopwatch.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/string.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/string_builder.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/task_group.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/tdigest.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/test_common.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/thread_pool.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/time.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/tracing.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/trie.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/type_fwd.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/type_traits.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/ubsan.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/union_util.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/unreachable.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/uri.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/utf8.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/value_parsing.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/vector.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/visibility.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/windows_compatibility.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/util/windows_fixup.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/vendored/xxhash.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/vendored/portable-snippets/debug-trap.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/vendored/portable-snippets/safe-math.h
cpp/sp2/python/adapters/vendored/pyarrow-15.0.0/arrow/vendored/xxhash/xxhash.h
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_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_sp2_type.cpp
cpp/tests/engine/test_tick_buffer.cpp
cpp/tests/engine/test_time_series.cpp
cpp/tests/engine/test_window_buffer.cpp
sp2/__init__.py
sp2/baselib.py
sp2/basketlib.py
sp2/cache_support.py
sp2/curve.py
sp2/dataframe.py
sp2/math.py
sp2/profiler.py
sp2/random.py
sp2/showgraph.py
sp2/stats.py
sp2/typing.py
sp2.egg-info/PKG-INFO
sp2.egg-info/SOURCES.txt
sp2.egg-info/dependency_links.txt
sp2.egg-info/requires.txt
sp2.egg-info/top_level.txt
sp2/adapters/__init__.py
sp2/adapters/csv.py
sp2/adapters/db.py
sp2/adapters/kafka.py
sp2/adapters/parquet.py
sp2/adapters/perspective.py
sp2/adapters/slack.py
sp2/adapters/status.py
sp2/adapters/symphony.py
sp2/adapters/utils.py
sp2/adapters/websocket.py
sp2/adapters/output_adapters/__init__.py
sp2/adapters/output_adapters/parquet.py
sp2/adapters/output_adapters/parquet_utility_nodes.py
sp2/build/sp2_autogen.py
sp2/impl/__init__.py
sp2/impl/__sp2impl.py
sp2/impl/__sp2typesimpl.py
sp2/impl/adaptermanager.py
sp2/impl/builtin_functions.py
sp2/impl/config.py
sp2/impl/constants.py
sp2/impl/enum.py
sp2/impl/error_handling.py
sp2/impl/genericpushadapter.py
sp2/impl/mem_cache.py
sp2/impl/outputadapter.py
sp2/impl/pandas.py
sp2/impl/pandas_accessor.py
sp2/impl/pandas_ext_type.py
sp2/impl/pandas_perspective.py
sp2/impl/pulladapter.py
sp2/impl/pushadapter.py
sp2/impl/pushpulladapter.py
sp2/impl/struct.py
sp2/impl/warnings.py
sp2/impl/managed_dataset/__init__.py
sp2/impl/managed_dataset/aggregation_period_utils.py
sp2/impl/managed_dataset/cache_partition_argument_serializer.py
sp2/impl/managed_dataset/cache_user_custom_object_serializer.py
sp2/impl/managed_dataset/dataset_metadata.py
sp2/impl/managed_dataset/dateset_name_constants.py
sp2/impl/managed_dataset/datetime_utils.py
sp2/impl/managed_dataset/managed_dataset.py
sp2/impl/managed_dataset/managed_dataset_lock_file_util.py
sp2/impl/managed_dataset/managed_dataset_merge_utils.py
sp2/impl/managed_dataset/managed_dataset_path_resolver.py
sp2/impl/managed_dataset/managed_parquet_writer.py
sp2/impl/types/__init__.py
sp2/impl/types/autogen_types.py
sp2/impl/types/common_definitions.py
sp2/impl/types/container_type_normalizer.py
sp2/impl/types/generic_values_resolver.py
sp2/impl/types/instantiation_type_resolver.py
sp2/impl/types/numpy_type_util.py
sp2/impl/types/tstype.py
sp2/impl/types/type_annotation_normalizer_transformer.py
sp2/impl/types/typing_utils.py
sp2/impl/wiring/__init__.py
sp2/impl/wiring/adapters.py
sp2/impl/wiring/ast_utils.py
sp2/impl/wiring/base_parser.py
sp2/impl/wiring/context.py
sp2/impl/wiring/delayed_edge.py
sp2/impl/wiring/delayed_node.py
sp2/impl/wiring/dynamic.py
sp2/impl/wiring/edge.py
sp2/impl/wiring/feedback.py
sp2/impl/wiring/graph.py
sp2/impl/wiring/graph_parser.py
sp2/impl/wiring/node.py
sp2/impl/wiring/node_parser.py
sp2/impl/wiring/numba_node.py
sp2/impl/wiring/numba_node_parser.py
sp2/impl/wiring/outputs.py
sp2/impl/wiring/runtime.py
sp2/impl/wiring/signature.py
sp2/impl/wiring/special_output_names.py
sp2/impl/wiring/threaded_runtime.py
sp2/impl/wiring/cache_support/__init__.py
sp2/impl/wiring/cache_support/cache_config_resolver.py
sp2/impl/wiring/cache_support/cache_type_mapper.py
sp2/impl/wiring/cache_support/dataset_partition_cached_data.py
sp2/impl/wiring/cache_support/graph_building.py
sp2/impl/wiring/cache_support/partition_files_container.py
sp2/impl/wiring/cache_support/runtime_cache_manager.py
sp2/impl/wiring/numba_utils/__init__.py
sp2/impl/wiring/numba_utils/datetime_extension.py
sp2/impl/wiring/numba_utils/numba_type_resolver.py
sp2/impl/wiring/numba_utils/sp2_cpp_numba_interface.py
sp2/impl/wiring/numba_utils/sp2_numba_functions.py
sp2/impl/wiring/numba_utils/sp2_string_extension.py
sp2/include/sp2/adapters/kafka/KafkaAdapterManager.h
sp2/include/sp2/adapters/kafka/KafkaConsumer.h
sp2/include/sp2/adapters/kafka/KafkaInputAdapter.h
sp2/include/sp2/adapters/kafka/KafkaOutputAdapter.h
sp2/include/sp2/adapters/kafka/KafkaPublisher.h
sp2/include/sp2/adapters/kafka/KafkaSubscriber.h
sp2/include/sp2/adapters/parquet/ArrowIPCFileReaderWrapper.h
sp2/include/sp2/adapters/parquet/ArrowIPCFileWriterWrapper.h
sp2/include/sp2/adapters/parquet/ArrowSingleColumnArrayBuilder.h
sp2/include/sp2/adapters/parquet/DialectGenericListReaderInterface.h
sp2/include/sp2/adapters/parquet/DialectGenericListWriterInterface.h
sp2/include/sp2/adapters/parquet/FileReaderWrapper.h
sp2/include/sp2/adapters/parquet/FileWriterWrapper.h
sp2/include/sp2/adapters/parquet/FileWriterWrapperContainer.h
sp2/include/sp2/adapters/parquet/ParquetDictBasketOutputWriter.h
sp2/include/sp2/adapters/parquet/ParquetFileReaderWrapper.h
sp2/include/sp2/adapters/parquet/ParquetFileWriterWrapper.h
sp2/include/sp2/adapters/parquet/ParquetInputAdapterManager.h
sp2/include/sp2/adapters/parquet/ParquetOutputAdapter.h
sp2/include/sp2/adapters/parquet/ParquetOutputAdapterManager.h
sp2/include/sp2/adapters/parquet/ParquetOutputFilenameAdapter.h
sp2/include/sp2/adapters/parquet/ParquetReader.h
sp2/include/sp2/adapters/parquet/ParquetReaderColumnAdapter.h
sp2/include/sp2/adapters/parquet/ParquetStatusUtils.h
sp2/include/sp2/adapters/parquet/ParquetWriter.h
sp2/include/sp2/adapters/utils/JSONMessageStructConverter.h
sp2/include/sp2/adapters/utils/JSONMessageWriter.h
sp2/include/sp2/adapters/utils/MessageEnums.h
sp2/include/sp2/adapters/utils/MessageStructConverter.h
sp2/include/sp2/adapters/utils/MessageWriter.h
sp2/include/sp2/adapters/utils/ProtobufHelper.h
sp2/include/sp2/adapters/utils/ProtobufMessageStructConverter.h
sp2/include/sp2/adapters/utils/RawBytesMessageStructConverter.h
sp2/include/sp2/adapters/utils/StructAdapterInfo.h
sp2/include/sp2/adapters/utils/ValueDispatcher.h
sp2/include/sp2/core/BasicAllocator.h
sp2/include/sp2/core/Config.h
sp2/include/sp2/core/Config.h.in
sp2/include/sp2/core/DynamicBitSet.h
sp2/include/sp2/core/Enum.h
sp2/include/sp2/core/EnumBitSet.h
sp2/include/sp2/core/Exception.h
sp2/include/sp2/core/FileUtils.h
sp2/include/sp2/core/Generator.h
sp2/include/sp2/core/Hash.h
sp2/include/sp2/core/Likely.h
sp2/include/sp2/core/Platform.h
sp2/include/sp2/core/QueueWaiter.h
sp2/include/sp2/core/SRMWLockFreeQueue.h
sp2/include/sp2/core/System.h
sp2/include/sp2/core/TaggedPointerUnion.h
sp2/include/sp2/core/Time.h
sp2/include/sp2/cppnodes/statsimpl.h
sp2/include/sp2/engine/AdapterManager.h
sp2/include/sp2/engine/AlarmInputAdapter.h
sp2/include/sp2/engine/BasketInfo.h
sp2/include/sp2/engine/ConstInputAdapter.h
sp2/include/sp2/engine/Consumer.h
sp2/include/sp2/engine/CppNode.h
sp2/include/sp2/engine/CycleStepTable.h
sp2/include/sp2/engine/DialectGenericType.h
sp2/include/sp2/engine/Dictionary.h
sp2/include/sp2/engine/DynamicEngine.h
sp2/include/sp2/engine/DynamicNode.h
sp2/include/sp2/engine/Engine.h
sp2/include/sp2/engine/Enums.h
sp2/include/sp2/engine/EventPropagator.h
sp2/include/sp2/engine/Feedback.h
sp2/include/sp2/engine/GraphOutputAdapter.h
sp2/include/sp2/engine/InputAdapter.h
sp2/include/sp2/engine/InputId.h
sp2/include/sp2/engine/Node.h
sp2/include/sp2/engine/OutputAdapter.h
sp2/include/sp2/engine/PartialSwitchSp2Type.h
sp2/include/sp2/engine/PendingPushEvents.h
sp2/include/sp2/engine/Profiler.h
sp2/include/sp2/engine/PullInputAdapter.h
sp2/include/sp2/engine/PushEvent.h
sp2/include/sp2/engine/PushInputAdapter.h
sp2/include/sp2/engine/PushPullInputAdapter.h
sp2/include/sp2/engine/RootEngine.h
sp2/include/sp2/engine/Scheduler.h
sp2/include/sp2/engine/Sp2Enum.h
sp2/include/sp2/engine/Sp2Type.h
sp2/include/sp2/engine/StatusAdapter.h
sp2/include/sp2/engine/Struct.h
sp2/include/sp2/engine/TickBuffer.h
sp2/include/sp2/engine/TimeSeries.h
sp2/include/sp2/engine/TimeSeriesProvider.h
sp2/include/sp2/engine/TimerInputAdapter.h
sp2/include/sp2/engine/TypeCast.h
sp2/include/sp2/engine/VectorContainer.h
sp2/include/sp2/engine/WindowBuffer.h
sp2/include/sp2/engine/autogen_types.h
sp2/include/sp2/python/Common.h
sp2/include/sp2/python/Conversions.h
sp2/include/sp2/python/Exception.h
sp2/include/sp2/python/InitHelper.h
sp2/include/sp2/python/NumpyConversions.h
sp2/include/sp2/python/NumpyInputAdapter.h
sp2/include/sp2/python/PyAdapterManagerWrapper.h
sp2/include/sp2/python/PyBasketInputProxy.h
sp2/include/sp2/python/PyBasketOutputProxy.h
sp2/include/sp2/python/PyConstants.h
sp2/include/sp2/python/PyCppNode.h
sp2/include/sp2/python/PyEngine.h
sp2/include/sp2/python/PyInputAdapterWrapper.h
sp2/include/sp2/python/PyInputProxy.h
sp2/include/sp2/python/PyIterator.h
sp2/include/sp2/python/PyNode.h
sp2/include/sp2/python/PyNodeWrapper.h
sp2/include/sp2/python/PyNumbaNode.h
sp2/include/sp2/python/PyObjectPtr.h
sp2/include/sp2/python/PyOutputAdapterWrapper.h
sp2/include/sp2/python/PyOutputProxy.h
sp2/include/sp2/python/PySp2Enum.h
sp2/include/sp2/python/PySp2Type.h
sp2/include/sp2/python/PyStruct.h
sp2/include/sp2/python/Sp2TypeFactory.h
sp2/tests/__init__.py
sp2/tests/test_baselib.py
sp2/tests/test_basketlib.py
sp2/tests/test_baskets.py
sp2/tests/test_build.py
sp2/tests/test_caching.py
sp2/tests/test_curve.py
sp2/tests/test_dynamic.py
sp2/tests/test_engine.py
sp2/tests/test_examples.py
sp2/tests/test_graph_mem_cache.py
sp2/tests/test_history.py
sp2/tests/test_math.py
sp2/tests/test_numba_features.py
sp2/tests/test_numba_type_checking.py
sp2/tests/test_parsing.py
sp2/tests/test_profiler.py
sp2/tests/test_random.py
sp2/tests/test_showgraph.py
sp2/tests/test_stats.py
sp2/tests/test_type_checking.py
sp2/tests/adapters/__init__.py
sp2/tests/adapters/arrow_test_data.arrow
sp2/tests/adapters/conftest.py
sp2/tests/adapters/csv_test_data.csv
sp2/tests/adapters/kafka_utils.py
sp2/tests/adapters/parquet_test_data.parquet
sp2/tests/adapters/test_csv.py
sp2/tests/adapters/test_db.py
sp2/tests/adapters/test_kafka.py
sp2/tests/adapters/test_numpy.py
sp2/tests/adapters/test_parquet.py
sp2/tests/adapters/test_slack.py
sp2/tests/adapters/test_status.py
sp2/tests/adapters/test_symphony.py
sp2/tests/bin/test_basic_allocator
sp2/tests/bin/test_dictionary
sp2/tests/bin/test_dynamicbitset
sp2/tests/bin/test_enum
sp2/tests/bin/test_partial_switch_sp2_type
sp2/tests/bin/test_srmwlockfreequeue
sp2/tests/bin/test_tagged_pointer_union
sp2/tests/bin/test_tick_buffer
sp2/tests/bin/test_time
sp2/tests/bin/test_time_series
sp2/tests/bin/test_window_buffer
sp2/tests/impl/__init__.py
sp2/tests/impl/test_dateframe.py
sp2/tests/impl/test_enum.py
sp2/tests/impl/test_genericpushadapter.py
sp2/tests/impl/test_numba_features_support.py
sp2/tests/impl/test_outputadapter.py
sp2/tests/impl/test_pandas.py
sp2/tests/impl/test_pandas_accessor.py
sp2/tests/impl/test_pandas_ext_type.py
sp2/tests/impl/test_pandas_perspective.py
sp2/tests/impl/test_pulladapter.py
sp2/tests/impl/test_pushadapter.py
sp2/tests/impl/test_pushpulladapter.py
sp2/tests/impl/test_struct.py
sp2/tests/impl/utils/__init__.py
sp2/tests/impl/utils/test_lock_file.py
sp2/tests/impl/wiring/__init__.py
sp2/tests/impl/wiring/test_alarms.py
sp2/tests/impl/wiring/test_basket_outputs.py
sp2/tests/impl/wiring/test_edge.py
sp2/tests/impl/wiring/test_node.py
sp2/tests/impl/wiring/test_state.py
sp2/tests/impl/wiring/test_threaded_runtime.py
sp2/tests/impl/wiring/numba_utils/__init__.py
sp2/tests/impl/wiring/numba_utils/test_numba_datetime_extension.py
sp2/tests/utils/__init__.py
sp2/tests/utils/test_object_factory.py
sp2/tests/utils/typed_curve_generator.py
sp2/utils/__init__.py
sp2/utils/classproperty.py
sp2/utils/file_permissions.py
sp2/utils/lock_file.py
sp2/utils/object_factory_registry.py
sp2/utils/qualified_name_utils.py
sp2/utils/rm_utils.py
sp2/utils/sp2_watch_profile.py