mkql_time_order_recover.h 464 B

12345678910111213141516
  1. #pragma once
  2. #include <yql/essentials/minikql/computation/mkql_computation_node.h>
  3. namespace NKikimr::NMiniKQL {
  4. IComputationNode* TimeOrderRecover(const TComputationNodeFactoryContext& ctx,
  5. TRuntimeNode inputFlow,
  6. TRuntimeNode inputRowArg,
  7. TRuntimeNode rowTime,
  8. TRuntimeNode inputRowColumnCount,
  9. TRuntimeNode outOfOrderColumnIndex,
  10. TRuntimeNode delay,
  11. TRuntimeNode ahead,
  12. TRuntimeNode rowLimit);
  13. } //namespace NKikimr::NMiniKQL