OmniStream/cpp/runtime/partition/consumer · openEuler/OmniStream - AtomGit

文件	最后提交记录	最后更新时间
BufferAndAvailability.cpp	update with yellow zone	7 个月前
BufferAndAvailability.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
BufferManager.cpp	CleanCode	3 个月前
BufferManager.h	Support for unaligned checkpoint restore with flink mode	3 个月前
BufferOrEvent.cpp	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
BufferOrEvent.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
IndexedInputGate.cpp	Supplementary processes	4 个月前
IndexedInputGate.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
InputChannel.cpp	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
InputChannel.h	Support for unaligned checkpoint restore with flink mode	3 个月前
InputChannelInfo.cpp	fix inflightbuffers persistence	3 个月前
InputChannelInfo.h	rescal recover	3 个月前
InputGate.cpp	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
InputGate.h	Fix restoreGates call to RequestPartitions to not depend on taskType.	2 个月前
InputGateID.cpp	update with yellow zone	7 个月前
InputGateID.h	1. append InputGateID.h < method; 2. append RowData::createFieldGetter OMNI_VARCHAR case	7 个月前
InputWithData.cpp	update with yellow zone	7 个月前
InputWithData.h	update with yellow zone	7 个月前
LocalInputChannel.cpp	02	6 天前
LocalInputChannel.h	Add the announcement processing function	4 个月前
LocalRecoveredInputChannel.h	序列化器 TimeWindow::Serializer	20 天前
OmniLocalChannelReader.cpp	-log	18 天前
OmniLocalChannelReader.h	[fix] Fix OOM caused by repeatedly canceling jobs.	3 个月前
OmniLocalInputChannel.cpp	rescal recover	3 个月前
OmniLocalInputChannel.h	to aligned avoid submit resume cleancode	3 个月前
RecoveredInputChannel.cpp	Fixed recovered buffer to recycle	2 个月前
RecoveredInputChannel.h	Fix restoreGates call to RequestPartitions to not depend on taskType.	2 个月前
RemoteDataFetcherBridge.cpp	to aligned avoid submit resume cleancode	3 个月前
RemoteDataFetcherBridge.h	update with yellow zone	7 个月前
RemoteInputChannel.cpp	Merge remote-tracking branch 'omnistream/master' into recover-3.27 # Conflicts: # cpp/core/utils/threads/CompletableFutureV2.h # cpp/jni/bridge/OmniTaskBridgeImpl2.cpp # cpp/runtime/checkpoint/CheckpointOptions.cpp # cpp/runtime/checkpoint/CheckpointOptions.h # cpp/runtime/checkpoint/RescaleMappings.h # cpp/runtime/checkpoint/TaskStateSnapshot.cpp # cpp/runtime/checkpoint/TaskStateSnapshotDeserializer.cpp # cpp/runtime/checkpoint/channel/ChannelStateSerializer.cpp # cpp/runtime/checkpoint/channel/ChannelStateSerializer.h # cpp/runtime/checkpoint/channel/RecoveredChannelStateHandler.cpp # cpp/runtime/checkpoint/channel/SequentialChannelStateReader.cpp # cpp/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.cpp # cpp/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.h # cpp/runtime/event/SubtaskConnectionDescriptor.h # cpp/runtime/io/checkpointing/InputProcessorUtil.h # cpp/runtime/io/network/api/serialization/EventSerializer.cpp # cpp/runtime/io/network/partition/CheckpointedResultPartition.h # cpp/runtime/partition/PipelinedResultPartition.cpp # cpp/runtime/partition/PipelinedSubpartitionView.cpp # cpp/runtime/partition/ResultPartitionFactory.cpp # cpp/runtime/partition/consumer/BufferManager.h # cpp/runtime/partition/consumer/InputChannelInfo.h # cpp/runtime/partition/consumer/InputGate.h # cpp/runtime/partition/consumer/LocalRecoveredInputChannel.h # cpp/runtime/partition/consumer/OmniLocalInputChannel.cpp # cpp/runtime/partition/consumer/RecoveredInputChannel.cpp # cpp/runtime/partition/consumer/RecoveredInputChannel.h # cpp/runtime/partition/consumer/RemoteInputChannel.cpp # cpp/runtime/partition/consumer/RemoteInputChannel.h # cpp/runtime/partition/consumer/RemoteRecoveredInputChannel.h # cpp/runtime/partition/consumer/SingleInputGate.cpp # cpp/runtime/partition/consumer/SingleInputGate.h # cpp/runtime/partition/consumer/SingleInputGateFactory.cpp # cpp/runtime/state/memory/ByteStreamStateHandle.h # cpp/runtime/taskmanager/OmniTask.cpp # cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h # cpp/streaming/runtime/io/OmniStreamOneInputProcessor.cpp # cpp/streaming/runtime/tasks/omni/OmniStreamTask.cpp # cpp/test/runtime/io/checkpointing/CheckpointedInputGateTest.cpp # cpp/test/runtime/io/checkpointing/MockClasses.h # cpp/test/runtime/io/checkpointing/MockInputGate.h	3 个月前
RemoteInputChannel.h	rescal recover	3 个月前
RemoteRecoveredInputChannel.h	序列化器 TimeWindow::Serializer	20 天前
SingleInputGate.cpp	[feature] Session window (Nexmark Q11) can be executed normally with parallelism > 1.	2 个月前
SingleInputGate.h	Fix restoreGates call to RequestPartitions to not depend on taskType.	2 个月前
SingleInputGateFactory.cpp	Fix restoreGates call to RequestPartitions to not depend on taskType.	2 个月前
SingleInputGateFactory.h	Support for unaligned checkpoint restore with flink mode	3 个月前