Task Summary
Add ResultSchemaSpec pinning the canonical column layout of ResultSchema. Schema drift in this file silently breaks downstream readers, so a test pinning the column names and types is valuable:
runtimeStatisticsSchema exposes the canonical columns in order
runtimeStatisticsSchema pins the type of every column (operatorId STRING; time TIMESTAMP; inputTupleCnt/inputTupleSize/outputTupleCnt/outputTupleSize/dataProcessingTime/controlProcessingTime/idleTime LONG; numWorkers/status INTEGER)
consoleMessagesSchema exposes a single STRING message column
Priority
P3 – Low
Task Type
Task Summary
Add
ResultSchemaSpecpinning the canonical column layout ofResultSchema. Schema drift in this file silently breaks downstream readers, so a test pinning the column names and types is valuable:runtimeStatisticsSchemaexposes the canonical columns in orderruntimeStatisticsSchemapins the type of every column (operatorIdSTRING;timeTIMESTAMP;inputTupleCnt/inputTupleSize/outputTupleCnt/outputTupleSize/dataProcessingTime/controlProcessingTime/idleTimeLONG;numWorkers/statusINTEGER)consoleMessagesSchemaexposes a single STRINGmessagecolumnPriority
P3 – Low
Task Type