MCPcopy Create free account
hub / github.com/ByConity/ByConity / getBlockWithAllStreamData

Function getBlockWithAllStreamData

programs/copier/Internals.cpp:87–90  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

85}
86
87Block getBlockWithAllStreamData(const BlockInputStreamPtr & stream)
88{
89 return squashStreamIntoOneBlock(stream)->read();
90}
91
92
93bool isExtendedDefinitionStorage(const ASTPtr & storage_ast)

Callers 3

processPartitionPieceTaskImplMethod · 0.85
getRemoteCreateTableMethod · 0.85
getShardPartitionsMethod · 0.85

Calls 2

squashStreamIntoOneBlockFunction · 0.85
readMethod · 0.45

Tested by

no test coverage detected