Skip to content

Commit cd2b20d

Browse files
committed
Added TopN and Distinct recipe creator
1 parent 0be0443 commit cd2b20d

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

dataikuapi/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,6 @@
33
from apinode_client import APINodeClient
44
from apinode_admin_client import APINodeAdminClient
55

6-
from dss.recipe import GroupingRecipeCreator, JoinRecipeCreator, StackRecipeCreator, WindowRecipeCreator, SyncRecipeCreator, SamplingRecipeCreator, SQLQueryRecipeCreator, CodeRecipeCreator, SplitRecipeCreator, SortRecipeCreator
6+
from dss.recipe import GroupingRecipeCreator, JoinRecipeCreator, StackRecipeCreator, WindowRecipeCreator, SyncRecipeCreator, SamplingRecipeCreator, SQLQueryRecipeCreator, CodeRecipeCreator, SplitRecipeCreator, SortRecipeCreator, TopNRecipeCreator, DistinctRecipeCreator
77

88
from dss.admin import DSSUserImpersonationRule, DSSGroupImpersonationRule

dataikuapi/dss/recipe.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,14 @@ class SortRecipeCreator(SingleOutputRecipeCreator):
222222
def __init__(self, name, project):
223223
SingleOutputRecipeCreator.__init__(self, 'sort', name, project)
224224

225+
class TopNRecipeCreator(DSSRecipeCreator):
226+
def __init__(self, name, project):
227+
DSSRecipeCreator.__init__(self, 'topn', name, project)
228+
229+
class DistinctRecipeCreator(SingleOutputRecipeCreator):
230+
def __init__(self, name, project):
231+
SingleOutputRecipeCreator.__init__(self, 'distinct', name, project)
232+
225233
class GroupingRecipeCreator(SingleOutputRecipeCreator):
226234
def __init__(self, name, project):
227235
SingleOutputRecipeCreator.__init__(self, 'grouping', name, project)

0 commit comments

Comments
 (0)