1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
#pragma once
#include <yql/essentials/core/expr_nodes/yql_expr_nodes.h>
#include <yql/essentials/ast/yql_expr.h>
#include <util/datetime/base.h>
namespace NYql::NHopping {
struct THoppingTraits {
TString Column;
NYql::NNodes::TCoHoppingTraits Traits;
ui64 Hop;
ui64 Interval;
ui64 Delay;
};
struct TKeysDescription {
TVector<TString> PickleKeys;
TVector<TString> MemberKeys;
TVector<TString> FakeKeys;
TKeysDescription(const TStructExprType& rowType, const NYql::NNodes::TCoAtomList& keys, const TString& hoppingColumn);
TExprNode::TPtr BuildPickleLambda(TExprContext& ctx, TPositionHandle pos) const;
TExprNode::TPtr BuildUnpickleLambda(TExprContext& ctx, TPositionHandle pos, const TStructExprType& rowType);
TVector<NYql::NNodes::TCoAtom> GetKeysList(TExprContext& ctx, TPositionHandle pos) const;
TVector<TString> GetActualGroupKeys() const;
bool NeedPickle() const;
TExprNode::TPtr GetKeySelector(TExprContext& ctx, TPositionHandle pos, const TStructExprType* rowType);
};
TString BuildColumnName(const NYql::NNodes::TExprBase& column);
bool IsLegacyHopping(const TExprNode::TPtr& hoppingSetting);
void EnsureNotDistinct(const NYql::NNodes::TCoAggregate& aggregate);
TMaybe<THoppingTraits> ExtractHopTraits(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx, bool analyticsMode);
TExprNode::TPtr BuildTimeExtractor(const NYql::NNodes::TCoHoppingTraits& hoppingTraits, TExprContext& ctx);
TExprNode::TPtr BuildInitHopLambda(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx);
TExprNode::TPtr BuildUpdateHopLambda(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx);
TExprNode::TPtr BuildMergeHopLambda(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx);
TExprNode::TPtr BuildFinishHopLambda(
const NYql::NNodes::TCoAggregate& aggregate,
const TVector<TString>& actualGroupKeys,
const TString& hoppingColumn,
TExprContext& ctx);
TExprNode::TPtr BuildSaveHopLambda(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx);
TExprNode::TPtr BuildLoadHopLambda(const NYql::NNodes::TCoAggregate& aggregate, TExprContext& ctx);
} // namespace NYql::NHopping
|
